修改主题

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java

             client.setCallback(new MqttConsumerCallBack());
             client.connect(options);
 
-            String topic = "$share/airmonitor/298dd766/environment/message";
+            //String topic = "$share/airmonitor/298dd766/environment/message";
+            String topic = "/v1/298dd766/environment/message";
             client.subscribe(topic, 0);
         } catch (MqttException e) {
             e.printStackTrace();