如何获取Spring Cloud Stream Message对应的原生消息ID

通用实现方案 #

存在不依赖特定中间件的通用获取方案，Spring Cloud Stream 已经为所有官方绑定器统一了原生消息ID的标准头规范，不需要适配不同中间件的自定义头：

• 通用获取键为 org.springframework.cloud.stream.messaging.NativeMessageHeaderAccessor.NATIVE_MESSAGE_ID 常量，你可以直接从接收的 Message 头中读取该值即可。
• 代码示例：

import org.springframework.cloud.stream.messaging.NativeMessageHeaderAccessor;
import org.springframework.messaging.Message;

// 你的消息消费逻辑
public void consume(Message<String> message) {
    // 读取原生消息ID，不同中间件返回的类型略有差异，可根据实际场景强转
    Object nativeMessageId = message.getHeaders().get(NativeMessageHeaderAccessor.NATIVE_MESSAGE_ID);
    // GCP Pub/Sub 场景下该值为String类型的原生Pub/Sub消息ID，可直接强转为String使用
    String gcpPubSubNativeId = (String) nativeMessageId;
}

常见疑问说明 #

你问题中提到的 id 头是 Spring Messaging 框架内部为所有 Message 自动生成的UUID，仅用于Spring上下文内的消息唯一标识，和底层消息中间件无关，并不是你需要的原生ID。

特殊场景补充（仅GCP Pub/Sub可用，非通用） #

如果你需要获取GCP Pub/Sub的完整原生消息对象，可以读取头 GcpPubSubHeaders.ORIGINAL_MESSAGE 拿到原生的 com.google.pubsub.v1.PubsubMessage 实例，直接调用 getMessageId() 方法获取ID，但该方案依赖GCP Pub/Sub绑定器的特定实现，不具备跨中间件通用性。

内容的提问来源于stack exchange，提问作者John Feminella