在spring集成中,使用tcp客户机(从服务器接收数据)生成messagesource的最佳方法是什么?我的应用程序已经运行了ftp和sftp的数据,但是我需要实现一个带有tcp的版本。在以前的版本中,入口点是 InboundChannelAdapter
这样地:
@Bean
@InboundChannelAdapter(value = "channel", poller = @Poller(fixedDelay = "10000", maxMessagesPerPoll = "-1"))
public MessageSource<File> ftpMessageSource(
@Autowired AbstractInboundFileSynchronizer<FTPFile> ftpInboundFileSynchronizer) {
FtpInboundFileSynchronizingMessageSource source = new FtpInboundFileSynchronizingMessageSource(
ftpInboundFileSynchronizer);
source.setLocalDirectory(new File(repo));
source.setAutoCreateLocalDirectory(true);
source.setLocalFilter(new AcceptAllFileListFilter<File>());
return source;
}
1条答案
按热度按时间qaxu7uf21#
根本没有
MessageSource
对于tcp。因为tcp/ip是一个流协议,所以我们有一个连续工作的监听器MessageProducer
实施-TcpReceivingChannelAdapter
. 只需要简单地声明一下@Bean
定义并使用适当的ConnectionFactory
以及MessageChannel
注射用。