aijinhui
2023-12-14 0306d5836a7a56614e01af35b9e70f0224b47cb2
ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java
@@ -27,9 +27,6 @@
            this.mqttClient = new MqttClient(mqttUrl,clientId,mempersitence);//设置连接broker的host及clientId
            this.messageCallback = new MessageCallback();
        } catch (MqttException e) {
            System.out.println("初始化客户端mqttClient对象失败");
            System.out.println("brokerUrl:"+mqttUrl);
            System.out.println("clientId:"+clientId);
            e.getMessage();
        }
    }
@@ -42,7 +39,6 @@
        options.setUserName("admin");
        options.setPassword("xzx12345".toCharArray());
        options.setCleanSession(true);//设置为临时会话
        mqttClient.setCallback(messageCallback);//设置回调
        try {