@RestController通过@MessagingGateway对接IntegrationFlow异常耗时问题

• 网关动态代理的默认处理开销：@MessagingGateway生成的动态代理默认会加载全量通用处理逻辑，包括全局拦截器执行、参数合法性校验、头信息封装等通用流程，高并发压测下这部分逻辑的累积开销会被明显放大，且全程在调用方线程执行，直接计入前置耗时。
• 默认通道的全局钩子开销：你当前使用IntegrationFlow自动生成的startDataFlow.input通道，默认会继承Spring上下文全局配置的通道拦截器、统计回调、监控埋点等逻辑，哪怕你没有显式配置，部分Spring Integration的自动配置类也会注入默认的监控钩子，消息发送到通道前会执行所有钩子逻辑，产生额外耗时。
• Payload转换校验开销：网关将方法入参封装为Spring Integration标准Message<?>对象时，默认会遍历全局消息转换器做类型匹配与转换尝试，即便你的入参类型无需转换，默认的匹配检查逻辑在高并发场景下也会产生明显耗时。
• 自定义FlowExtension的额外包装开销：若你使用的FlowExtension是项目自定义封装的实现类，需要检查其get()方法是否对输入通道做了额外的代理、拦截逻辑包装，这类逻辑也会被计入消息入流前的耗时。

• 为@MessagingGateway显式指定Payload类型，关闭不必要的类型转换检查：

@MessagingGateway(defaultPayloadType = dataRequest.class)
public interface HttpMessageGateway {
    @Gateway(requestChannel = "startDataFlow.input")
    Result basicDataDescriptionFlow(@Payload dataRequest prDataRequest, @Headers Map<String, Object> map);
}

• 显式声明输入通道，关闭全局拦截器自动注入：

@Bean
public MessageChannel startDataFlowInput() {
    // 构造方法传入false表示不注入全局通道拦截器
    return new DirectChannel(false);
}

@Bean
public IntegrationFlow startDataFlow() {
    // 从自定义的无拦截器通道启动流
    return IntegrationFlow.from(startDataFlowInput())
            .handle(someHandler1)
            .handle(someHandler2)
            .handle(someHandler3)
            .get();
}

• 按需关闭网关的默认全局拦截器，仅保留必要的自定义拦截器：

// 不需要拦截器则interceptorNames留空，有需要则填入自定义拦截器的Bean名称
@MessagingGateway(interceptorNames = {}, defaultPayloadType = dataRequest.class)
public interface HttpMessageGateway {
    // 原有方法逻辑不变
}

内容的提问来源于stack exchange，提问作者Jonathan H