海康电表维护

doum

2026-03-30 1879eaa3af5e45c6228ec2188a6c324000b3d7fa

海康电表维护

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttClientCache.java

@@ -6,4 +6,5 @@

public class MqttClientCache {
    public static  LinkedHashMap<String, MqttClient> clientMapCache = new LinkedHashMap<>();
    public static  MqttClient clientSignleCache=null;
}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttPushCallback.java

@@ -30,8 +30,6 @@
@Service
@Slf4j
public class MqttPushCallback implements MqttCallback {


        @Autowired
        private DeviceMapper deviceMapper;
        @Autowired

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java

@@ -17,7 +17,7 @@
@Slf4j
public class MqttSubServiceImpl implements MqttBizService {
    @Autowired
    private MqttPushCallback callBack ;
    private MqttPushCallback callBack;
    @Override
    public MqttClient subscribe(MqttClient client,MqttConfig config,String[] topics){
        log.error("mqtt订阅开始========开始"+ JSONObject.toJSONString(config));
@@ -32,7 +32,6 @@
        log.error("mqtt订阅开始========结束"+ JSONObject.toJSONString(config));
        return client;
    }

    @Override
    public MqttClient publish(MqttClient client,MqttConfig config, String topic, String param){
        log.error("mqtt发布消息========开始"+ JSONObject.toJSONString(config)+"\n"+param);