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
使用顺序消息到时候,建议在起始的时候记录一下分区数,防止中间某个服务宕机导致hash值发生变化导致消息乱序。
原回答者GitHub用户duhengforever
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。