我认为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
我无法收到服务器的回复.
任何帮助表示赞赏
最佳答案
TcpSendingMessageHandler用于单向使用 – 仅用于将消息发送到TCP套接字.
所以,你的配置看起来很好,对我来说它应该工作.
TcpListener exiting – no listener and not single use
只是来自TcpNetConnection的DEBUG消息,表明您的组件是单向的.
因此,您无法从服务器收到回复是正常的.因为你只向那里发送消息.
要有请求/回复方案,请考虑使用TcpOutboundGateway
.
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。