我想使用Spring Integration处理MQTT消息。
这是我的处理要求：基于入站消息有效负载，应将其复制到具有相同有效负载但标头不同的多个消息中。更具体地讲，不同的MQTT主题标头是因为我想将它们发送到不同的主题。
出站消息也应按顺序发送：首先，来自第一个入站消息的所有已转换消息，然后来自第二个入站消息的所有消息，等等。
我应使用哪些消息端点来实现此目的？
最佳答案
因此，您所描述的实际上不是MQTT特定的，而是称为splitter的企业集成模式，Spring Integration提供了对它的支持，您可以使用XML，Annotation和/或Java DSL对其进行配置。您可以找到更多信息here。
在坚果壳中，拆分器是一个带有特定约定的消息处理程序，该协议使它可以从“单个”（聚合器的反向类）中返回“许多”。基本上，您会收到一条消息（在您的情况下是从MQTT发出的），并在拆分器实现中将其拆分为多条消息。