如何使用spring集成或使用出站通道适配器将单个文件发送到多台主机
我有一个场景，在这个场景中，我需要通过SFTP和spring集成将一个文本文件从主机发送到多个远程计算机。请建议实现这一点的方法。我可以使用出站通道适配器发送单个文件到单个主机。我已经检查了以下链接以动态创建通道和会话工厂，但我不能以编程方式创建通道适配器，请建议https://github.com/spring-projects/spring-integration-samples/blob/a93ee7fb35913de603dcca9970fea28bcfe956cf/advanced/dynamic-ftp/src/test/java/org/springframework/integration/samples/ftp/dynamicftpchannelresolvests.java#l9
https://github.com/spring-projects/spring-integration-samples/blob/master/advanced/dynamic-ftp/src/main/java/org/springframework/integration/samples/ftp/dynamicftpchannelresolver.java
共有1个答案
-
使用Spring Integration Kafka，使用出站通道适配器，我尝试向名为“test”的主题发送消息 通过命令行终端，我启动了动物园管理员、kafka并创建了名为“test”的主题 Spring XML配置 JUnit测试代码 测试用例成功，在调试时，我发现channel.send()返回true 我使用下面的命令通过命令行检查了主题，但是我在测试主题中看不到任何消息。 bin/kaf
-
问题内容： 入站和出站通道适配器之间的根本区别是什么？ 任何示例都将非常有帮助。 我已经查看过Spring文档，这种“方向性”的区别对我来说还不清楚。我支持配置了outbound-channel-adapter的应用程序，但是我发现使用 出站 标签可以直观地了解行为计数器。该适配器获取一个外部文件，然后 将其 引入应用程序中， 在 该应用程序中我们解析文件并保留数据。 这类似于这个问题，但是我想更
-
我发现了一个xml配置的入站适配器示例，但我并不完全理解。配置指定REST请求设置请求方法、使用的格式等。 我认为，从Spring集成的角度来看，响应应该更加重要，因为响应实际上是为消息通道提供信息的。我说得对吗？ HTTP入站适配器用作消息endpoint（实际上是消息起始点），它调用HTTP请求，例如REST服务的URL。”http://myRest/transfer/next“-向SI消息通
-
我试图将从Quickfix读取消息（读取修复消息）配置到spring集成中。我知道我可以使用入站通道适配器从外部源（如QuickFix）读取数据。您能提供如何编写事件驱动入站通道适配器的示例吗？我有以下配置不起作用
-
如何在不使用XML的情况下将2个通道输出到具有Spring集成的单个通道。类似于以下问题多通道的消息进入单通道 在我的上下文中，我有2个PollableChannel bean，我希望将消息从这两个bean（非聚合）路由到一个@ServiceActivator，即完成如下操作：
-
我正在使用Spring集成jms出站通道适配器，它将消息发送到动态队列。我使用属性destination expression=“headers.DestinationQueueName”。在将出站消息写入OUT\U MSG通道之前，在代码中设置DestinationQueueName。 如何在队列上设置这些属性：，和？