1. Confirm消息确认机制
- 消息确认,是指生产者发送消息给broker,然后broker会给生产者一个应答;
- 生产者接收应答,用来确定该消息是否正常发送到broker,这种方式也是消息可靠性投递的核心保障。
2. Confirm确认消息的实现
- 在channel上开启确认模式: channel.confirmSelect();
- 在channel上添加监听:addConfirmListener,监听成功和失败的结果,根据具体的结果对消息进行重新发送、记录日志等后续处理。
3. Return消息机制
- Return Listener用于处理一些不可路由的消息;
- 消息生产者,通过指定一个Exchange和Routingkey,把消息送达到某一个队列中去,然后消费者监听队列,进行消费处理操作;
- 但某些情况下,如果我们在发送消息的时候,当前的exchange不存在或者指定的路由key路由不到,这个时候如果我们需要监听这种不可达的消息,就需要Return Listener!
4. Return关键的配置项
mandatory:如果为true,则监听器会接收到路由不可达的消息,然后进行后续处理;如果为false,则broker端会自动删除该消息!