RabbitMq消息发送确认有哪些注意事项

这篇文章主要介绍“RabbitMq消息发送确认有哪些注意事项”,在日常操作中,相信很多人在RabbitMq消息发送确认有哪些注意事项问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”RabbitMq消息发送确认有哪些注意事项”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

成都创新互联公司总部坐落于成都市区,致力网站建设服务有成都网站设计、网站制作、网络营销策划、网页设计、网站维护、公众号搭建、小程序制作、软件开发等为企业提供一整套的信息化建设解决方案。创造真正意义上的网站建设,为互联网品牌在互动行销领域创造价值而不懈努力!

消息发送确认

生产者发送消息,是先发送消息到Exchange,然后Exchange再路由到Queue。这中间就需要确认两个事情,第一,消息是否成功发送到Exchange;第二,消息是否正确的通过Exchange路由到Queue。
spring提供了两个回调函数来处理这两种消息发送确认。

ConfirmCallback和ReturnCallback

  • 实现ConfirmCallback并重写confirm(CorrelationData correlationData, boolean ack, String cause)回调方法,可以确认消息是否发送到Exchange。

  • 实现ReturnCallback并重写returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey)回调方法,可以确认消息从EXchange路由到Queue失败。注意:这里的回调是一个失败回调,只有消息从Exchange路由到Queue失败才会回调这个方法。

  • 注意,若需要以上两个回调函数生效,需要添加配置
    配置文件:

  •  

  • # 开启发送确认
    spring.rabbitmq.publisher-confirms=true
    # 开启发送失败退回
    spring.rabbitmq.publisher-returns=true
    #指定消息在没有被队列接收时是否强行退回还是直接丢弃
    spring.rabbitmq.template.mandatory=true

 mandatory的作用:

        当mandatory标志位设置为true时,如果exchange根据自身类型和消息routingKey无法找到一个合适的queue存储消息,那么broker会调用basic.return方法将消息返还给生产者;当mandatory设置为false时,出现上述情况broker会直接将消息丢弃;通俗的讲,mandatory标志告诉broker代理服务器至少将消息route到一个队列中,否则就将消息return给发送者;

到此,关于“RabbitMq消息发送确认有哪些注意事项”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!


网页标题:RabbitMq消息发送确认有哪些注意事项
分享URL:http://ybzwz.com/article/johosc.html