|
|
@@ -1,6 +1,7 @@
|
|
|
package com.ruoyi.data.service.impl;
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
+import cn.hutool.core.lang.UUID;
|
|
|
import cn.hutool.json.JSONObject;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
@@ -120,7 +121,7 @@ public class MqttServiceImpl implements MqttService {
|
|
|
MQTTConnect mqttConnect = new MQTTConnect();
|
|
|
try {
|
|
|
System.out.println(mqttUrl);
|
|
|
- mqttConnect.createMqttClient(mqttUrl,clientID,mqttUser,mqttPassword,new Callback());
|
|
|
+ mqttConnect.createMqttClient(mqttUrl, UUID.fastUUID().toString(),mqttUser,mqttPassword,new Callback());
|
|
|
mqttConnect.sub(mqttTopic);
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
