采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
1、顺序消息希望一个supplierid对应一个messagequeue,这个实际不合理吧,supplierId是有实时增减,messagequeue不可能的数量是初始化决定的,总不能每次增减supplierId的时候修改messagequeue的数量吧2、关于异常处理,顺序消息消费失败是会把这条消息放回队列头是吗?非顺序的是放回队列尾?
固定好编号一一对应,如果修改可以自己做一个控制台。 顺序消费失败后一般就是阻塞,顺序消费的意义在于业务的顺序,如果非要失败也可以后续做补偿处理,没有重回队列的概念
比方说,一个组顺序消息1,2,3,4;producer发送完了,consumer1拿到消息1处理的时候失败了或者直接就down了,这个时候怎么处理消息1?不重回队列让group里的其他consumer重试吗?,那后面几个消息怎么处理?
1挂了其他的就阻塞,等着处理成功后,2 3 4再处理
这样集群的容错性不是很差吗?这样不是和单机的效果一样了吗?
登录后可查看更多问答,登录/注册
理论+实战,系统掌握RocketMQ核心技术, 挑战高并发抗压实战
10.0k 15
1.2k 11
1.0k 7
1.1k 6