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

‘liusuyi’

2023-10-08 157c26f5188c7ed62a4547f7e3b5a5a3e3ed7729

 src/main/java/com/ard/utils/mqtt/MqttProducerCallback.java

ÎļþÃû´Ó src/main/java/com/ard/utils/mqtt/MqttConsumerCallback.java ÐÞ¸Ä
@@ -2,6 +2,7 @@

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.*;

import java.util.Arrays;

/**
@@ -12,18 +13,14 @@
 * @Version: 1.0
 **/
@Slf4j(topic = "mqtt")
public class MqttConsumerCallback implements MqttCallbackExtended {
public class MqttProducerCallback implements MqttCallbackExtended {

    private MqttClient client;
    private MqttConnectOptions options;
    private String[] topic;
    private int[] qos;

    public MqttConsumerCallback(MqttClient client, MqttConnectOptions options, String[] topic, int[] qos) {
    public MqttProducerCallback(MqttClient client, MqttConnectOptions options) {
        this.client = client;
        this.options = options;
        this.topic = topic;
        this.qos = qos;
    }

    /**
@@ -73,22 +70,18 @@
    }

    /**
     * mqtt连接后订阅主题
     * mqtt连接完成
     */
    @Override
    public void connectComplete(boolean b, String s) {
        try {
            if (null != topic && null != qos) {
                if (client.isConnected()) {
                    client.subscribe(topic, qos);
                    log.debug("mqtt连接成功");
                    log.debug("--订阅主题:：" + Arrays.toString(topic));
                } else {
                    log.debug("mqtt连接失败");
                }
            if (client.isConnected()) {
                log.info("mqtt连接成功");
            } else {
                log.info("mqtt连接失败");
            }
        } catch (Exception e) {
            log.error("mqtt订阅主题异常:" + e);
            log.error("mqtt连接异常:" + e);
        }
    }
}