如何为MessagingGateway发送的每条消息自动添加TenantId请求头？

不用修改所有publishEvent调用的前提下，有两种高效的实现方式：

方案一：基于Gateway请求增强器（AbstractGatewayRequestHandlerAdvice） #

这种方式专门针对EventGateway的所有请求做拦截处理，在消息发送前自动注入TenantId头：

1. 实现自定义增强器类

public class TenantIdGatewayAdvice extends AbstractGatewayRequestHandlerAdvice {

    @Override
    protected Object doInvoke(MethodInvocation invocation, Message<?> message) throws Throwable {
        TenantContext tenantContext = TenantContextHolder.getContext();
        // 仅当存在租户信息时添加头
        if (tenantContext != null && tenantContext.getTenantId() != null) {
            Message<?> modifiedMessage = MessageBuilder.fromMessage(message)
                    .setHeader("TenantId", tenantContext.getTenantId())
                    .build();
            return super.doInvoke(invocation, modifiedMessage);
        }
        return super.doInvoke(invocation, message);
    }
}

2. 注册增强器Bean并关联到EventGateway

// 注册增强器Bean
@Bean
public TenantIdGatewayAdvice tenantIdGatewayAdvice() {
    return new TenantIdGatewayAdvice();
}

// 修改EventGateway注解，指定使用该增强器
@MessagingGateway(advice = "tenantIdGatewayAdvice")
public interface EventGateway {
    @Gateway(requestChannel = "SomeChannel")
    void publishEvent(@Header(value = "EventName") String event, @Payload Object payload);
}

这个方案的优势是仅对当前Gateway的请求生效，不会影响其他通道的消息处理，完全不需要修改任何publishEvent的调用代码。

方案二：基于通道拦截器（ChannelInterceptor） #

如果需要对发送到SomeChannel的所有消息统一添加TenantId头，可以使用全局通道拦截器：

@Component
@GlobalChannelInterceptor(patterns = "SomeChannel") // 仅拦截指定通道的消息
public class TenantIdChannelInterceptor implements ChannelInterceptor {

    @Override
    public Message<?> preSend(Message<?> message, MessageChannel channel) {
        TenantContext tenantContext = TenantContextHolder.getContext();
        if (tenantContext != null && tenantContext.getTenantId() != null) {
            return MessageBuilder.fromMessage(message)
                    .setHeader("TenantId", tenantContext.getTenantId())
                    .build();
        }
        return message;
    }
}

这种方式会拦截所有发送到SomeChannel的消息，不管消息来源是哪个Gateway，适合需要对通道做全局处理的场景。

补充说明 #

两种方案都依赖TenantContextHolder的ThreadLocal特性，需要确保在调用publishEvent时，当前线程的TenantContext已经正确设置（比如通过过滤器、AOP等方式在业务代码执行前注入租户信息）。

内容的提问来源于stack exchange，提问作者Hasan Can Saral