优化mqtt生产者取消消费者订阅

‘liusuyi’

2023-10-08 157c26f5188c7ed62a4547f7e3b5a5a3e3ed7729

 src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java

@@ -1,10 +1,9 @@
package com.ard.alarm.apponekey.service.impl;

import java.util.Date;
import java.util.List;

import com.alibaba.fastjson2.JSON;
import com.ard.utils.mqtt.MqttConsumer;
import com.ard.utils.mqtt.MqttProducer;
import com.ard.utils.uuid.IdUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@@ -34,7 +33,7 @@
            ardAlarmApponekey.setId(IdUtils.fastSimpleUUID());
            ardAlarmApponekey.setCreateTime(new Date());
            printLog(ardAlarmApponekey);
            MqttConsumer.publish(2, false, "apponekey", JSON.toJSONString(ardAlarmApponekey));
            MqttProducer.publish(2, false, "apponekey", JSON.toJSONString(ardAlarmApponekey));
            return 1;
        } catch (Exception ex) {
            log.error("一键报警处理异常:" + ex.getMessage());