本文主要是介绍第十九章 : Spring Boot 集成RabbitMQ(三),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
第十九章 : Spring Boot 集成RabbitMQ(三)
前言
本章节重点:RabbitMQ消息确认机制的代码示例:生产者消息确认机制、Return消息机制、消费端ACK和Nack机制3种消息确认模式。
Springboot 版本 2.3.2.RELEASE ,RabbitMQ 3.9.11,Erlang 24.2
消息确认的场景
使用RabbitMQ很可能造成消息丢失,导致业务中断的情况,例如:
-
生产者发送消息到RabbitMQ服务器失败。
-
RabbitMQ服务器自身故障导致消息丢失。
-
消费者处理消息失败。
针对上面的情况,RabbitMQ提供了多种消息确认机制,确保消息的正常处理,主要有 生产者消息确认机制
、Return消息机制
、消费端ACK和Nack机制
3种消息确认模式。
生产者消息确认机制示例
-
修改配置文件
修改application.properties配置文件,增加消息确认机制的相关配置,示例如下:
# 开启确认机制 spring.rabbitmq.publisher-confirm-t
这篇关于第十九章 : Spring Boot 集成RabbitMQ(三)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!