1. Confirm消息确认机制

  1. 消息确认,是指生产者发送消息给broker,然后broker会给生产者一个应答;
  2. 生产者接收应答,用来确定该消息是否正常发送到broker,这种方式也是消息可靠性投递的核心保障。
    RabbitMQ(七):RabbitMQ的Confirm确认消息和Return消息机制

2. Confirm确认消息的实现

  1. 在channel上开启确认模式: channel.confirmSelect();
  2. 在channel上添加监听:addConfirmListener,监听成功和失败的结果,根据具体的结果对消息进行重新发送、记录日志等后续处理。

3. Return消息机制

  1. Return Listener用于处理一些不可路由的消息;
  2. 消息生产者,通过指定一个Exchange和Routingkey,把消息送达到某一个队列中去,然后消费者监听队列,进行消费处理操作;
  3. 但某些情况下,如果我们在发送消息的时候,当前的exchange不存在或者指定的路由key路由不到,这个时候如果我们需要监听这种不可达的消息,就需要Return Listener!

4. Return关键的配置项

mandatory:如果为true,则监听器会接收到路由不可达的消息,然后进行后续处理;如果为false,则broker端会自动删除该消息!
RabbitMQ(七):RabbitMQ的Confirm确认消息和Return消息机制

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-10-17
  • 2021-10-17
  • 2021-11-09
猜你喜欢
  • 2021-10-17
  • 2021-10-17
  • 2022-12-23
  • 2021-08-11
  • 2021-10-17
  • 2021-12-24
相关资源
相似解决方案