MRSupper_Phone/Assets/MediaSoup/WebSocket/WSHandler.cs

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using LitJson;
using System;
using XRTool.Util;
using UnityEngine.SceneManagement;
using BestHTTP.WebSocket;

public class WSHandler
{

    public static WebSocketClient _client;
    public static WebSocketClient _roomClient;
    public static WebSocketClient _roomRtcClient;

    private static WSOfficeHandler _Office;
    private static WSRtcHandler _Rtc;
    private static WSRtcHandler _webRtc;

    public static WSRtcHandler Rtc
    {
        get
        {
            if (_Rtc == null)
            {
                _Rtc = new WSRtcHandler();
            }
            return _Rtc;
        }
    }

    public static WSOfficeHandler Office
    {
        get
        {
            if (_Office == null)
            {
                _Office = new WSOfficeHandler();
            }
            return _Office;
        }
    }
    public static WSRtcHandler WebRtc
    {
        get
        {
            if (_webRtc == null)
            {
                _webRtc = new WSRtcHandler();
            }
            return _webRtc;
        }
    }

    public static void init()
    {
        GameObject prefab = (GameObject)Resources.Load("websocket");
        GameObject websocket = GameObject.Instantiate(prefab);
        _client = websocket.GetComponent<WebSocketClient>();
        _client.OnMessaged += OnMessageReceived;
        _client.OnWebErrorClose += OnWebErrorClosed;
        _client.Connect(NetWorkHeadersConfig.Remote_SocketHall_url+"token=" + UserInfo.User_Token+"&unionId="+UserInfo.UnionId, "大厅");

        _client._webSocket.OnError += OnError;
    }

    private static void OnRtcError(WebSocket ws, Exception ex)
    {
        //PopUpInfo.Instance.showPublic(PopUpInfo.PopType.PopOk, RtcStrConfig.serverClose, "返回登陆", () => {

        //    ShowLogin.Instance.loginType = LoginType.INIT;
        //    ScenesManager.Instance.showWindow(SceneType.ShowLogin);
        //});
        WSHandler.clientClosed();
        WSHandler.roomRtcCloes();
        // PopUpInfo.Instance.showPublic(PopUpInfo.PopType.Tip, "服务器连接失败！");
        /*
        TimerMgr.Instance.CreateTimer(() =>
        {
            init();
        }, 1f);*/
    }

    private static void OnError(WebSocket ws, Exception ex)
    {
        _client.CloseWebSocket();
        GameObject.Destroy(_client.gameObject);

        WSHandler.roomRtcCloes();
        WSHandler.clientClosed();
        //PopUpInfo.Instance.showPublic(PopUpInfo.PopType.PopOk, RtcStrConfig.serverClose, "返回登陆", () => {

        //    ShowLogin.Instance.loginType = LoginType.INIT ;
        //    ScenesManager.Instance.showWindow(SceneType.ShowLogin);
        //});
    }

    private static void OnWebErrorClosed(string data)
    {
        _client.CloseWebSocket();
        GameObject.Destroy(_client.gameObject);

        WSHandler.roomRtcCloes();
        WSHandler.clientClosed();
        //PopUpInfo.Instance.showPublic(PopUpInfo.PopType.PopOk, RtcStrConfig.serverClose, "返回登陆", () => {

        //    ShowLogin.Instance.loginType = LoginType.INIT;
        //    ScenesManager.Instance.showWindow(SceneType.ShowLogin);
        //});
    }

    public static void clientClosed()
    {
        _client.CloseWebSocket();
        GameObject.Destroy(_client.gameObject);
    }

    public static string _roomid;

