spring-boot-starter-amqp 2.3.12如何开启Rabbitmq消息发送去人

<think>好的，我现在需要帮助用户在Spring Boot 2.3.12中使用spring-boot-starter-amqp配置RabbitMQ的消息发送确认功能。首先，我要回忆一下RabbitMQ的发布确认机制，这通常涉及Publisher Confirm和Publisher Return两种机制。确认（Confirm）是指消息成功到达交换机，而返回（Return）则是当消息无法路由到队列时触发的回调。 用户明确提到了publisher confirms，所以重点在于如何启用ConfirmCallback。接下来，我需要查找Spring Boot AMQP的配置方式，特别是2.3.12版本的文档或配置属性。记得在Spring Boot中，配置通常通过application.properties或application.yml文件进行。 根据引用[1]和[4]，用户已经展示了如何配置RabbitMQ的连接信息，比如主机、端口、用户名和密码。现在需要找到与发布者确认相关的配置项。在Spring Boot AMQP中，可能涉及到spring.rabbitmq.publisher-confirms和spring.rabbitmq.publisher-returns属性，但需要注意，随着版本更新，属性名称可能有所变化。例如，旧版本可能使用publisher-confirms，而新版本可能改为publisher-confirm-type。 查阅Spring Boot 2.3.x的文档发现，从2.2版本开始，publisher-confirms已被弃用，改用publisher-confirm-type来启用确认模式。确认类型有三种：NONE（禁用）、SIMPLE（同步等待确认）和CORRELATED（异步回调）。因此，在2.3.12版本中，正确的配置应该是设置spring.rabbitmq.publisher-confirm-type为correlated。 接下来，用户需要在代码中配置RabbitTemplate以处理ConfirmCallback。需要创建一个配置类，可能是@Configuration，然后定义RabbitTemplate并设置ConfirmCallback。同时，如果要启用返回机制（当消息无法路由到队列时），需要设置spring.rabbitmq.publisher-returns为true，并在RabbitTemplate中设置Mandatory为true，这样才会触发ReturnCallback。 还要注意，ConfirmCallback需要实现RabbitTemplate.ConfirmCallback接口，并重写confirm方法。同样的，ReturnCallback需要实现RabbitTemplate.ReturnCallback接口，并重写returnedMessage方法。这些回调方法需要被注册到RabbitTemplate实例中。 此外，需要确保配置文件中的相关属性正确设置，例如在application.yml中添加publisher-confirm-type和publisher-returns。同时，在配置RabbitTemplate时，可能需要设置mandatory属性为true以启用消息返回功能。 最后，用户可能需要测试配置是否正确，例如发送一条消息到不存在的交换机或无法路由的队列，观察是否触发了相应的回调方法。同时，处理异常情况，比如网络问题导致的消息确认失败，确保应用程序的健壮性。 总结步骤：1. 在配置文件中启用publisher-confirm-type和publisher-returns。2. 配置RabbitTemplate，设置Mandatory属性。3. 实现ConfirmCallback和ReturnCallback接口，并将它们注册到RabbitTemplate。4. 测试确认和返回机制是否正常工作。</think>在Spring Boot 2.3.12中启用RabbitMQ消息发送确认功能需通过配置文件与代码回调结合实现。以下是具体配置步骤： ### 一、基础配置 1. **在`application.yml`中启用确认机制** ```yaml spring: rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest # 启用发布者确认模式 publisher-confirm-type: correlated # 启用消息返回机制（路由失败时触发） publisher-returns: true ``` - `publisher-confirm-type: correlated`表示异步接收Broker的确认结果[^1] - `publisher-returns: true`启用消息路由失败回调[^4] 2. **配置RabbitTemplate** ```java @Configuration public class RabbitConfig { @Autowired private RabbitTemplate rabbitTemplate; @PostConstruct public void init() { // 设置Mandatory触发Return回调 rabbitTemplate.setMandatory(true); // 注册确认回调 rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() { @Override public void confirm(CorrelationData correlationData, boolean ack, String cause) { if (ack) { System.out.println("消息到达交换机: " + correlationData); } else { System.out.println("消息未到达交换机: " + cause); } } }); // 注册返回回调 rabbitTemplate.setReturnsCallback(returned -> { System.out.println("消息路由失败: " + returned.getMessage()); }); } } ``` ### 二、功能验证 1. **成功场景**：发送到有效交换机 ```java rabbitTemplate.convertAndSend("validExchange", "routingKey", "message"); ``` 输出：`消息到达交换机: null` 2. **失败场景**：发送到无效交换机 ```java rabbitTemplate.convertAndSend("invalidExchange", "", "message"); ``` 输出：`消息未到达交换机: channel error; protocol method: #method<channel.close>` 3. **路由失败**：发送到有效交换机但无匹配队列 ```java rabbitTemplate.convertAndSend("validExchange", "invalidKey", "message"); ``` 输出：`消息路由失败: (Body:'message' ...)` ### 三、高级配置 1. **超时控制**（可选） ```yaml spring: rabbitmq: template: # 等待确认的超时时间（毫秒） reply-timeout: 5000 ``` 2. **异常处理** ```java @RabbitListener(queues = "confirmQueue") public void handleError(Message message, Channel channel) { // 实现消息消费异常处理逻辑 } ```