集群环境下的Spring Integration流式入站信道适配器
我需要在多/集群环境中实现sftp流入站通道适配器。我不应该将文件存储在我的本地目录中，我已经流文件并立即处理它。它在单个实例中工作得很好，但是如果我试图在多个节点中运行poller，就会遇到类似重复处理的问题，第二个节点找不到文件。
我尝试使用propertiesmetadatastore按照https://docs.spring.io/spring-integration/reference/html/redis.html#redis-metadata-store
datastore创建实现它，但问题仍未解决。
谢谢
共有1个答案
嗯，不清楚您的环境中发生了什么，但是SFTPpersistentAcceptonCefilelistFilter和任何可能的分布式MetadataStore是您的解决方案。对，redismetadataStore就是其中之一：所有集群实例都必须查看同一个Redis服务器。
-
我们在Oracle Weblogic 10.3.6服务器中有两个节点的集群环境，它是循环的。 我有一个服务，它从外部系统获取消息并将它们放入数据库（Oracle DB）。 我正在使用jdbc入站适配器转换这些消息并将其传递到通道。一条消息只处理一次。我计划在DB表中有一列（NODE\u NAME）。当从外部系统获取消息的第一个服务也使用NODE_名称（weblogic.NAME）更新列时。在jdb
-
问题内容： 入站和出站通道适配器之间的根本区别是什么？ 任何示例都将非常有帮助。 我已经查看过Spring文档，这种“方向性”的区别对我来说还不清楚。我支持配置了outbound-channel-adapter的应用程序，但是我发现使用 出站 标签可以直观地了解行为计数器。该适配器获取一个外部文件，然后 将其 引入应用程序中， 在 该应用程序中我们解析文件并保留数据。 这类似于这个问题，但是我想更
-
我需要一个http入站流通道，类似于ftp流适配器通道(http://docs.spring.io/spring-integration/docs/4.3.9.RELEASE/reference/html/ftp.html#ftp-流媒体）但我找不到，SI支持吗？如果不是，是否有可能解决问题？ 我需要从http流通道接收soap消息，使用SAX转换消息，然后将其发送到http出站流通道
-
Redis streams是否受益于群集模式？假设您有10个流，它们是分布在集群中还是全部分布在同一个节点上？我计划使用Redis streams实现真正的高吞吐量（每秒200万条消息），因此我担心Redis streams在这种规模下的性能。 如果Redis streams不能在集群模式下进行开箱即用的扩展，那么任何关于水平扩展Redis streams的指导都会非常棒。
-
目前Cloud-ML生态云只有武清集群。这个集群的基本配置如下： 武清集群 集群目前包括若干台CPU和GPU节点。 集群的Endpoint为：https://cnbj2.cloudml.api.xiaomi.com
-
我试图将从Quickfix读取消息（读取修复消息）配置到spring集成中。我知道我可以使用入站通道适配器从外部源（如QuickFix）读取数据。您能提供如何编写事件驱动入站通道适配器的示例吗？我有以下配置不起作用