使用tcp和spring集成生成消息源

zqry0prt  于 2021-07-09  发布在  Java
关注(0)|答案(1)|浏览(358)

在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;
}
qaxu7uf2

qaxu7uf21#

根本没有 MessageSource 对于tcp。因为tcp/ip是一个流协议,所以我们有一个连续工作的监听器 MessageProducer 实施- TcpReceivingChannelAdapter . 只需要简单地声明一下 @Bean 定义并使用适当的 ConnectionFactory 以及 MessageChannel 注射用。

相关问题