价格配置

jiangping

2023-10-17 95d3f1671b5a27bb811a374d7c06df5e2dc9035b

 server/services/src/main/java/com/doumee/core/mqtt/config/MqttClientInit.java

@@ -19,7 +19,7 @@
            try {
                // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
//                String clientId =config.getClientid()+ Constants.getUUID();
                String clientId =config.getClientid()+"001";
                String clientId =config.getClientid()+(int)(Math.random()*10000);
                client = new org.eclipse.paho.client.mqttv3.MqttClient(config.getHost(), clientId,new MemoryPersistence());
                // MQTT的连接设置
                MqttConnectOptions   options = new MqttConnectOptions();
@@ -51,7 +51,7 @@
            try {
                // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
//                String clientId =config.getClientid()+ Constants.getUUID();
                String clientId =config.getSubclientid()+"001";
                String clientId =config.getClientid()+(int)(Math.random()*10000);
                subClient = new org.eclipse.paho.client.mqttv3.MqttClient(config.getHost(), clientId,new MemoryPersistence());
                // MQTT的连接设置
                MqttConnectOptions   options = new MqttConnectOptions();