基于RocketMQ的分布式事务是如何保证发送端和消费端的一致性的?
如图,这是RocketMQ的实现事务消息的流程图.大体步骤解读可以这样认为: 事务发起方首先发送prepare消息到MQ Server. MQ Server向事务发起方ACK确认消…
事务性消息是什么意思？分布式事务和事务消息有什么区别和联系？
分布式事务应该是涉及两个事务的提交，网上看到的demo代码，都是一个生产者的本地事务，而消费者只是业务处理然后返回接收消息成功的状态，没有写成了…
RocketMQ 客户端的负载均衡算法是否会导致某一时刻的重复消费？
问题描述 因为consumer的负载均衡是通过获取某一个Topic所关联的所有Broker来进行均衡算法，选择具体“订阅”哪一个QueueId来消费。但是每一个Consum…
RocketMQ broker busy 问题
公司用的是rocketmq消息中间件，随着业务量的增长，最近偶尔会报：[TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in q…
rocketmq官方的Order Message Example的一些疑问？
问题描述 在官网学习rocketmq的例子代码有疑问，链接：http://rocketmq.apache.org/do... 是 Subscription message sample code 里面多个if判断取模…
sendDefaultImpl call timeoutRocketmq
在使用Rocketmq队列服务时，服务端看日志已经启动成功了，但使用官方客户端调用的代码执行时，就抛出了上面的错误。我使用Rocketmq的版本为4.3.0。下…
RocketMQ 设置 brokerIP1 无效
RocketMQ 设置 brokerIP1 无效，默认会找到docker 的地址，导致无法连接到broker 配置： 2018-06-20 21\:00\:56 INFO main - namesrvAddr=127.0.0.1:…
rocketmq4.2版本，怎么在win7环境下安装
在win7环境下安装rocketmq4.2版本，官网没有windows的安装教程，根据网上的教程都是旧版本的，都是说启动mqnamesrv.exe，在4.2版本根本就没有这个文…
