Merge branch 'wjc' into dev-hxb

mac

2024-02-20 dc8ae12444d1d887394eb525e2b80dd120dc4c87

 app/src/main/java/com/hdl/photovoltaic/ui/test/UniAppMqtt.java

New file
@@ -0,0 +1,274 @@
package com.hdl.photovoltaic.ui.test;

import android.content.Context;
import android.os.Build;

import androidx.annotation.RequiresApi;

import com.alibaba.fastjson.JSON;
import com.hdl.photovoltaic.other.HdlUniLogic;
import com.hdl.photovoltaic.uni.HDLUniMP;
import com.hdl.sdk.link.common.utils.LogUtils;
import com.hdl.sdk.link.core.config.HDLLinkConfig;

import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclipse.paho.client.mqttv3.IMqttActionListener;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.IMqttToken;
import org.eclipse.paho.client.mqttv3.MqttCallbackExtended;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;


/**
 * Created by hxb on 2022/1/6.
 */
public class UniAppMqtt {

    private String clientId;

    /**
     * 获取标识mqtt的tag值
     *
     * @return -
     */
    public String getClientId() {
        return clientId;
    }

    final String tag = "uniToAndroid->>>MqttRecvClient--->";
    /**
     * 当前 mqtt client
     */
    MqttAndroidClient mClient;

    /**
     * instance
     */
    private volatile static UniAppMqtt instance;

    /**
     * getInstance
     *
     * @return UniAppMqtt
     */
    public static synchronized UniAppMqtt getInstance() {
        if (instance == null) {
            synchronized (HDLLinkConfig.class) {
                if (instance == null) {
                    instance = new UniAppMqtt();
                }
            }
        }
        return instance;
    }

    /**
     * 初始化当前mqtt
     *
     * @param context   上下文
     * @param serverURI 地址，格式tcp://127.0.0.1:1883
     * @param clientId  客户端Id
     * @param topics    主题
     */
    public void initMqtt(Context context, String serverURI, String clientId, String[] topics) throws MqttException {
        if (null != mClient) {
            return;
        }
        this.clientId = clientId;
        mClient = new MqttAndroidClient(context, serverURI, clientId);

        mClient.setCallback(new MqttCallbackExtended() {

            @Override
            public void connectComplete(boolean reconnect, String serverURI) {
                for (String topic : topics) {
                    try {
                        subscribe(topic);
                    } catch (MqttException e) {
                        LogUtils.e(tag, "订阅主题失败" + topic);
                    }
                }
            }

            @Override
            public void connectionLost(Throwable cause) {
                LogUtils.e(tag, "测试mqtt断开");
            }

            @Override
            public void messageArrived(String topic, MqttMessage message) {
                //Topic格式   PCToAndroid(或AndroidToPC)/#guid唯一值/uni_event
                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
                    sendMqttToUni(topic, new String(message.getPayload()));
                }
            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {
//                LogUtils.i(tag,"发布消息成功");
            }
        });
        //配置连接
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(true);
        //服务端允许匿名
//        options.setUserName("username");
//        options.setPassword("password".toCharArray());
        options.setAutomaticReconnect(true);

//        //配置客户端离线或者断开连接的选项
//        DisconnectedBufferOptions disconnectedBufferOptions = new DisconnectedBufferOptions();
//        disconnectedBufferOptions.setBufferEnabled(true);
//        disconnectedBufferOptions.setBufferSize(5000);
//        disconnectedBufferOptions.setDeleteOldestMessages(true);
//        disconnectedBufferOptions.setPersistBuffer(true);
//        mClient.setBufferOpts(disconnectedBufferOptions);
        connect(options);
    }


    /**
     * 连接mqtt
     *
     * @param options -
     */
    private void connect(MqttConnectOptions options) throws MqttException {
        try {
            mClient.connect(options, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    LogUtils.i(tag, "mqtt连接成功");
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    LogUtils.e(tag, "mqtt连接失败" + JSON.toJSONString(asyncActionToken.getException().getMessage()) + "  exception=" + JSON.toJSONString(exception.getMessage()));
                }
            });
        } catch (MqttException e) {
            LogUtils.e(tag, e.getMessage());
        }
    }

    /**
     * 订阅主题
     *
     * @param topic 主题
     */
    public void subscribe(String topic) throws MqttException {
        mClient.subscribe(topic, 2, null, new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {
                LogUtils.i(tag, "订阅主题" + topic);
            }

            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                LogUtils.e(tag, "订阅主题失败" + topic);
            }
        });
    }

    /**
     * 发布数据出去
     *
     * @param topic   主题
     * @param payload 内容
     */
    public void publish(String topic, String payload) throws MqttException {

        //回复时，mqtt主题中的方向要变化，要做方向替换
        topic = topic.replace("PCToAndroid", "AndroidToPC");
        String finalTopic = topic;
        mClient.publish(topic, payload.getBytes(), 1, false, null, new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {
                LogUtils.e(tag, "回复主题--->" + finalTopic + "\r\n" + payload);
            }

            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                LogUtils.e(tag, "回复失败--->" + finalTopic + "\r\n" + exception.getMessage());
            }
        });
    }

    /**
     * 取消订阅
     */
    public void unsubscribe(String topic) throws MqttException {
        mClient.unsubscribe(topic, null, new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {

            }

            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {

            }
        });
    }

    /**
     * 断开连接
     */
    public void disconnect() throws MqttException {
        mClient.disconnect(null, new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {
                LogUtils.e(tag, "断开连接");
            }

            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {

            }
        });
    }

    /**
     * uni通过qtt传过来的数据处理
     *
     * @param topic   主题
     * @param payload 负载内容
     */
    @RequiresApi(api = Build.VERSION_CODES.O)
    void sendMqttToUni(final String topic, String payload) {
        if (null == topic || null == payload) {
            return;
        }
        String[] split = topic.split("/");
        if (split.length < 3) {
            return;
        }
        //表示大类
        String request_module_topic = split[2];
        MqttDCUniMPJSCallback mqttDCUniMPJSCallback = new MqttDCUniMPJSCallback();
        mqttDCUniMPJSCallback.setMqttCallBack(new MqttCallBack() {
            @Override
            public void onResult(Object data) {
                if (null != data)
                    try {
                        //返回数据给uni
                        publish(topic, data.toString());
                    } catch (Exception ignored) {
                    }
            }
        });
        // JSON.parse(payload)
        HdlUniLogic.getInstance().onOtherUniMPEventReceive(HDLUniMP.UNI_APP_ID, request_module_topic, payload, mqttDCUniMPJSCallback);
    }

    private boolean mIsUni = false;

    public void setUni(boolean isUni) {
        mIsUni = isUni;
    }

    public boolean getUni() {
        return mIsUni;
    }
}