当然,rocketmq内并没有提供这种实现,由于各个业务的差异性,rocketmq官方让业务人员(程序猿)自己去实现幂等性 何为幂等性,即生产者生产一条消息,消费者只能消费一次,因为各个mq都实现了消息消费失败重试机制,因此这些都可能使消息 消费重复,所以可选如下方案:

file

以上只是其中的一种,还可以用redis等数据库作为校验消息的工具,