Spring mqtt integration SubscribeYou

Question

PAHO mqttを使用してSpring Mavenでwebappを作成しています。 mqttを実装するには2つの方法がありますが、1つはSpring Mqtt Integrationであり、2つ目は接続オブジェクトを作成して接続/切断する一般的な方法ですが、どれくらい便利で信頼性が高いかです。

今私はSpring Mqttインテグレーションで購読を実装していますが、それは誰でも簡単なチュートリアルをお勧めします。

ありがとうございました！

Answer 1

Spring Integration MQTT Sample Spring Boot Appを参照してください。

stdInからの読み取りは、MQTTを介してデータを送信し、データを受信して​​ログに記録します。

// publisher 

@Bean 
public IntegrationFlow mqttOutFlow() { 
    return IntegrationFlows.from(CharacterStreamReadingMessageSource.stdin(), 
        e -> e.poller(Pollers.fixedDelay(1000))) 
      .transform(p -> p + " sent to MQTT") 
      .handle(mqttOutbound()) 
      .get(); 
} 

@Bean 
public MessageHandler mqttOutbound() { 
    MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler("siSamplePublisher", mqttClientFactory()); 
    messageHandler.setAsync(true); 
    messageHandler.setDefaultTopic("siSampleTopic"); 
    return messageHandler; 
} 

// consumer 

@Bean 
public IntegrationFlow mqttInFlow() { 
    return IntegrationFlows.from(mqttInbound()) 
      .transform(p -> p + ", received from MQTT") 
      .handle(logger()) 
      .get(); 
} 

private LoggingHandler logger() { 
    LoggingHandler loggingHandler = new LoggingHandler("INFO"); 
    loggingHandler.setLoggerName("siSample"); 
    return loggingHandler; 
} 

@Bean 
public MessageProducerSupport mqttInbound() { 
    MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter("siSampleConsumer", 
      mqttClientFactory(), "siSampleTopic"); 
    adapter.setCompletionTimeout(5000); 
    adapter.setConverter(new DefaultPahoMessageConverter()); 
    adapter.setQos(1); 
    return adapter; 
}