我想使用Spring Integration来处理MQTT消息。
这是我的处理要求:基于入站消息有效负载,它应该被复制到具有相同有效负载的多个消息但是……
因此,您所描述的实际上并非MQTT特定,而是称为企业集成模式 分离器 和Spring Integration提供了对它的支持,您可以使用XML,Annotation和/或Java DSL进行配置。你可以找到更多信息 这里 。
在一个坚果shell中,Splitter是一个消息处理程序,它具有一个特定的契约,允许它从“单个”(聚合器的反转类型)返回“很多”。您基本上会收到一条消息(在您的情况下来自MQTT)并将其拆分为拆分器实现中的多条消息。