RocketMQ关于消息顺序消费和重复消费问题的解决
2018-05-03 本文已影响657人
totohui
RocketMQ作为消息中间件,并没有过多关注这两个问题,实际上交由业务系统解决更为合适。
RocketMQ只保证消息的顺序发送,通过一定算法,将一组顺序消息发送到同一个broker下面的同一个队列,消费者进行顺序监听即可。
1. 消费端处理消息的业务逻辑保持幂等性
2. 保证每条消息都有唯一编号且保证消息处理成功与去重表的日志同时出现
1.幂等性。比如支付成功后的回调,如果订单状态是已支付,直接返回true。
2. 消息去重表。