1、重复消费
原因:
(1)系统多次向RocketMQ发送请求
(2)RocketMQ消费完未提交offset宕机
解决办法:幂等性
(1)RocketMQ支持查询是否已发送该消息,不存在则发送,性能偏低
(2)借助Redis,Redis存在写入失败风险
2、消息丢失
(1)生产者->Broker:网络
(2)Broker刷盘:内存中的数据还未刷盘,机器宕机
(3)Broker->消费者:消息还未被消费,通知Broker已消费,消费者宕机
解决办法:

1、重复消费
原因:
(1)系统多次向RocketMQ发送请求
(2)RocketMQ消费完未提交offset宕机
解决办法:幂等性
(1)RocketMQ支持查询是否已发送该消息,不存在则发送,性能偏低
(2)借助Redis,Redis存在写入失败风险
2、消息丢失
(1)生产者->Broker:网络
(2)Broker刷盘:内存中的数据还未刷盘,机器宕机
(3)Broker->消费者:消息还未被消费,通知Broker已消费,消费者宕机
解决办法: