MREdustryXR/Assets/Scripts/MQTTClient.cs

using LitJson;
using login;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using UnityEngine;
using UnityEngine.Android;
using uPLibrary.Networking.M2Mqtt.Messages;
using static QTTManager;

public class MQTTClient : MonoSingleton<MQTTClient>
{
    //public string front = "client/";
    // public string id = "";
    //public string username = "u@unity3";// 需要根据服务器设置
    //public string password = null;// 需要根据服务器设置
    public string rid = "mqttx_b4c02ddc"; //其他人的ID
    //public string account;
    //public string roomId;
    //public string email;
    //public string phone;
    //public string roleId;
    //public string resourcePool;
    //public string expertType;
    //public string _username;

    public event Action<JsonData> OnCoordinate;
    public static byte[] bytes;
    // public static string certification;
    // public static byt ta;
    QTTManager qt;
    // Start is called before the first frame update
    void Start()
    {
        // 请求文件读取和写入权限
        if (!Permission.HasUserAuthorizedPermission(Permission.ExternalStorageRead) ||
            !Permission.HasUserAuthorizedPermission(Permission.ExternalStorageWrite))
        {
            Permission.RequestUserPermission(Permission.ExternalStorageRead);
            Permission.RequestUserPermission(Permission.ExternalStorageWrite);
        }
        bytes = (Resources.Load("emqxsl-ca") as TextAsset).bytes;

        Debug.Log(" DGJ  ===> emqxsl-ca.bytes " + bytes.Length);
    }
    Queue<MqttMsgPublishEventArgs> rlist = new Queue<MqttMsgPublishEventArgs>();
    private void OnReceived(MqttMsgPublishEventArgs obj)
    {
        rlist.Enqueue(obj);


    }

    private void OnConnecting()
    {
        Debug.Log("MQtt  连接中");
    }

    private void onSucceed()
    {
        // Subscribe(MQTTManager.Instance.front + "online/" + MQTTManager.Instance.phone);

        //Subscribe(MQTTManager.Instance.front + "personnel/" + MQTTManager.Instance.resourcePool);
        Subscribe(MQTTManager.Instance.front + "personnel/" + MQTTManager.Instance.resourcePoolId);
        Subscribe(MQTTManager.Instance.front + "online/" + MQTTManager.Instance.id);
    }



    private void onFaild()
    {
        Debug.Log("MQtt  连接失败");
    }

    // Update is called once per frame
    void Update()
    {
        if (rlist.Count > 0)
        {
            for (int i = 0; i < rlist.Count; i++)
            {
                OnUnityReceived(rlist.Dequeue());
            }
        }
    }
    //MQTT接收到的数据
    public void OnUnityReceived(MqttMsgPublishEventArgs obj)
    {
        string msg = Encoding.UTF8.GetString(obj.Message);
        Debug.Log("uid => " + obj.Topic + ":\n" + msg);
        //   UILogManager.Instance.text3.text = msg;
        MQTTManager.Instance.Received(msg);
    }

    private void OnDestroy()
    {
        DisConnect();
    }

    //连接
    public void Connect()
    {

      //  Debug.Log("DGJ ===> MQTT " + HttpActionLang.Instance.mqttSocket);
        //if (DeviceType.type == "Phone")
        //{
        //    id =UserInfo.Instance.name + "_Phone";
        //    rid = front+UserInfo.Instance.name + "_Glasses";

        //}
        //else
        //{
        //    id = UserInfo.Instance.name + "_Glasses";
        //    rid = front+UserInfo.Instance.name + "_Phone";
        //}

        //  Debug.Log("DGJ ==>MQTT " + id + account + "  " + username + "   " + certification + "  " + HttpActionLang.Instance.mqttSocket);

        DisConnect();
     //   qt = new QTTManager(MQTTManager.Instance.clientId, MQTTManager.Instance.username, MQTTManager.certification, HttpActionLang.Instance.mqttSocket, "1883");

        qt.ConnectionFailed += onFaild;
        qt.ConnectionSucceeded += onSucceed;
        qt.OnConnecting += OnConnecting;
        qt.OnReceived += OnReceived;
        qt.OnClose += OnClose;
        qt.Connect();
        StartCoroutine(Reconnection());
        //  StartSendCameraPos();
    }

    private void OnClose(EventArgs obj)
    {
        Debug.Log("断开连接");


    }

