如何保证RabbilMQ消息可靠传输？

201 阅读 0 评论 133 点赞

我是靠谱客的博主无语萝莉，这篇文章主要介绍如何保证RabbilMQ消息可靠传输？，现在分享给大家，希望可以做个参考。

生产者丢失消息：
RabbitMQ提供transaction和confirm模式来确保消息不丢失。transaction模式：发送消息是开启事务，如果消息发送异常则进行回滚，如果发送成功则进行提交。confirm模式：发布的消息会获得以个唯一的ID一但消息被发送到所匹配的队列之后RabbitMQ就会发送一个ACK给生产者，让生产者知道消息已经到达目的对列了。如果rabbitMQ能处理给消息会返回一个Nack消息。
消息队列丢失消息：
一般会持久化磁盘配置，这个持久化可以和confirm机制配合使用，在消息持久化磁盘之后再给生产者发送一个Ack消息，这样，如果在消息持久化磁盘之前rabbitMQ阵亡了,那么生产者就接受不到消息就会自动重新发送消息
消费者丢失消息：处理消息成功后手动回复确认消息。