mqtt

jiangping

2023-10-13 50c6151c164d8d6bd4d052257c75ba424883fecb

 server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java

@@ -38,9 +38,13 @@
        @Override
        public void messageArrived(String topic, MqttMessage message) throws Exception {
            // subscribe后得到的消息会执行到这里面
            try {
            System.out.println("接收消息主题 : " + topic);
            System.out.println("接收消息Qos : " + message.getQos());
            System.out.println("接收消息内容 : " + new String(message.getPayload()));
            deviceSubcribeService.listener(new String(message.getPayload()),topic);
                deviceSubcribeService.listener(message.getId()+"",new String(message.getPayload()),topic);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
}