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 {