confirm消息确认
消息确认是指:生产者投递消息后,如果broker接收到消息后,会给生产者一个应答<br> 接收消息成功,返回true<br> 接收消息失败,返回false<br> 如果无应答,可能与broker服务器tcp通信故障
application添加配置:rabbitemq.publisher-confirms: true #开启消息发布确认(消息成功发送到broker)
代码实现见springboot整合章节
return消息机制
application配置:rabbitmq.publisher-returns: true #开启消息回调监听器<br> rabbitmq.template.mandatory: true
return listener: 用于处理那些无法路由的消息
生产者通过exchange和routingKey,将消息路由到指定的队列中去;消费者监听队列,进行消息消费;在某些情况下,我们指定的exchange不存在,或者指定的key路由不到队列,这些消息就是不可达的消息,这个时候就需要用到return listener监听这些不可达的消息;
关键配置项:Mandatory 如果为true:监听会接收到路由不可达的消息,进行后续处理; 如果为false:broker端会自动删除该消息
代码实现见springboot整合章节