2、发送方:执行本地事务 4、rocketmq:如果没有接收到任何信息可能超时啦,出了各种异常咋办?回查事务状态,有可能发送方实例已经宕机需要回查同一个生产者组的其他實例来获取状态。具体怎么获取?参考rocketmq的事务消息示例代码即可 5、consumer段消息成功机制保障 检测频率在哪里设置,在broker.conf中设置transactionCheckInterval太长了,如果要結合分布式事务不可能给与这么长的超时时间,1-2秒较合适 检测的时候只会对超时的prepare消息检测,超时时间在哪里设置? 重试几次transactionCheckMax,如果超过这个检测次数丢弃消息,rollback默认是5次,太多了2-3次即可。这里有个难以解决的问题假设producer业务已操作成功,但是所有producer都死了没法囙查,消息被超时rollback导致下游业务接收不到消息。 3、在Master为恢复前都是读取不到其brokerAddr的,因此每次都是从Slave处拉取消息虽然其每次都建议Consumer从Master處读取。 查看指定topic路由信息: 查看指定topic状态: 查看指定topic的消息: