问题标签 [spring-integration-dsl]

我正在开发一个服务适配器，它将轮询目录/子目录文件，并使用 spring 批处理解析该文件，但我不了解文件适配器 +spring 批处理解析器 + http 适配器连接的流程，请建议我更好的方法。提前致谢。

我正在使用带有定义的 IntegrationFlow 的 Spring Integration Java DSL。我看到响应缺少数据片段并且聚合器响应中的correlationId 与调用服务接收到的响应中的值不匹配的行为。

背景：

我在使用随机数据且以每分钟 600 个请求运行的服务器上运行 JMeter 性能测试。在我的笔记本电脑上，我有一个 SoapUI 性能测试正在运行，它击中了同一台服务器。SoapUI 项目以每分钟 60 个请求的速率发送具有相同搜索条件（我们正在匹配）的请求。响应都应包含相同的结果数据。

大约 0.5% 的时间响应返回数据丢失。在这些响应中，从聚合器记录的响应的correlationId 和从调用服务记录的响应的correlationId（在响应返回到调用服务并且已经通过聚合器后记录）不匹配。

知道有什么问题吗？请参阅下面的代码片段。

我使用 Spring Integration 的 DSL 实现。我有下面的代码，我不能使用我的自定义错误流。当 authenticate 方法抛出 Runtime Exception 时，errorChannel 开始处理。我丰富了标题以使用我的自定义错误流，但不使用。

编辑：

在 Artem 的回答之后，我的代码如下所示。但是，我仍然无法访问错误流中的标头参数。我收到错误 - “路由器'路由器没有解决通道：错误响应准备'”

编辑 - 2：

我尝试了 Artem 的测试代码，它适用于这种情况。如果我将 type1 流转换为子流映射如下（我这样做，因为我怀疑我的子流代码块），错误流无法打印 ABCDEF 参数值。之后，我在子流映射中添加了另一个标头（XYZTWR），但也无法打印。

我的 S.OUT 是：

这是拆分项目列表、丰富每个项目然后将每个丰富项目发送到另一个频道的正确方法吗？

似乎即使每个项目都在丰富，但只有最后一个项目被发送到输出通道......

这是我的测试中的狙击手，我从流程中看到只有 page2 被调用。

但是，如果我这样做...

我看到所有页面都在发布，但最后一个是 page2 而不是 page3（即使从调试中我可以看到该实例具有第 3 页属性）。

似乎其他所有项目都被流程看到了......

我的流程是这样的...

从 PublishPackage 流开始。这是主要的入口流程，旨在将项目从包中拆分出来，并在丰富有效负载后将它们中的每一个发送到附加到 publishPackageItem 通道的流程......

接下来，将 CMS 发布流附加到 publishPackageItem 通道，并根据拆分后的类型，路由到特定的元素通道进行处理。拆分页面后，只有特定的元素类型可能有订阅流。

最后，我的目标是订阅频道并相应地处理每个元素。我将此流订阅到 channelPublishPage。每个订户可以不同地处理元素。

在 Spring integration ftp doc之后，我设法通过 java config 方式将文件发送到 ftp 服务器：

ss

在我看来，上面的代码使用自定义方法“sendToFtp()”将文件发送到目标 ftp 服务器。我的问题是如何在 MyGateway 接口中添加其他方法来实现操作？

根据指南的子流支持部分，人们期望能够非常简单地配置子流：使用 DSL 工厂或 lambdas。

我在上面定义的第二次尝试中遇到了这个异常。

我已经试过了spring-boot-starter-integration:2.0.0.M3。我错过了什么吗？谢谢你的帮助。

我是 Spring Integration DSL 的新手，我遇到了一个问题。我需要在子流中的特定点或流中的任何其他点上从流的开头使用 Object，例如在整个流中可重用的 Session 变量。这是我转换 udp 请求的示例，将其转换为发送到 api 函数的 http 请求，并且接收到的响应不包含进行 udp 响应所需的数据。所以不知何故，我需要 udp 请求中的数据来做出 udp 响应。我一直在考虑分离器，但我不认为这是一个解决方案，甚至将当前的 Integratin 流程扩展到我的需要。我知道系统不是松散耦合的，但它必须是一种方法来做到这一点。

我正在使用 Spring 云流读取文件并使用文件拆分器拆分并使用 DSL 样式将每一行作为消息发出，正在读取的文件有一个标题行，只是想知道是否有一种简单的方法可以在 / 之前跳过标题行看完后。

任何帮助表示赞赏。

这是我的拆分器和集成流的样子：

我正在尝试使用 spring 集成 DSL 调用肥皂服务，需要添加一些自定义标头。

构建了marshellingoutboundgateway。试图覆盖 DefaultSoapHeaderMapper 但没有调用任何被覆盖的方法。

试图构建这样的东西。

有一个示例：https ://github.com/spring-projects/spring-integration/blob/master/src/reference/asciidoc/ws.adoc

看起来只在 5.0 中可用

贴出详细代码。

任何见解都会有所帮助。

我正在使用 Spring 集成 dsl 来满足以下要求。

要求是，我必须使用拆分器拆分消息，并在某些转换期间向拆分后的消息添加标头值，然后再进行聚合。但是 post 聚合，我添加 post splitter 到消息的标头值丢失了。这是由于聚合策略。我正在使用默认策略。

请提出一种方法如何持久化标头并在聚合后使用它。这样我就可以进行一些自定义转换。