最近对系统进行压测，发现发送消息到消息队列的时候出现如下错误： com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start ...

　　rocketmq 集群启动后，项目连接不上，总是报错 senddefaultimpl call timeout，查看rocket-console ，显示rocketmq 集群地址都为内网地址，所以问题出在配置上 修改broker 的配置如下，注意brokerIP1 这个配置必须有 ...

缘起 在RocketMQ客户端的DefaultMQPushConsumer的start方法被执行时，时不时会报出invokeSync call timeout异常，如下： 如果着急马上找到解决办法，可以直接跳到解决办法。不过，授人以鱼，不如授之以渔。还是建议把寻找解决办法的过程看完，第一 ...

待续 ...

...

生产销售系统出现 504 Gateway Timeout 异常，其实就是服务器响应太慢导致nginx带来超时，先不说服务端慢的优化问题；只是单纯的解决504。到网上发现了一篇文章fix it Add these variables to nginx.conf file ...

一、说明 分为两种，一种是直接发消息，client内部有选择queue的算法，不允许外界改变。还有一种是可以自定义queue的选择算法（内置了三种算法，不喜欢的话可以自定义算法实现）。 二、源码 1、send(msg, mq) 1.1、使用场景 有时候我们不希望默认 ...

Kafka重复消费与消息丢失参考： https://www.cnblogs.com/kaleidoscope/p/9763053.html https://blog.csdn.net/qingqi ...