如何保证消息不被重复消费
消息重复消费的话其实就是考虑怎么保证系统的一个幂等性。
这个其实还是得结合业务来说吧，
比如你拿个数据要写库，你先根据主键查一下，如果这数据都有了，你就别插入了，update 一下好吧。
比如你是写 Redis，那没问题了，反正每次都是 set，天然幂等性。
比如你不是上面两个场景，那做的稍微复杂一点，你需要让生产者发送每条数据的时候，里面加一个全局唯一的 id，类似订单 id 之类的东西，然后你这里消费到了之后，先根据这个 id 去比如 Redis 里查一下，之前消费过吗？如果没有消费过，你就处理，然后这个 id 写 Redis。如果消费过了，那你就别处理了，保证别重复处理相同的消息即可。
比如基于数据库的唯一键来保证重复数据不会重复插入多条。因为有唯一键约束了，重复数据插入只会报错，不会导致数据库中出现脏数据
消息的五种模型
简单模型（一个生产方，一个消费方），工作模型，发布订阅，
路由，主题
消息丢失怎么办
数据的丢失问题，它可能出现在生产者、MQ、消费者中，分三种情况吧。
https://www.jianshu.com/p/4491cba335d1
如何解决消息队列的延时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时呢？
https://www.jianshu.com/p/5f4b3a520719