jjzjj

TcpOutboundGateway

全部标签

java - spring 集成中的自定义并发 TcpOutboundGateway

我正在尝试使用TcpOutboundGateway和客户端TcpConnectionFactory与外部TCP服务器通信。在我的场景中,每个连接都应该与不同的线程相关联(线程上的每个连接可能用于多个请求/响应)。所以我使用了这个主题中的ThreadAffinityClientConnectionFactory:SpringIntegrationtcpclientmultipleconnections它工作正常,直到我尝试打开超过4个并发连接,第五个(及以上)连接因超时而失败。我发现org.springframework.integration.ip.tcp.TcpOutboundGat

java - 如何使用 Spring Integration 动态创建多个 TcpOutboundGateways?

我有一个场景,我需要一个客户端应用程序能够在应用程序启动时动态创建到可变数量的唯一主机/端口组合的TCP连接。我正在尝试使用SpringIntegrationTcpOutboundGateway来完成此操作,但一直找不到解决方案。我希望每个主机/端口组合都有自己专用的TcpOutboundGateway。到目前为止,我对TcpOutboundGateway的研究使我得出以下单一网关解决方案……@MessageGateway(defaultRequestChannel=“sendMessage”)publicinterfacemyMessageGateway{byte[]sendMess