    public static void roomRtcinit(string roomid)
    {
        _roomid = roomid;
        GameObject prefab = (GameObject)Resources.Load("websocket");
        GameObject websocket = GameObject.Instantiate(prefab);
        _roomRtcClient = websocket.GetComponent<WebSocketClient>();
         _roomRtcClient.OnWebErrorClose += OnRoomRtcWebErrorClosed;
        _roomRtcClient.OnMessaged += OnRoomRtcMessageReceived;
        //
        //    _roomRtcClient.Connect("wss://apitest.shadowcreator.com:6443/?roomId=" + _roomid);

        _roomRtcClient.Connect(NetWorkHeadersConfig.Remote_SocketRtc_url + "unionId=" + UserInfo.UnionId+ "&token=" + UserInfo.User_Token + "&roomId="+ _roomid, "音视频");

        _roomRtcClient._webSocket.OnError += OnRtcError;
        //   _roomRtcClient.Connect("wss://cgdemo.shadowcreator.com/rtc/?roomId=" + _roomid, "音视频");
        //    _roomRtcClient.Connect("wss://api.shadowcreator.com:443/rtcwss/?roomId=" + _roomid);
        _roomRtcClient._webSocket.OnOpen += OnrtcOpen;
        _roomRtcClient._webSocket.OnMessage += OnRTCMessage;
    }

    private static void OnRTCMessage(WebSocket webSocket, string message)
    {
        if (SCRtcFactory.Instance != null)
        {
            JsonData data = JsonMapper.ToObject(message);
            if (data.Keys.Contains("id") && data["id"].ToString() == WSRtcHandler.produceid)
            {
                SCRtcFactory.Instance.mSCRtcHandle.setProduce(data["data"]["id"].ToString());
            }
            else if (data.Keys.Contains("request"))
            {
                Rtc.RtcResponse(data);
            }
        }
    }

    public static void OnrtcOpen(WebSocket ws)
    {
        RemoteRtc.Instance.start(_roomid);
    }

    public static void roomRtcCloes()
    {
        try
        {
            if (_roomRtcClient)
            {
                _roomRtcClient.CloseWebSocket();
            }
            if (_roomRtcClient.gameObject)
            {
                GameObject.Destroy(_roomRtcClient.gameObject);
            }
            RemoteRtc.Instance.Close();
        }
        catch
        {
           // UnityLog.LogError("退出房间异常"+ _roomRtcClient);
        }
    }
    public static void OnRoomRtcWebErrorClosed(string message)
    {
        roomRtcCloes();

        /*
        TimerMgr.Instance.CreateTimer(() =>
        {
            roomRtcinit(_roomid);

        }, 1f);*/
    }
    

    public static void roomCloes()
    {
        _roomClient.CloseWebSocket();
        GameObject.Destroy(_roomClient.gameObject);
        roomRtcCloes();
    }

    public static void OnRoomWebErrorClosed(string message)
    {
        roomCloes();
        /*
        TimerMgr.Instance.CreateTimer(() =>
        {
            roominit(_roomid);
            WSHandler.Room.OnInit -= onRoomInit;
            WSHandler.Room.OnInit += onRoomInit;

        }, 1f);*/
    }

    public static void SendRtcMessage(JsonData data)
    {
        UnityLog.Log("SendRtcMessage===>" + data.ToJson(), 1);
        string message = data.ToJson();
        if (_roomRtcClient != null)
            _roomRtcClient.Send(message);
    }

    public static void SendMessage(JsonData data)
    {
        UnityLog.Log("SendMessage===>" + data.ToJson(), 1);
        string message = data.ToJson();
        if (_client != null)
            _client.Send(message);
    }

    private static JsonData message_data = new JsonData();
    public static void OnMessageReceived(string message)
    {
        UnityLog.Log("SocketMessage===>" + message, 1);
        message_data.Clear();
        message_data = JsonMapper.ToObject(message);
        Office.OnMessageReceived(message_data);
    }

    public static void OnRoomRtcMessageReceived(string message)
    {
        UnityLog.Log("SocketRoomRtcMessage===>" + message, 1);
        message_data.Clear();
        message_data = JsonMapper.ToObject(message);
        Rtc.OnMessageReceived(message_data);
    }
}