我应该如何在Spring集成中构建我的消息？

Question

我有一个我编码的应用程序，我正在重构它以更好地利用 Spring 集成。应用程序处理文件的内容。

问题（如我所见）是我当前的实现传递文件而不是消息，即 Spring 集成消息。

为了避免进一步滚动我自己的代码，然后我必须在以后维护它，我想知道是否有推荐的结构来构建 Spring 集成中的消息。我想知道的是，是否有一些推荐的通道组合，例如我应该使用的消息生成器。

我还没有配置它的代码，但我想最终得到以下组件/进程：

>

接收文件，删除文件的页眉和页脚，获取每一行并将其转换为消息

public class ShippedBoxMessageBuilder 实现了 CustomMessageBuilder {

@Override public Message buildMessage（String input） { ShippedBox shippedBox = （ShippedBox） ShippedBoxFactory.manufacturingShippedFile（input）; return MessageBuilder.withPayload（shippedBox）.build（）; } ...

邮件按类型路由到相应的处理通道

我预期的解决方案似乎已经使它复杂化了。但是，我故意将两个任务分开 1）将文件分解为多行消息




Answer 1

实际上，Spring 集成中有 MessageBuilder 支持。

此类框架的一般目的是帮助后端开发人员将其域代码与消息传递基础结构分离。最后，要使用 Spring 集成，您需要遵循 POJO 和方法调用原则。

您可以编写自己的服务、转换器和域模型。然后你只需使用一些开箱即用的组合（例如

我建议您阅读Spring Integration in Action一书，以获得更多有关此事的图片。

您能解释一下直接处理 Spring 集成组件的原因吗？

更新

1）将文件分成多行消息

这

2）将消息转换为消息

再说一次：没有理由构建消息对象。在一些转换器（再次是 POJO）中构建新的有效负载并框架包装到其要发送的消息中就足够了。

有效负载类型 路由器不言自明：它检查有效负载类型，但不检查消息类型。当然，有效负载也可以是消息，甚至任何标头也可以是。

无论如何，您的构建器快照最终显示的正是普通 Spring 集成消息的创建。正如我所说：只需将一个有效载荷转换为另一个有效载荷并从某个 POJO 返回它就足够了，您将将其用作变压器参考。