springboot集成rabbitmq 消息交换机confirm异步回调配置

Spring Boot 集成 RabbitMQ 时，若想利用消息交换机 (Exchange) 的确认模式（Confirm Exchange），并设置异步回调处理消息确认，通常需要在配置文件中添加特定设置，并创建一个消费者类来处理回调。以下是基本步骤：

1. **启用RabbitMQ支持**：首先，在`application.properties`或`application.yml`文件中添加RabbitMQ的连接信息：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

2. **配置Exchange和Queue**：确认交换机 (`confirm-exchange`) 和队列 (`confirm-queue`) 可能需要分别配置：

spring.rabbitmq.exchanges:
  confirm-exchange:
    type: direct
    durable: true
    autoDelete: false
    internal: false
    arguments:
      x-dead-letter-exchange: dead-letter-exchange # 死信交换机

spring.rabbitmq.queues:
  confirm-queue:
    bindings:
      - exchange: confirm-exchange
        routingKey: confirm.# # 匹配所有路由键
        queue: confirm-queue
        arguments:
          x-message-ttl: 30000 # 30秒超时时间

3. **配置消费者**：创建一个消费确认消息的消费者类，例如 `ConfirmMessageConsumer`，继承自 `RabbitTemplateAware` 并实现 `RabbitListener` 接口：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ConfirmMessageConsumer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @RabbitListener(queues = "confirm-queue", consumerProperties = "x-dead-letter-exchange=dead-letter-exchange")
    public void handleConsumeAck(Message message) {
        // 处理收到的消息确认，比如记录日志、更新状态等
        String correlationId = message.getHeaders().get("correlationId");
        System.out.println("Received acknowledge for correlation ID: " + correlationId);
        
        try {
            // 发送消息确认，如采用AMQP的Confirm模式，则调用confirmSelect()
            rabbitTemplate.confirmSelect();
        } catch (IOException e) {
            // 处理确认失败的情况
            e.printStackTrace();
        }
    }
}

4. **开启异步回调**：确保在发送消息时使用 `sendAndDeclare` 或 `convertAndSend` 方法，它们会自动触发回调处理：

@Autowired
private RabbitTemplate rabbitTemplate;

// 发送消息
rabbitTemplate.convertAndSend("exchange-name", "routing-key", yourPayload, headers -> {
    headers.put("correlationId", generateCorrelationId()); // 设置关联ID
});