如何定义多个sftp连接？
我正在尝试使用出站网关从多个sftp服务器下载文件，sftp服务器的数量在属性中配置(这意味着我需要动态定义连接)， 我的应用程序.属性： sftp.host=host1,host2 sftp.user=user1,user2 sftp.pwd=pwd1,pwd2 当前我使用Java配置为： @Configuration 公共类SFtpConfig{ static Lo
..
spring-integration相关内容
有没有办法通过代码启动文件：inbound-Channel-Adapter？
我遇到了将特定文件从一个位置复制到另一个位置的情况。轮询不是必需的，因为该操作将被故意触发。此外，在运行时决定从中选取文件的目录。 我可以进行如下配置：
..
Java：MQTT MessageProducerSupport to Flux
我有一个简单的MQTT客户端，它通过IntegrationFlow： 输出收到的消息 public MqttPahoClientFactory mqttClientFactory() { DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory(); MqttConnectOptions op
..
Spring集成-传出转接重命名问题
我使用示例程序here来构建我的代码。本地SFTP测试服务器一切正常，当我今天在我的客户端SFTP服务器上测试时，它给了我一个例外，如下所示。 当我调试时，我看到客户端的SFTP服务器上的文件被写入，扩展名为“.write”。内容很好，我看不出传输的文件有任何问题，但现在的问题是文件名。在阅读spring docs之后，我看到这是临时文件扩展名，程序尝试将其重命名回原始名称，但由于客户端SF
..
向ftp出站网关动态提供目录和文件名
我们要求FTP客户端下载一个文件，该文件的名称和目录是在运行时提供的。因此，可能会要求FTP客户端从远程服务器上的foo1/foo2目录路径下载file1.txt。 我们确实有一个使用Spring Integration FTP出站网关的解决方案。使用此解决方案使其动态化： 创建网关的ApplicationContext 使用文件名和远程目录路径设置网关属性 文件已下载 Appl
..
如何使用SFTP出站网关命令下载文件？
我想使用‘mget’命令从sftp服务器下载文件。以下是我的Java配置： @Bean public SessionFactory sftpSessionFactory() { DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true); ..
..
项目反应器采用Spring集成时的主要工艺流程程序化方法
我想定义一个流，使用反应器Kafka消费Kafka并写入MongoDB，只有在成功时才将ID写入Kafka。我正在将项目反应器与Spring Integration JavaDSL结合使用，并且我希望有一个FlowBuilder类在较高级别定义我的管道。我目前有以下方向： public IntegrationFlow buildFlow() { return IntegrationFl
..
从Spring Integration调用POX Web服务
我在一个项目中使用了Spring Integration，该项目集成(成功)了各种睡觉/JSON和SOAP端点。 现在我需要调用一个配置为通过HTTP接受Plain-Old-XML-over-HTTP的BusinessWorks实例。 从“Spring Integration in Action”一书中，我得到了一个提示，我应该为此使用int-ws：outbound-ateway。 此配置生成正确
..
如何让Spring为JdbcMetadataStore创建相应的模式？
我想使用JDBC元数据存储，如下所述： https://docs.spring.io/spring-integration/docs/5.2.0.BUILD-SNAPSHOT/reference/html/jdbc.html#jdbc-metadata-store 报价： org.springframework work.Integration.jdbc包具有数据库架构 几个RDMBS
..
动态注册的Bean在几天后没有响应
假设我们有5个流，并且对于每个流，我们在每个流上设置了pollerMetadata ThreadPoolTaskExecutor。 我觉得几天后周期性触发器似乎卡住了。 以下是为每个流创建pollerMetadata的代码快照 ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); PollerMeta
..
Spring集成：带有标题丰富的自定义拆分器
是否可以实现可以返回Iterator和添加自定义标头信息的消息拆分器？ 例如，如果我有以下类 public class CsvFileToIteratorSplitter extends AbstractMessageSplitter { @Override protected Object splitMessage(Message message) {
..
FileReadingMessageSource.WatchServiceDirectoryScanner：是否关闭到子目录的递归下降？
版本： Spring: 5.2.16.RELEASE Spring Integrations: 5.3.9.RELEASE macOS Big Sur: 11.6 我正在使用XML设置目录扫描器FileReadingMessageSource.WatchServiceDirectoryScanner，如下所示：
..
结合JMS传输的Spring集成散集模式
我需要实现以下架构： 我有必须使用JMS发送到系统(某些外部应用程序)的数据。 根据您只需要发送到必要系统的数据(例如，如果系统数为4，则可以从1发送到4) 需要等待收到消息的系统响应，收到所有应答后，需要处理接收到的数据(或至少处理一个超时) 相关ID包含在传出和传入JMS消息的标头中 每个新的此类进程都可以异步并行启动 现在我只在Spring JMS的帮助下
..
在 RabbitMQ 中分组接收消息，最好使用 Spring AMQP?
我从服务 (S) 接收消息，该服务将每个单独的属性更改作为单独的消息发布到实体.一个人为的例子是这样的实体: 人{编号:123名称:“某事"，地址: {...}} 如果姓名和地址在同一事务中更新，则 (S) 将发布两条消息，PersonNameCorrected 和 PersonMoved.问题出在接收端，我在其中存储此 Person 实体的投影，并且每个属性更改都会导致写入数据库.所以在这个
..
在 Spring Integration 中处理异常时遇到问题
我是 Spring 集成的新手，对如何将错误消息发送到指定的错误队列感到困惑.我希望错误消息成为原始消息的标题并最终出现在单独的队列中.我读到这可以通过标题丰富器来完成，我尝试实现它，但错误队列中没有显示任何内容. 另外，我是否需要一个单独的异常处理类才能将错误消息放入错误队列，或者我可以在我的转换方法中抛出异常吗? 这是我的 xml 配置: 现在，正在加载的消息没有来源，所以程
..
Spring AMQP 集成 - 消费者手册 致谢
我正在测试 Spring-AMQP 与 Spring-Integration 支持，我有以下配置和测试:
..
为什么 Spring Integration 有多个 XML 模式，我应该使用哪一个?
要在 Spring XML 配置文件中使用 Spring Integration，我需要声明 si 命名空间，并提供 XML Schema 的模式位置:
..
使用 Java DSL 成功进行 ftp 传输后移动文件
我已经使用 spring-integration java dsl 定义了一个流程来 ftp 传输文件，处理它，然后将其传输回“存档"目录，最后将其移动到本地存档目录中.这是“很容易"的事情: @Bean公共集成流 ftpInboundFlow() {if (ftpProperties.getEnabled() == false) {返回空值；}logger.trace("开始 ftp 流");
..
集群中的 spring 集成 + cron + 石英?
我有一个由 cron 表达式触发的 spring 集成流程，如下所示:
..
Spring Boot TCP 客户端
我正在寻找一个通过 sing boot 连接 TCP 的示例，无需 xml(spring-integration). 我从 如何在spring boot中创建一个Tcp Connection来接受连接? URL. 在这个例子中，只需要 main 方法就足以连接 tcp.为什么这里声明了其他 bean 和转换器? 有错吗?我想与 Spring 集成，而不是使用简单的 Java 套接
..