spring-integration 相关问题

有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。

Spring Integration 将所有文件作为一条消息读取

我们如何从目录中读取所有文件作为单个消息>？用例是通过迭代所有文件并将其文件名作为单个文件读取来发送状态报告

spring-integration

回答 1 投票 0

Spring Integration AbstractMessageSourceAdvice 已弃用

我正在使用 AbstractMessageSourceAdvice 在轮询文件夹后实现一项操作，但它已被弃用，该类的替换类是什么，您有教程吗？这是我的代码：

spring-integration

回答 1 投票 0

Spring Boot 和 Spring 集成。问题

我有一个SpringBoot应用程序。我有一个专用服务器，我将在其中通过 HTTP GET 请求读取数据。我为 Spring Integration 模块配置了 http-outbound-config.xml 文件。当我...

java spring spring-boot spring-integration spring-integration-http

回答 1 投票 0

使用 Spring Integration 在不同的 Spring Boot 应用程序之间发送 JMS 消息

我正在尝试使用 Spring 集成从一个 Spring Boot 应用程序（主程序）向另一个 Spring Boot 应用程序（工作程序）发送 Jms 消息。我使用嵌入式 ActiveMQ 作为代理。我已经做了以下...

spring-integration spring-jms

回答 1 投票 0

在 Spring Integration 中检测 Websocket 断开连接

我有一个基于 WebSocketInboundChannelAdapter 的集成流程，配置如下。 @豆集成流集成流（）{ StandardWebSocketClient 客户端 = new StandardWebSocketClient()...

java spring spring-boot spring-integration spring-websocket

回答 1 投票 0

迁移到 Spring Boot 3.0 和 Spring Integration 6.0 后打印警告

将项目从 Spring Boot v2.7 迁移到 v3.0（从而从 Spring Integration v5.5 迁移到 v6.0）后，会打印出以下警告：警告 22084 --- [重新启动Main]

spring spring-boot spring-integration

回答 4 投票 0

如何使用 spring 集成来池化多个目录而不是创建单独的文件入站适配器？有没有动态的方法来创建这个

如何创建10个以上目录的spring集成？就我而言，目前我们有 2 个位置可供池化，这很容易，我们可以为每个目录创建 2 个不同的文件入站适配器...

spring-boot spring-integration spring-integration-dsl spring-integration-file

回答 1 投票 0

Tcp 入站网关不调用串行器，但解串器正在被调用

我们需要监听端口并接收消息，然后我们需要将其写回到同一个输出流中。我们已经编写了运行良好的自定义解串器。但自定义序列化器我...

spring-integration spring-integration-dsl

回答 1 投票 0

检查 Spring Integretion FTP 中的被动端口

https://medium.com/nerd-for-tech/retrieve-files-from-ftp-server-using-spring-integration-5ccc4a972eaf 我正在基于上述站点实现 FTP 行为。在上面的网站中，我只添加了...

spring ftp spring-integration ftp-client passive-mode

回答 1 投票 0

Spring Integration - 回滚 JMS MessageDrivenChannelAdapter 而不会造成日志污染

我正在使用 Spring Integration（带有 Java DSL）来使用来自 JMS（MQ 和 Solace）的消息。在某些情况下，我的流程会引发异常，我希望将消息回滚到传输并重新返回...

error-handling spring-integration

回答 1 投票 0

使用 Spring Batch 集成进行文件监控和处理

我目前正在学习 spring-batch-integration，为此我想创建一个应用程序来监视指定目录中的 txt 文件，然后如果该文件存在则启动批处理作业...

spring-batch spring-integration spring-integration-dsl spring-batch-integration spring-integration-file

回答 1 投票 0

spring集成中poller的查询

我对 Spring 集成以及下面所述的几乎所有内容都是新手。我有一个 inboundChannelAdapter 来从 pubsub 中的订阅中提取消息。事实上，它正在从 p 中提取消息...

spring-integration google-cloud-pubsub spring-integration-dsl

回答 1 投票 0

如何处理 SI HttpRequestExecutingMessageHandler 中的“Transfer-Encoding=chunked”

我正在使用 HttpRequestExecutingMessageHandler 调用外部服务器。我正在使用 JSON 到对象转换器来转换 JSON 数据。但我收到以下异常。引起者：com.

spring spring-boot spring-integration spring-integration-http

回答 2 投票 0

如何使用 Spring 集成将请求方法从 POST 更改为 GET 并从正文请求参数中提取？

我有一个正在运行的 api，它需要 prop 作为参数。我想解决的任务是使用 spring 集成创建一个代理，该代理接受带有 body 的 post 请求。例如：发布http://

spring-integration spring-webflux

回答 1 投票 0

当文件对象是目录时，如何将 SFTP Spring Integration mput 与 SftpOutboundGateway 一起使用？

<int-sftp:outbound-gateway session-factory="sftpSessionFactory" use-temporary-file-name="false" request-channel="tmpDirToUploadOutputChannel" command="mput" expression="payload" remote-directory="/out" reply-channel="sftpUploadFilesResultChannel"> </int-sftp:outbound-gateway>` 当我从服务激活器发送消息时 - 文件是包含文件的目录 val message = MessageBuilder .withPayload(tmpOutFile) // .setHeader("file_name", tmpOutFileName) .build() 出站网关使用最后一个文件名，在服务器上我只能看到服务器上的一个文件如何正确使用并使用所有文件名？我来自服务激活器的消息尤里卡！ inbound-channel-adapter --> service-activator 返回消息文件是目录 --> sftp outbound-gateway sftp 出站网关将来自入站通道适配器的文件名缓存在标头 file_name 中当我设置“file_name”时，“” val message = MessageBuilder .withPayload(File(tmpOutDirPath)) .setHeader("file_name", "") .build() 在这种情况下，removeHeader 也不起作用

spring-integration spring-integration-sftp

回答 1 投票 0

如何在Spring集成中使用rabbitmq作为缓冲区来创建背压缓解？

我有一个在 http://localhost:9999/greet/v3/api (API A) 上运行的 api，它响应 2 秒延迟的请求（模拟）。我创建了以下集成流程来代理所有

spring-integration spring-webflux spring-integration-amqp

回答 1 投票 0

Spring 集成消息通道 - 基于内存或基于文件

我想评估一下spring集成是否适合我们当前的需求。我们将收到一个包含 100 万笔交易的输入流（让我们考虑下面代码中的 A 是 1

spring-integration

回答 1 投票 0

Spring Integration 反序列化器未通过 TCP 获取整个消息

我们正在使用 Spring 集成流连接到 Tcp 端口并获取消息。在下面找到相同的代码。 @豆公共集成流集成流（）{ 返回