SpringインテグレーションでTCPを使用してMessageSourceを作成する

Question

サーバからデータを受信して​​いるTCPクライアントでSpring Integrationで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; 
} 

Answer 1

TCPにはMessageSourceはありません。ちょうどTCP/IPはストリーミングプロトコルなので、我々はMessageProducerの実装を介して継続的に働くリスナーを持っています - TcpReceivingChannelAdapter。このためには、普通の@Beanの定義を宣言し、注入には適切なConnectionFactoryとMessageChannelを使用するだけです。