MREdustryXR/Assets/Scripts/MQTTManager.cs

using LitJson;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using UnityEngine;


public class MQTTManager : MonoSingleton<MQTTManager>
{

    public string front = "client/";
    public string id = "";
    public string username = "u@unity3";// 需要根据服务器设置
    public string password = null;// 需要根据服务器设置
    public string rid = "mqttx_b4c02ddc"; //其他人的ID
    public string clientId = "";
    public string account;
    public string roomId;
    public string email;
    public string phone;
    public string roleId;
    //  public string resourcePool;
    public string resourcePoolId;
    public string expertType;
    public string _username;
    public string room;
    public static string certification;

    /// <summary>
    ///  获取信令
    /// </summary>
    public void Signal()
    {
      //  GameStart.Instance.StartCoroutine(HttpTool.Instance.SendHttp(HttpActionLang.signal_certification, "", SignalCallBack));

        //  GameStart.Instance.StartCoroutine(HttpTool.Instance.SendHttp(HttpActionLang.userinfo, "", UserInfoCallBack));
        // HttpTool.Instance.PostMqtt(HttpAction.signal_certification, "", SignalCallBack);
    }


    public void SetAccoutInfo(string account)
    {
        MQTTManager.Instance.account = account;

    }
    private void SignalCallBack(string msg)
    {
        Debug.Log(msg);

        JObject obj = JObject.Parse(msg);
        if (obj["code"].ToString() == "200")
        {
          //  HttpActionLang.Instance.mqttSocket = obj["data"]["host"].ToString();
            MQTTManager.certification = obj["data"]["certification"].ToString();
            MQTTManager.Instance.front = obj["data"]["topicPrefix"].ToString();
            MQTTManager.Instance.clientId = obj["data"]["clientId"].ToString();
            MQTTManager.Instance.username = obj["data"]["username"].ToString();
         //   MQTTClient.Instance.Connect();

            //  StartCoroutine(TestCreateRoom());
        }
        else
        {
            Debug.LogError("MQTT 获取信令失败 ！！！" + obj["code"].ToString());
        }
    }



    private void UserInfoCallBack(string msg)
    {
        Debug.Log(msg);

        JObject obj = JObject.Parse(msg);
        if (obj["code"].ToString() == "200")
        {
            MQTTManager.Instance._username = obj["data"]["name"].ToString();
            MQTTManager.Instance.roleId = obj["data"]["roleId"].ToString();
            MQTTManager.Instance.email = obj["data"]["email"].ToString();
            MQTTManager.Instance.phone = obj["data"]["phone"].ToString();
            //   MQTTManager.Instance.resourcePool = obj["data"]["resourcePool"].ToString();
            MQTTManager.Instance.resourcePoolId = obj["data"]["resourcePoolId"].ToString();
            MQTTManager.Instance.expertType = obj["data"]["expertType"].ToString();
        }
        else
        {
            Debug.LogError("获取用户信息失败 ！！！" + obj["code"].ToString());
        }
    }

    public void SetRoomId(string id)
    {
        MQTTManager.Instance.roomId = id;
        //   MQTTClient.Instance.roomId = "9527";

        // 订阅房间频道

        MQTTClient.Instance.Subscribe(MQTTManager.Instance.front + "room/" + id);



    }

    public void UnSubscribe(string id)
    {
        MQTTClient.Instance.UnSubscribe(MQTTManager.Instance.front + "room/" + id);
    }

    /// <summary>
    /// 发送消息
    /// </summary>
    /// <param name="msg"></param>
    public void PushMsg(string msg)
    {
        if (!string.IsNullOrEmpty(msg))
        {
            JsonData json = new JsonData();
            json["account"] = MQTTManager.Instance.account;
            json["Sid"] = "sid";//选择的场景id
            json["msg"] = msg;
            MQTTClient.Instance.publish(Encoding.UTF8.GetBytes(json.ToJson()));

        }

    }

    /// <summary>
    /// 发送消息
    /// </summary>
    /// <param name="msg"></param>
    public void PushMsg(string channelID, string msg)
    {

        Debug.Log("DGJ ===> MQTT Test " + msg);
        if (!string.IsNullOrEmpty(msg))
        {
            MQTTClient.Instance.publish(channelID, Encoding.UTF8.GetBytes(msg));

        }

    }

    /// <summary>
    ///  接受消息
    /// </summary>
    /// <param name="msg"></param>
    public void Received(string msg)
    {
        JObject obj = JObject.Parse(msg);

        Debug.Log("Received  ===>  " + obj["action"].ToString());

        switch (obj["action"].ToString())
        {
          
            default:
                break;
        }


    }
}