Spring Mqtt - 以编程方式将消息发布到多个主题

Question

如何以编程方式发布具有不同主题的消息？

<mqtt:outbound-channel-adapter id="mqttOut" 
    auto-startup="true" 
    client-id="foo"
    url="tcp://localhost:1883"
    client-factory="clientFactory"
    default-qos="0"
    default-retained="false"
    default-topic="bar"
    async="true"
    async-events="true" />

我尝试了Spring integration MQTT publish & subscribe to multiple topics，但无法配置。

还尝试了MqttPahoMessageHandlerAdapter，它有一个publish()，但有protected。

使用org.eclipse.paho.client.mqttv3.MqttAsyncClient 和org.eclipse.paho.client.mqttv3.MqttCallback 非常简单。但我想一直坚持春天。

如果有人能指出我正确的方向，不胜感激。

Answer 1

无论如何，您都可以使用 Spring Integration 做到这一点！拥有大量 EIP 组件实现和板载 Spring 功能（注入、SpEL 等），再加上一点想象力，即使没有任何 Java 代码，我们也可以达到任何最终应用程序的要求。

因此，<mqtt:outbound-channel-adapter> 允许在运行时确定 topic。您应该提供 MqttHeaders.TOPIC MessageHeader 而不是 default-topic。

因此，如果您需要向多个主题发送相同的消息，您只需为每个主题构建该消息的副本。 <splitter> 可以帮助我们：

<int:splitter input-channel="enricheMessage" output-channel="sendMessage" apply-sequence="false">
    <int-groovy:script>
        ['topic1', 'topic2', 'topic3'].collect {
            org.springframework.integration.support.MessageBuilder.withPayload(payload)
                    .copyHeaders(headers)
                    .setHeader(org.springframework.integration.mqtt.support.MqttHeaders.TOPIC, it)
                    .build()
        }
    </int-groovy:script>
</int:splitter>

sendMessage可以是ExecutorChannel，实现并行发布。

更新

您可以在<splitter> 上使用ref 和method，使用类似的Java 代码实现相同的迭代和消息丰富逻辑。 当然，即使使用 SpEL 也可以做到这一点，但使用 Collection Projection 会看起来有点复杂。

Answer 2

声明一个<publish-subscribe-channel id="toMqtt" />；将其设置为每个出站通道适配器上的channel 属性；消息将被发送到每个适配器。