RabbitMQ监听器对应的ServletFilter等价组件是什么？

你已经在Spring Boot Web应用里通过MDCFilter给HTTP请求绑定了UUID到MDC日志上下文，现在想在RabbitMQ监听器里实现类似的链路追踪日志标记对吧？在Spring整合RabbitMQ的生态（Spring AMQP）里，对应的等价组件是方法拦截器（MethodInterceptor），配合Spring的AOP机制或者RabbitMQ监听器的配置来实现，具体来说可以通过自定义RabbitListenerAdvice来完成。

下面给你两种常用的实现方式：

方式一：自定义MethodInterceptor实现MDC上下文管理 #

这种方式和Servlet Filter的逻辑高度相似——在消费消息前给当前线程绑定requestId，消费完成后清理，避免线程池复用导致的MDC污染。

先写拦截器的代码：

import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.slf4j.MDC;
import java.util.UUID;

public class MdcRabbitInterceptor implements MethodInterceptor {
    private static final String REQUEST_ID_KEY = "requestId";

    @Override
    public Object invoke(MethodInvocation invocation) throws Throwable {
        // 优先从消息头获取requestId（如果生产者传递了链路ID的话）
        String requestId = null;
        Object[] args = invocation.getArguments();
        if (args != null && args.length > 0 && args[0] instanceof org.springframework.amqp.core.Message) {
            org.springframework.amqp.core.Message message = (org.springframework.amqp.core.Message) args[0];
            requestId = message.getMessageProperties().getHeaders().get(REQUEST_ID_KEY, String.class);
        }
        // 如果没有获取到，就生成新的UUID
        if (requestId == null) {
            requestId = UUID.randomUUID().toString();
        }
        
        try {
            MDC.put(REQUEST_ID_KEY, requestId);
            // 执行监听器的消息处理逻辑
            return invocation.proceed();
        } finally {
            // 务必清理MDC，否则线程池复用会导致上下文混乱
            MDC.remove(REQUEST_ID_KEY);
        }
    }
}

然后配置这个拦截器，让它作用于所有RabbitMQ监听器：

import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableRabbit
public class RabbitMdcConfig {

    @Bean
    public MdcRabbitInterceptor mdcRabbitInterceptor() {
        return new MdcRabbitInterceptor();
    }

    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory,
                                                                               MdcRabbitInterceptor mdcRabbitInterceptor) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        // 将拦截器加入监听器容器的通知链
        factory.setAdviceChain(mdcRabbitInterceptor);
        return factory;
    }
}

如果只想给某个特定的监听器生效，也可以直接在@RabbitListener注解里指定：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class OrderMessageListener {

    @RabbitListener(queues = "order-queue", adviceChain = "mdcRabbitInterceptor")
    public void handleOrderMessage(String orderJson) {
        // 这里的日志会自动带上MDC中的requestId
        // 比如log.info("处理订单：{}", orderJson);
    }
}

方式二：利用MessagePostProcessor（补充方案） #

如果你只是想在消息消费前处理消息头，MessagePostProcessor可以用来修改消息，但它不负责线程上下文的管理，所以如果要绑定MDC，还是拦截器更合适。不过可以配合使用，比如从消息头提取requestId后交给拦截器处理。

关键注意点 #

• 必须清理MDC：RabbitMQ监听器使用线程池处理消息，如果不清理MDC，后续请求会复用之前的上下文，导致日志追踪混乱。
• 链路ID传递：如果生产者在发送消息时把requestId放到消息头里，消费者直接读取就能实现全链路的统一ID追踪，这比生成新ID更有价值。

内容的提问来源于stack exchange，提问作者Raja Anbazhagan