Spring整合MQTT

pom.xml

             
                  
      
       org.eclipse.paho
                    
      
       org.eclipse.paho.client.mqttv3
                  
      
       1.0.2
               
             
                 
      
       com.google.code.gson
                  
      
       gson
                  
      
       2.8.1
              
             
             
                   
      
       org.springframework.integration
                  
      
       spring-integration-mqtt
                  
      
       4.3.5.RELEASE
                  
                        
                             
        
         org.eclipse.paho
                              
        
         mqtt-client
                          
                         
                             
        
         org.springframework
                              
        
         spring-messaging
                          
                     
                
               
                     
                   
      
       org.fusesource.mqtt-client
                    
      
       mqtt-client
                    
      
       1.14
              
     

 

spring-mqtt.xml

实现消息处理类

public class MqttService2{    private static final Logger log = LoggerFactory.getLogger(MqttService2.class);    private MqttPahoMessageHandler mqtt;    private volatile Integer serialno = 0;        public void startCase(Message
     
       recmsg){                //mqtt5.0//        String topic = (String) recmsg.getHeaders().get("mqtt_receivedTopic");        String topic = (String) recmsg.getHeaders().get("mqtt_topic");        String payload = recmsg.getPayload();        log.info("消息解析headers结果：{},{}", topic, payload);    }}
     

startCase()方法中的参数目前我知道的有三种：