我想使用 Spring Integration 来处理 MQTT 消息。
这是我的处理要求:基于入站消息有效负载，它应该被复制到具有相同有效负载但不同 header 的多条消息中。更具体地说，不同的 MQTT 主题 header ，因为我想将它们发送到不同的主题。
出站消息也应按顺序发送:首先是来自第一个入站消息的所有已转换消息，然后是来自第二个入站消息的所有消息等。
我应该使用什么消息端点来实现它？
最佳答案
因此，您所描述的实际上不是特定于 MQTT 的，而是一种名为 splitter 的企业集成模式Spring Integration 为其提供支持，您可以使用 XML、注释和/或 Java DSL 对其进行配置。您可以找到更多信息 here .
简而言之，Splitter 是一个具有特定合约的消息处理程序，允许它从“单个”返回“多个”(类似于聚合器)。您基本上会收到一条消息(在您的情况下来自 MQTT)并将其拆分为拆分器实现中的多条消息。
关于java - Spring 集成 : copy one inbound message to multiple outbound，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54590517/