在线状态由map改成redis，定时保持emqx链接

Van333

2022-12-05 694d691291f6ee89061fdbb9fd451ecb5519b69b

 ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/StatusMqttCallBack.java

@@ -10,6 +10,7 @@
import com.sandu.ximon.admin.manager.iot.amqp.processor.c3ChargingProcessor;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum;
import com.sandu.ximon.admin.utils.RedisUtils;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.springframework.stereotype.Component;
@@ -34,7 +35,8 @@

    private static final String localMqttConnectStatusDisconnected = "disconnected";

    public static final Map<String, Integer> localMqttConnectStatusMap = new ConcurrentHashMap<>();
    public static final String localMqttConnectStatus = "localMqttConnectStatus.";



    protected final static ExecutorService EXECUTOR_SERVICE = new ThreadPoolExecutor(
@@ -56,7 +58,7 @@
    protected void handleReceiveMessage(String topic, String message) {
        EXECUTOR_SERVICE.submit(() -> processMessage(topic,message));

        log.info("接收到消息---StatusMqttCallBack:topic={},message={}", topic, message);
//        log.info("接收到消息---StatusMqttCallBack:topic={},message={}", topic, message);
    }


@@ -69,17 +71,15 @@
            String mac = topic.split("/")[4];
            String status = topic.split("/")[5];

            System.out.println("----------------------");
            System.out.println(mac);
            System.out.println(status);
            if (status.equals(localMqttConnectStatusConnected)){
                // 设备数据上报
                localMqttConnectStatusMap.put(mac,1);
                boolean set = RedisUtils.getBean().set(localMqttConnectStatus + mac, 1);
                log.error("设备上线------，mac:{},上线,{}",mac,set);
            }
            else if (status.equals(localMqttConnectStatusDisconnected)){
                localMqttConnectStatusMap.put(mac,0);
                boolean set = RedisUtils.getBean().set(localMqttConnectStatus+mac,0);
                log.error("设备下线------，mac:{},下线.{}",mac,set);
            }


        } catch (Exception e) {
            e.printStackTrace();