JunShi101ShiNei/Assets/MediaSoup/WebSocket/WebSocketClient.cs

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using BestHTTP.WebSocket;
using System;
using BestHTTP;
using BestHTTP.Authentication;

public class WebSocketClient : MonoBehaviour {

    //  [SerializeField]
    // private string address = "wss://rtc.shadowcreator.com:3300";
    public static Dictionary<string, WebSocketClient> webSockets = new Dictionary<string, WebSocketClient>();
    private WebSocket _webSocket;
	private static bool init = false;
    //	public static WebSocketClient Instance{ private set; get;}

    private string sName = "111";
	public delegate void OnWebSocketCloseDelegate ();
	public static OnWebSocketCloseDelegate OnWebSocketClose;
    public delegate void OnMessagedDelegate(string data);
    public OnMessagedDelegate OnMessaged;
    // Use this for initialization
    void Start ()
    {
        DontDestroyOnLoad(this.gameObject);
       // Invoke("Connect", 1f);
     //   Connect();
    }

	void Awake()
	{
		//if (!init) {
			//Instance = this;
		//} else {
		//	Destroy (this.gameObject);
		//	return;
		//}
	}
	
	// Update is called once per frame
	void Update () {
	}

	void OnDestroy()
	{
		CloseWebSocket ();
	
	}

	void OnApplicationQuit()
	{
		CloseWebSocket ();
	}

	private void CloseWebSocket()
	{
		if (_webSocket != null) {
            webSockets.Remove(name);
            _webSocket.Close();
			_webSocket = null;
		}
	}

	void OnOpen(WebSocket ws)
	{
		Debug.Log("-WebSocket Open!\n");
	//	StartCoroutine (Ping ());
	}
    public static float times;
    public static int count=0;
    public static int maxCount;
	void OnMessageReceived(WebSocket ws, string message)
	{
        
       // Debug.Log(message);
        /*
        times = times + Time.deltaTime;
        count++;
        if (times>1)
        {
            maxCount = count;
            count = 0;
            times = 0;
        }*/
        // 
        OnMessage(message);
    }
    private void OnMessage(string data)
    {
        if (OnMessaged != null)
        {
            OnMessaged(data);
        }
    }
    void OnClosed(WebSocket ws, UInt16 code, string message)
	{
		string log = string.Format("-WebSocket closed! Code: {0} Message: {1}\n", code, message);
		Debug.Log(log);
		if (OnWebSocketClose != null) {
			OnWebSocketClose ();
		}
	}

	void OnError(WebSocket ws, Exception ex)
    {
        Debug.Log("OnError");
        string errorMsg = string.Empty;
		#if !UNITY_WEBGL || UNITY_EDITOR
		if (ws.InternalRequest.Response != null)
			errorMsg = string.Format("Status Code from Server: {0} and Message: {1}", ws.InternalRequest.Response.StatusCode, ws.InternalRequest.Response.Message);
		#endif

		string log = string.Format("-An error occured: {0}\n", (ex != null ? ex.Message : "Unknown Error " + errorMsg));
		Debug.Log (log);
        webSockets.Remove(name);
        _webSocket = null;
		/*
		LoadManager.showClickPop ("网络异常，请重新登陆",ShadowSystem.Quit);*/
	}

	public void Connect()
    {
        Debug.Log("开始连接");
        webSockets.Add(sName, this);
         //_webSocket = new WebSocket(new Uri(NetworkConfiguration.socket_Url));
        _webSocket = new WebSocket(new Uri(NetworkConfiguration.socket_Url_test));
        _webSocket.InternalRequest.AddHeader("Sec-WebSocket-Protocol", "protoo");
       // _webSocket.Send
        //_webSocket.
#if !UNITY_WEBGL
        _webSocket.StartPingThread = true;
#if !BESTHTTP_DISABLE_PROXY
        if (HTTPManager.Proxy != null)
        {
            _webSocket.InternalRequest.Proxy = new HTTPProxy(HTTPManager.Proxy.Address, HTTPManager.Proxy.Credentials, false);
            Debug.Log("连接。。。。");

        }
#endif
#endif

        // Subscribe to the WS events
        _webSocket.OnOpen += OnOpen;
		_webSocket.OnMessage += OnMessageReceived;
		_webSocket.OnClosed += OnClosed;
		_webSocket.OnError += OnError;
        // Start connecting to the server
        _webSocket.Open();
        Debug.Log("开始连接Open");
    }

	IEnumerator Ping()
	{
		while (_webSocket != null) {
			yield return new WaitForSeconds (50);
            Debug.Log("Ping");
			Send ("Ping");
		}
	}

	public void Send(string message)
	{
		if (_webSocket != null)
        {
            //Debug.Log(message);
            _webSocket.Send (message);
        }
	}
}