Spring Boot集成RabbitMQ发送消息后如何获取MessageId？

我懂你想要的是在发送RabbitMQ消息时，能拿到一个类似IBM MQ里JMS MessageId的唯一标识对吧？其实RabbitMQ本身没有像JMS那样自动生成并返回MessageId的默认机制，但我们可以通过两种方式轻松实现这个需求，下面给你详细拆解：

方式一：自定义生成MessageId（最直接，贴合JMS的使用习惯） #

这种方式和JMS的逻辑最像——我们自己生成一个全局唯一的ID，绑定到消息属性里，发送前就能直接拿到这个ID，完全符合你想要的使用体验。

步骤很简单：

1. 用UUID（或者分布式ID生成器）生成唯一标识；
2. 通过MessagePostProcessor把这个ID设置到消息的messageId属性中；
3. 可选：配合CorrelationData做发送确认，确保消息成功投递到Broker。

示例代码：

import org.springframework.amqp.core.MessagePostProcessor;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.support.CorrelationData;
import java.util.UUID;

// 生成唯一MessageId
String messageId = UUID.randomUUID().toString();
// 关联CorrelationData，用于后续的发送确认（可选）
CorrelationData correlationData = new CorrelationData(messageId);

// 发送消息并设置MessageId
rabbitTemplate.convertAndSend("", queueName, message, (MessagePostProcessor) msg -> {
    // 把自定义ID设置为消息的MessageId
    msg.getMessageProperties().setMessageId(messageId);
    // 还可以添加类似JMS的时间戳属性
    msg.getMessageProperties().setTimestamp(new java.util.Date());
    return msg;
}, correlationData);

// 此时你已经拿到了这个MessageId，可以直接记录或业务使用
System.out.println("发送的消息MessageId: " + messageId);

方式二：通过发布确认回调获取标识（适合需要Broker端确认的场景） #

如果希望依赖RabbitMQ Broker的投递确认来获取标识，首先得开启RabbitMQ的发布确认功能，然后通过回调拿到关联的ID（或者Broker的投递标签）。

首先在application.yml里开启发布确认：

spring:
  rabbitmq:
    host: your-rabbit-host
    port: 5672
    username: guest
    password: guest
    # 开启发布确认，correlated类型会触发回调
    publisher-confirm-type: correlated
    # 可选：开启路由失败的消息返回
    publisher-returns: true

然后配置RabbitTemplate的确认回调：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.support.CorrelationData;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public RabbitTemplate rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        
        // 设置发布确认回调
        rabbitTemplate.setConfirmCallback((CorrelationData correlationData, boolean ack, String cause) -> {
            if (ack) {
                // 消息成功投递到Broker
                if (correlationData != null) {
                    // 这里的ID就是我们发送时绑定的MessageId
                    System.out.println("消息成功投递，MessageId: " + correlationData.getId());
                }
            } else {
                // 消息投递失败，处理异常逻辑
                System.err.println("消息投递失败，原因: " + cause);
            }
        });
        
        return rabbitTemplate;
    }
}

发送消息的代码和方式一一致，通过CorrelationData绑定自定义的messageId，就能在回调里拿到确认后的标识。

为什么之前用MessagePostProcessor没成功？ #

大概率是你没有明确调用msg.getMessageProperties().setMessageId()来设置标识——RabbitMQ默认不会自动填充这个字段，必须手动给消息添加这个属性，才能拿到类似JMS的MessageId。

内容的提问来源于stack exchange，提问作者Anand Varkey Philips