java 配置中的 <tcp-outbound-channel-adapter> 是什么？

Question

我有 spring 集成 XML 配置和以下 bean

<int-ip:tcp-outbound-channel-adapter id="outboundClient"
channel="input"
connection-factory="client"/>

我认为 java 配置中的等价物是

@ServiceActivator(inputChannel = "input", requiresReply = "true")
public TcpSendingMessageHandler outboundClient() {
    TcpSendingMessageHandler tcpSendingMessageHandler = new TcpSendingMessageHandler();
    tcpSendingMessageHandler.setConnectionFactory(clientConnectionFactory());
    tcpSendingMessageHandler.setRetryInterval(10000);
    tcpSendingMessageHandler.setClientMode(true);
    return tcpSendingMessageHandler;
}

但是，在日志中，我看到

TcpListener exiting - no listener and not single use

我无法收到服务器的回复。

感谢任何帮助

Answer 1

TcpSendingMessageHandler 用于单向使用 - 仅用于向 TCP 套接字发送消息。

所以，您的配置看起来不错，对我来说应该可以。

TcpListener exiting - no listener and not single use

只是来自 TcpNetConnection 的 DEBUG 消息，表明您的组件是 one-way。

因此您收不到服务器的回复是正常的。因为你只发消息到那里。

有request/reply个场景考虑使用。

java 配置中的 <tcp-outbound-channel-adapter> 是什么？

what is equivalent of <tcp-outbound-channel-adapter> in java config?

java

spring

spring-integration

spring-java-config