开发者社区 > 云原生 > 正文

关于消息顺序的问题

1、双主双从结构,两个master上面都有TestTopic

2、使用局部顺序消息特性

Message msg = new Message("TestTopic", tags[i % tags.length], "KEY" + i, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET)); SendResult sendResult = producer.send(msg, new MessageQueueSelector() { @Override public MessageQueue select(List mqs, Message msg, Object arg) { Integer id = (Integer) arg; int index = id % mqs.size(); return mqs.get(index); } }, orderId);

3、首先发送一条消息,orderID=123456,假设第一条消息发送到broker-a的队列里面。在发送下一条orderID=123456的消息之前关闭broker-a的master节点和slave节点,这个时候在发送消息,消息就会发送到broker-b的队列里面了,这样消息就不能发送到一个队列里面了,严格局部顺序就不能保证了

期待严格的消息顺序,像broker-a只有master节点宕机时,后续消息发送直接快速失败,而不是直接发送到另一个master。

当broker-a的主从都宕机时,就会出现发送到broker-b,这样就不能保证严格消息顺序

rocketmq 4.3.0 2 namesrv 2 master 2 slave

或者是设计时就考虑到这种情况,只是RocketMQ不保证严格的顺序消息,在消费端还是要做一定的顺序判断处理

原提问者GitHub用户makabakaboom

展开
收起
芬奇福贵 2023-05-26 16:15:10 165 0
1 条回答
写回答
取消 提交回答
  • 使用顺序消息到时候,建议在起始的时候记录一下分区数,防止中间某个服务宕机导致hash值发生变化导致消息乱序。

    原回答者GitHub用户duhengforever

    2023-05-26 18:04:50
    赞同 展开评论 打赏

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载