HTTP Interceptor 无法为 RabbitMQ 消息添加 trace-id，因其仅作用于 HTTP 请求生命周期，而 RabbitMQ 发送是脱离请求上下文的异步操作；正确做法是在 AMQP 封装层中主动提取 trace-id 并注入消息 headers。
Interceptor 本身不处理发往 RabbitMQ 的消息，它只拦截 HTTP 请求/响应或微服务调用的入站/出站数据流。想给发往 RabbitMQ 的消息自动加 trace-id，得在消息发送环节介入，而不是靠 HTTP 拦截器。
为什么不能直接用 HTTP Interceptor 给 RabbitMQ 消息加 trace
HTTP Interceptor 运行在请求生命周期内，作用域是 ExecutionContext 中的 HttpArgumentsHost。而 RabbitMQ 发送（比如调用 amqpService.publish() 或 client.emit()）通常是服务层异步操作，脱离了原始请求上下文 —— 尤其当消息在定时任务、后台 Job、或非请求触发的逻辑中发出时，trace-id 已不可见。
-
Interceptor拦截不到publish()调用本身，它不监听任意函数调用 - 即使你在 Controller 里发消息，
Interceptor也只在响应返回前生效，无法“注入”到后续异步的 AMQP 调用中 - RabbitMQ 消息是字节流，没有内置上下文传播机制，必须手动把 trace 信息塞进
headers或properties
正确做法：封装 AMQP 发送逻辑 + 主动注入 trace-id
核心思路是把 trace 提取和消息发送耦合在一个可控的封装层里，避免每个 publish() 都重复写提取逻辑。推荐在自定义 RabbitMQService 中统一处理：
- 从
cls-hooked或@nestjs/terminus的Tracer实例中获取当前trace-id（前提是已集成 OpenTelemetry 或类似方案） - 构造
options.headers时显式写入'trace-id': currentTraceId - 确保所有业务代码都通过该封装方法发消息，而非直调
amqpService.publish()
示例（简化）：
DMap GL地图JSAPI（dmapgl）开发指南。用于编写、审查、调试 DMap 地图 API 代码，涵盖地图初始化、覆盖物渲染、图层管理、事件处理、控件交互等任务。当用户提及 dmap、dmapgl、jsapi‑gl 或相关地图开发需求时自动触发。
export class TracedRabbitMQService {
constructor(
private readonly amqpService: AmqpConnection,
private readonly tracer: Tracer, // 来自 @opentelemetry/api
) {}
async publishWithTrace(
exchange: string,
routingKey: string,
payload: any,
options: amqp.Options.Publish = {},
) {
const span = this.tracer.getCurrentSpan();
const traceId = span?.spanContext().traceId ?? 'unknown';
const fullOptions = {
...options,
headers: {
...options.headers,
'trace-id': traceId,
},
};
await this.amqpService.publish(exchange, routingKey, Buffer.from(JSON.stringify(payload)), fullOptions);
}
}
容易漏掉的兼容点：RPC 场景下的 trace 透传
如果你用 @RabbitRPC 做服务间调用，光在发送端加 trace-id 不够 —— 接收端还得能从消息头里读出来，并继续向下传递。否则链路会断在 RPC 入口。
- 接收端需在
@RabbitRPC处理器里解析msg.fields.headers['trace-id']（注意：不是msg.content，而是 AMQP 协议层的headers） - 若该处理器内部还要发新消息（比如调下游），必须把刚拿到的
trace-id再带进去，形成接力 - 不要依赖 NestJS 的
REQUESTscope 注入，因为@RabbitRPC方法运行在 AMQP 上下文中，不是 HTTP
换句话说，trace propagation 是端到端的手动接力，没有框架自动帮你跨协议续传。
最常被忽略的是：RabbitMQ 消息头里的 trace-id 是字符串，而 OpenTelemetry SDK 期望的是 SpanContext 对象；直接塞进去会导致下游 OTel SDK 无法识别。务必确认你用的 tracing 库是否支持从 header 自动还原 span 上下文 —— 否则得自己做格式转换。