    private IEnumerator Reconnection()
    {
        while (true)
        {
            yield return new WaitForSeconds(5);
            if (qt != null && !qt.IsConnect())
            {
                Debug.Log(" DGJ ===>  Reconnection ");
                Connect();
            }
        }
    }



    //断开连接
    public void DisConnect()
    {
        if (qt != null && qt.IsConnect())
            qt.DisConnect();

    }

    /// <summary>
    /// 订阅频道
    /// </summary>
    /// <param name="channelID"></param>
    public void Subscribe(string channelID)
    {
        Debug.Log(" DGJ   =====> Subscribe " + channelID);
        if (qt != null && qt.IsConnect())
        {
            ushort s = qt.Subscribe(
                        new string[]
                        {
                              channelID
                              //front+"room/"+roomId

                        },
                        new byte[]
                        {
                                MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE,
                                //MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE

                        });


            Debug.Log(" DGJ   =====> Subscribe2");
        }
        else
            Debug.LogError(" MQTT 未连接 ！！！");



    }

    public void UnSubscribe(string channelID)
    {
        if (qt != null && qt.IsConnect())
        {
            ushort s = qt.Unsubscribe(new string[] { channelID });
        }
    }


    public void StartSendCameraPos()
    {
        StartCoroutine(sendCameraPos());
    }

    //眼镜端像手机端发送实时位置
    IEnumerator sendCameraPos()
    {
        Debug.Log("DGJ  =====>  sendCameraPos" + qt.IsConnect());
        while (true)
        {
            yield return new WaitForSeconds(1f);
            if (qt != null && qt.IsConnect())
            {
                JsonData json = new JsonData();
                json["type"] = "CamPos";
                //  json["x"] = OpenXRCamera.Instance.head.position.x;
                //json["y"] = OpenXRCamera.Instance.head.position.y;
                //json["z"] = OpenXRCamera.Instance.head.position.z;
                //json["x"] = GameManager.Instance.Player.transform.localPosition.x;
                //json["y"] = GameManager.Instance.Player.transform.localPosition.y;
                //json["z"] = GameManager.Instance.Player.transform.localPosition.z;
                json["Sid"] = "sid";//选择的场景id
                publish(Encoding.UTF8.GetBytes(json.ToJson()));
            }


        }
    }
    //眼镜发送触发的景点
    public void sendActiveSp(string spid, bool isOpen)
    {
        JsonData json = new JsonData();
        json["type"] = "ActiveSp";
        json["Sid"] = "sid";//选择的场景id
        json["spid"] = spid;//景点id
        json["isOpen"] = isOpen;//是否打开
        publish(Encoding.UTF8.GetBytes(json.ToJson()));
        Debug.Log("MQtt  发送manage");
    }


    //眼镜发送触发的视频
    public void sendActiveVideo(string spid, string videoId, bool isplay, float jindu)
    {
        JsonData json = new JsonData();
        json["type"] = "ActiveVideo";
        json["Sid"] = "sid";//选择的场景id
        json["spid"] = spid;//景点id
        json["videoId"] = videoId;//视频id
        json["isplay"] = isplay;//是否播放
        json["jindu"] = jindu;//视频进度
        publish(Encoding.UTF8.GetBytes(json.ToJson()));
        Debug.Log("MQtt  发送manage");
    }

    public void SendCoord()
    {
        JsonData json = new JsonData();
        json["id"] = UserInfo.Instance.name;
        json["type"] = "Coord";
        json["x"] = 0.1f;
        json["y"] = 0.1f;
        json["z"] = 0.1f;

    }



    public void publish(byte[] bs)
    {
        if (qt != null && qt.IsConnect())
        {
            // Debug.Log(id + account + "  DGJ  publish =====>  " + front + "room/" + roomId + "   " + bs.Length);
            //  qt.Publish(front + "room/" + roomId, bs, MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
        }
        else
        {
            Debug.LogError(" MQTT  未连接 ");
        }

    }

    public void publish(string channelID, byte[] bs)
    {
        if (qt != null && qt.IsConnect())
        {
            Debug.Log(MQTTManager.Instance.clientId + MQTTManager.Instance.account + "  DGJ  publish =====>  " + channelID + "   " + bs.Length);
            qt.Publish(channelID, bs, MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
        }
        else
        {
            Debug.LogError(" MQTT  未连接 ");
        }

    }
}