Spring-Boot MQTT構成

Question

データベースから名前を選んだ多くのデバイスにペイロードを送信する必要があります。その後、別のトピックに送信する必要があります。settings/{put devicename here}のようになります。

私が使用していた設定は、私がスプリングブートのリファレンスドキュメントから得たものです。

MQTTConfiguration.javaここ

@Configuration 
@IntegrationComponentScan 
public class MQTTConfiguration { 

@Autowired 
private Settings settings; 
@Autowired 
private DevMqttMessageListener messageListener; 

@Bean 
MqttPahoClientFactory mqttClientFactory() { 
    DefaultMqttPahoClientFactory clientFactory = new DefaultMqttPahoClientFactory(); 
    clientFactory.setServerURIs(settings.getMqttBrokerUrl()); 
    clientFactory.setUserName(settings.getMqttBrokerUser()); 
    clientFactory.setPassword(settings.getMqttBrokerPassword()); 
    return clientFactory; 
} 

@Bean 
MessageChannel mqttOutboundChannel() { 
    return new DirectChannel(); 
} 

@Bean 
@ServiceActivator(inputChannel = "mqttOutboundChannel") 
public MessageHandler mqttOutbound() { 
    MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler("dev-client-outbound", 
      mqttClientFactory()); 
    messageHandler.setAsync(true); 
    messageHandler.setDefaultTopic(settings.getMqttPublishTopic()); 
    return messageHandler; 
} 

@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel") 
public interface DeviceGateway { 
    void sendToMqtt(String payload); 
} 
} 

、私は1トピックに送信しています。そこで以下のようなBeanを追加して、複数のトピックに送信しました。

@Bean 
public MqttClient mqttClient() throws MqttException { 
    MqttClient mqttClient = new MqttClient(settings.getMqttBrokerUrl(), "dev-client-outbound"); 
    MqttConnectOptions connOptions = new MqttConnectOptions(); 
    connOptions.setUserName(settings.getMqttBrokerUser()); 
    connOptions.setPassword(settings.getMqttBrokerPassword().toCharArray()); 
    mqttClient.connect(connOptions); 
    return mqttClient; 
} 

と私は、作品

try {  
    mqttClient.publish(settings.getMqttPublishTopic()+device.getName(), mqttMessage); 
    } catch (MqttException e) { 
     LOGGER.error("Error While Sending Mqtt Messages", e); 
    } 

を使用して送信します。

私の質問は、パフォーマンスを向上させるために同じ出力チャンネルを使用することができますか？はいの場合は、どんな助けでも大歓迎です。ありがとうございました。

Answer 1

MqttClientは同期です。

MqttPahoMessageHandler確認を待つが、アプリケーションイベントとして後で確認を公開しないように（trueにasync設定）MqttAsyncClientを使用して構成することができます。

独自のコードを使用してループ内で複数のメッセージを送信している場合は、非同期クライアントを使用して後でIMqttDeliveryToken補完を待つほうが速いでしょう。