Spring Integration 6.0.0：如何在AbstractRequestHandlerAdvice中获取目标Bean名称

方案一：利用wrapHandler方法结合ThreadLocal（推荐） #

Spring Integration的AbstractRequestHandlerAdvice提供了wrapHandler方法，该方法会在目标handler被包装时调用，此时传入的参数就是实际的http:outbound-gateway实例（属于AbstractReplyProducingMessageHandler子类，已实现BeanNameAware接口）。我们可以重写这个方法，将handler的bean名称存入ThreadLocal，后续在doInvoke方法中直接取出使用，完全无需反射。

示例代码：

public class HttpGatewayLoggingAdvice extends AbstractRequestHandlerAdvice {

    private final ThreadLocal<String> currentGatewayBeanName = new ThreadLocal<>();

    @Override
    protected MessageHandler wrapHandler(MessageHandler handler) {
        // 仅处理AbstractReplyProducingMessageHandler类型的handler（http:outbound-gateway属于此类）
        if (handler instanceof AbstractReplyProducingMessageHandler replyProducingHandler) {
            currentGatewayBeanName.set(replyProducingHandler.getBeanName());
        }
        return super.wrapHandler(handler);
    }

    @Override
    protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) throws Exception {
        try {
            String gatewayBeanName = currentGatewayBeanName.get();
            // 执行日志记录逻辑：打印请求头、负载、gateway名称
            log.info("调用HTTP网关[{}]，请求头：{}，请求负载：{}", 
                gatewayBeanName, message.getHeaders(), message.getPayload());
            
            Object result = callback.execute();
            
            // 处理响应：如果是Message类型，打印响应信息
            if (result instanceof Message<?> responseMessage) {
                log.info("HTTP网关[{}]响应，响应头：{}，响应负载：{}", 
                    gatewayBeanName, responseMessage.getHeaders(), responseMessage.getPayload());
            }
            return result;
        } finally {
            // 必须清理ThreadLocal，避免内存泄漏
            currentGatewayBeanName.remove();
        }
    }
}

原理说明 #

• wrapHandler方法在Advice绑定到目标handler时执行一次，此时可以安全获取handler的bean名称。
• 使用ThreadLocal存储是因为同一请求线程中，wrapHandler和doInvoke的调用是一一对应的，不会出现线程安全问题。
• 最终在finally块中清理ThreadLocal，防止内存泄漏。

方案二：通过请求头传递网关名称（备选） #

如果不想使用ThreadLocal，可以在每个http:outbound-gateway的配置中添加header-enricher，将网关自身的bean名称注入到请求消息头中，后续在Advice中直接从消息头读取。

示例XML配置：

<int-http:outbound-gateway id="userApiGateway" 
                           request-channel="userRequestChannel" 
                           url="http://example.com/api/users">
    <int-http:request-handler-advice-chain>
        <bean class="com.example.HttpGatewayLoggingAdvice"/>
    </int-http:request-handler-advice-chain>
    <!-- 注入网关bean名称到请求头 -->
    <int:header-enricher>
        <int:header name="gateway_bean_name" expression="#this.id"/>
    </int:header-enricher>
</int-http:outbound-gateway>

Advice中读取头信息的代码：

@Override
protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) throws Exception {
    String gatewayBeanName = message.getHeaders().get("gateway_bean_name", String.class);
    // 日志记录逻辑...
    return callback.execute();
}

优缺点 #

• 优点：实现简单，无需依赖ThreadLocal。
• 缺点：需要为每个http:outbound-gateway单独配置header-enricher，扩展性较差。

内容的提问来源于stack exchange，提问作者al.truisme