MQ消息机制如何确认消费了消息？
消息队列如何保证消息能百分百成功被消费
  ⽬前常⽤的消息队列有很多种，如RabbitMQ,下⾯以RabbitMQ为例来讲如何保证消息队列中的信息能百分百被消费掉.
  其中消费队列的⼯作流程如下:
.我们可以再增加⼀个机制，增加⼀个确认机制：
流程解释:
1）订单服务⽣产者再投递消息之前，先把消息持久化到Redis或DB中，建议redis，⾼性能。消息的状态为发送中。
activemq启动报错
2）confirm机制监听消息是否发送成功？如ack成功消息，删除redis中此消息。
3）如果nack不成功的消息，这个可以根据⾃⾝的业务选择是否重发此消息。也可以删除此消息，由⾃⼰的业务决定。
4）这边加了个定时任务，来拉取隔⼀定时间了，消息状态还是为发送中的，这个状态就表明，订单服务是没有收到ack成功消息。
5）定时任务会作补偿性的投递消息。这个时候如果MQ回调ack成功接收了，再把redis中此消息删除
这种⽅案其实就是加上⼀个补偿机制，不管MQ有没有真正的接收到，只要缓存redis中的消息还是发送中的状态，就意味着这个消息没有成功的投递出去，也没有被消费，定时任务启动时就要重新发送.
当然定时任务那边我们还可以加上⼀个补偿的次数，如果⼤于3次，还是没有收到ack消息，那就直接把消息的状态设置为【失败】，由⼈⼯去排查到底是为什么？
不过这样的⽅案，就会有可能发送多次相同的消息，很有可能MQ已经收到了消息，就是ack消息回调时出现⽹络故障，没有让⽣产者收到。那就要要求消费者⼀定在消费的时候保障幂等性。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。