RabbitMQ事务和Confirm发送方消息确认

正常情况下,如果消息经过交换器进入队列就可以完成消息的持久化,但如果消息在没有到达broker之前出现意外,那就造成消息丢失,有没有办法可以解决这个问题? RabbitMQ有两种方式来解决这个问题: 通过AMQP提供的事务机制实现; 使用发送者确认模式实现; 一、事务使用 事务的实现主要是对信道(Channel)的设置,主要的方法有三个: channel.txSelect()声明启动事务模式; c
相关文章
相关标签/搜索