区分消息订阅类型，新增上下线监听，修复定时帧缺少CRC32，替换设备在线状态查询方法

Van333

2022-11-16 51af3e4e7c5fb612576b98fd6407f6b65859f374

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

ÎļþÃû´Ó ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/DefaultMqttCallBack.java ÐÞ¸Ä
@@ -31,8 +31,8 @@
 * @date 2022/11/9 16:24
 */
@Slf4j
@Component("default")
public class DefaultMqttCallBack extends AbsMqttCallBack {
@Component("java_server_msg")
public class MsgMqttCallBack extends AbsMqttCallBack {

    private static final String localMqttConnectTypeOfSync = "1";

@@ -44,7 +44,7 @@
    protected final static ExecutorService EXECUTOR_SERVICE = new ThreadPoolExecutor(
            Runtime.getRuntime().availableProcessors(),
            Runtime.getRuntime().availableProcessors() * 2, 60, TimeUnit.SECONDS,
            new LinkedBlockingQueue<>(50000), new DefaultMqttCallBack.NameTreadFactory());
            new LinkedBlockingQueue<>(50000), new MsgMqttCallBack.NameTreadFactory());

    static class NameTreadFactory implements ThreadFactory {

@@ -60,7 +60,7 @@
    protected void handleReceiveMessage(String topic, String message) {
        EXECUTOR_SERVICE.submit(() -> processMessage(topic,message));

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