RabbitMQ消息确认机制-可靠抵达

为了确保消息的可靠传递，可以采用事务消息，但其性能会大幅下降。为此，引入了确认机制以提高效率。确认机制包括生产者端的ConfirmCallback和ReturnCallback以及消费者端的ack机制。 - **ConfirmCallback**：通过设置`spring.rabbitmq.publisher-confirms=true`或`spring.rabbitmq.publisher-confirm-type=correlated`开启，并在RabbitTemplate中设置确认回调，当消息被成功接收时触发。 - **ReturnCallback**：通过配置`spring.rabbitmq.publisher-returns=true`及`spring.rabbitmq.template.mandatory=true`启用，在消息未能正确路由到队列时触发回调。 - **消费者确认**：默认情况下，消费者自动确认消息；若需手动控制，则应将`spring.jms.listener.acknowledge-mode`设为`manual`，并在监听器中实现具体的消息签收（`basicAck`）或拒收逻辑（`basicNack`/`basicReject`）。这样即使处理过程中出现问题，也能保证消息不会丢失。

2648
0
java
总结
MQ
RabbitMQ
RabbitMQ消息确认机制-可靠抵达

RabbitMQ的安装及使用

RabbitMQ是一款使用Erlang开发的开源消息中间件，支持AMQP协议。它具有高可靠性、灵活的消息分发策略（如简单模式、工作队列模式等）、集群支持、多种协议兼容性以及丰富的客户端语言支持。RabbitMQ还提供了可视化管理界面和插件扩展机制。通过Docker可以方便地安装和配置RabbitMQ，并设置为开机自启。文章详细介绍了四种类型的Exchange（Direct, Fanout, Topic, Headers）及其应用场景，同时展示了如何在Spring Boot项目中整合RabbitMQ，包括依赖引入、配置设置、组件启用及消息发送与接收的具体实现。这为开发者提供了一个全面了解和使用RabbitMQ作为消息中间件的基础指南。

2814
0
java
总结
springboot
MQ
RabbitMQ的安装及使用