怎么保证消息的幂等性
出现非幂等性的情况
- 1、生产者已把消息发送到mq，在mq给生产者返回确认消息的时候网络中断，故生产者未收到确定信息，生产者认为消息未发送成功，但实际情况是，mq已成功接收到了消息，在网络重连后，生产者会重新发送刚才的消息，造成mq接收了重复的消息
- 2、消费者在消费mq中的消息时，mq已把消息发送给消费者，消费者在给mq返回ack时网络中断，故mq未收到确认信息，该条消息会重新发给其他的消费者，或者在网络重连后再次发送给该消费者，但实际上该消费者已成功消费了该条消息，造成消费者消费了重复的消息；
解决思路
- 1.消息发送者发送消息时携带一个全局唯一的消息id
- 2.消费者获取消费后先根据id在redis/db中查询是否存在消费记录。
- 3.如果没有消费过就正常消费，消费完毕后写入redis/db
- 4.如果消息消费过就直接舍弃