此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.4.0！spring-doc.cn

操作员 gateway（）

定义中的 operator 是一个特殊的服务激活器实现，通过其 input 通道调用其他端点或集成流并等待回复。 从技术上讲，它与定义中的嵌套组件起着相同的作用（参见 从 Chain 中调用 Chain），并允许流更清晰、更直接。 从逻辑上和业务角度来看，它是一个消息传递网关，允许在目标集成解决方案的不同部分之间分发和重用功能（请参阅 消息传递网关）。 此运算符具有多个用于不同目标的重载：gateway()IntegrationFlow<gateway><chain>spring-doc.cn

  • gateway(String requestChannel)按其名称将消息发送到某个端点的 input 通道;spring-doc.cn

  • gateway(MessageChannel requestChannel)通过直接注入将消息发送到某个端点的 input 通道;spring-doc.cn

  • gateway(IntegrationFlow flow)将消息发送到提供的 的 input 通道。IntegrationFlowspring-doc.cn

所有这些都具有一个变体，其中包含第二个参数，用于配置 target 和相应的 。 此外，基于 -的方法允许调用现有 bean 或通过功能接口的就地 lambda 将流声明为子流，或者以方法清理器代码样式提取它：Consumer<GatewayEndpointSpec>GatewayMessageHandlerAbstractEndpointIntegrationFlowIntegrationFlowIntegrationFlowprivatespring-doc.cn

@Bean
IntegrationFlow someFlow() {
        return IntegrationFlow
                .from(...)
                .gateway(subFlow())
                .handle(...)
                .get();
}

private static IntegrationFlow subFlow() {
        return f -> f
                .scatterGather(s -> s.recipientFlow(...),
                        g -> g.outputProcessor(MessageGroup::getOne))
}
如果下游流并不总是返回回复，则应将 设置为 0 以防止无限期挂起调用线程。 在这种情况将在该点结束，并释放线程以进行进一步的工作。requestTimeout