123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156 |
- using LitJson;
- using Newtonsoft.Json.Linq;
- using System.Collections;
- using System.Collections.Generic;
- using System.Text;
- using UnityEngine;
- public class MQTTManager : MonoSingleton<MQTTManager>
- {
-
-
-
- public void Signal()
- {
- GameStart.Instance.StartCoroutine(HttpTool.Instance.SendHttp(HttpActionLang.signal_certification, "", SignalCallBack));
-
-
- }
- public void SetAccoutInfo(string account)
- {
- MQTTClient.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();
- MQTTClient.certification = obj["data"]["certification"].ToString();
- MQTTClient.Instance.front = obj["data"]["topicPrefix"].ToString();
- MQTTClient.Instance.id = obj["data"]["clientId"].ToString();
- MQTTClient.Instance.username = obj["data"]["username"].ToString();
- MQTTClient.Instance.Connect();
- }
- 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")
- {
- MQTTClient.Instance._username = obj["data"]["name"].ToString();
- MQTTClient.Instance.roleId = obj["data"]["roleId"].ToString();
- MQTTClient.Instance.email = obj["data"]["email"].ToString();
- MQTTClient.Instance.phone = obj["data"]["phone"].ToString();
- MQTTClient.Instance.resourcePool = obj["data"]["resourcePool"].ToString();
- MQTTClient.Instance.expertType = obj["data"]["expertType"].ToString();
- }
- else
- {
- Debug.LogError("获取用户信息失败 !!!"+ obj["code"].ToString());
- }
- }
- public void SetRoomId(string id)
- {
- MQTTClient.Instance.roomId = id;
-
-
- MQTTClient.Instance.Subscribe(MQTTClient.Instance.front + "room/" + id);
-
- }
-
-
-
-
-
- public void PushMsg(string msg)
- {
- if (!string.IsNullOrEmpty(msg))
- {
- JsonData json = new JsonData();
- json["account"] = MQTTClient.Instance.account;
- json["Sid"] = "sid";
- json["msg"] = msg;
- MQTTClient.Instance.publish(Encoding.UTF8.GetBytes(json.ToJson()));
-
- }
- }
-
-
-
-
- public void Received(string msg)
- {
- JObject obj = JObject.Parse(msg);
- Debug.Log("Received ===> " + obj["action"].ToString());
- switch (obj["action"].ToString())
- {
- case "timeout":
- UICallManager.Instance.EventTimeOut();
- break;
- case "invite":
- if(obj["control"]!=null)
- {
- string roomid = obj["rtcRoom"].ToString();
- UICallManager.Instance.EventInvite(obj["control"].ToString(), roomid);
- }
- else
- {
- Debug.LogError(" 非控制台邀请 ");
- }
-
- break;
- case "noexpert":
- UICallManager.Instance.EventNoExpert();
- break;
- case "chat":
-
- string username = "";
- string chatMsg = "";
- FileList.Instance.AddMsgItem(null, username, chatMsg);
- break;
- case "file":
-
- break;
- default:
- break;
- }
- }
- }
|