Spring Integration中是否有http:inbound-gateway对应的advice-handler等价实现？

1. 直接给http:inbound-gateway配置Advice Chain #

和你处理出站网关的思路完全一致，http:inbound-gateway同样支持通过advice-chain属性注入增强逻辑。你可以复用之前写的日志Advice，或者针对入站场景调整：

• 定义自定义MethodInterceptor，在拦截方法中获取ServerHttpRequest、请求参数、路径等信息完成日志记录；
• 在http:inbound-gateway配置中指定advice-chain，指向你的拦截器Bean。

示例配置片段：

<int-http:inbound-gateway request-channel="inboundRequestChannel"
                          reply-channel="inboundReplyChannel"
                          path="/api/**"
                          advice-chain="inboundLoggingAdvice"/>

<bean id="inboundLoggingAdvice" class="com.yourpackage.InboundLoggingInterceptor"/>

2. 使用Spring Integration通道拦截器 #

入站网关会将请求消息发送到配置的request-channel，给这个通道添加拦截器，就能在消息流转前后记录请求/响应细节：

• 实现ChannelInterceptor接口，重写preSend方法提取Message中的HttpHeaders、请求体、路径等信息记录日志；
• 重写postSend或afterReceiveCompletion方法记录响应状态和内容；
• 将拦截器注册到对应的request/reply通道上。

示例代码：

public class InboundChannelLoggingInterceptor implements ChannelInterceptor {
    private static final Logger logger = LoggerFactory.getLogger(InboundChannelLoggingInterceptor.class);

    @Override
    public Message<?> preSend(Message<?> message, MessageChannel channel) {
        HttpHeaders headers = message.getHeaders().get(HttpHeaders.HTTP_REQUEST_HEADERS, HttpHeaders.class);
        String path = message.getHeaders().get(HttpHeaders.REQUEST_URL, String.class);
        logger.info("Inbound HTTP Request - Path: {}, Headers: {}, Body: {}", 
                    path, headers, message.getPayload());
        return message;
    }

    @Override
    public void postSend(Message<?> message, MessageChannel channel, boolean sent) {
        if (message != null) {
            HttpStatus status = message.getHeaders().get(HttpHeaders.STATUS_CODE, HttpStatus.class);
            logger.info("Inbound HTTP Response - Status: {}, Body: {}", status, message.getPayload());
        }
    }
}

配置注册拦截器：

<int:channel id="inboundRequestChannel">
    <int:interceptors>
        <ref bean="inboundChannelLoggingInterceptor"/>
    </int:interceptors>
</int:channel>

3. 利用Spring MVC原生拦截器 #

http:inbound-gateway底层依赖Spring MVC处理请求，直接用Spring MVC的HandlerInterceptor就能全局拦截入站HTTP请求：

• 实现HandlerInterceptor接口，在preHandle方法记录请求的URL、参数、头部等；
• 在postHandle或afterCompletion方法记录响应状态、响应体（需通过ContentCachingResponseWrapper包装响应对象才能获取响应体）；
• 通过WebMvcConfigurer注册拦截器，指定匹配入站网关的路径。

示例代码：

public class InboundHttpRequestInterceptor implements HandlerInterceptor {
    private static final Logger logger = LoggerFactory.getLogger(InboundHttpRequestInterceptor.class);

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        logger.info("Inbound Request - Method: {}, URL: {}, Params: {}", 
                    request.getMethod(), request.getRequestURL(), request.getParameterMap());
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        logger.info("Inbound Response - Status: {}", response.getStatus());
    }
}

注册拦截器：

@Configuration
public class WebConfig implements WebMvcConfigurer {
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new InboundHttpRequestInterceptor()).addPathPatterns("/api/**");
    }
}

4. 全局通道拦截器 #

如果有多个入站网关，用@GlobalChannelInterceptor注解可一次性拦截所有匹配规则的通道，避免重复配置：

• 给拦截器类添加@GlobalChannelInterceptor(patterns = "inbound*Channel")注解，指定要拦截的通道名称模式；
• 实现ChannelInterceptor的方法完成日志记录。

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