websocket长连接

using UnityEngine;using System.Collections;using System.Collections.Generic;using System.IO;using System.Net;using System.Net.Sockets;using System.Runtime.InteropServices;namespace SYW_WebScoket{public class WebSocketManager : Singleton<WebSocketManager>{#region Fieldpublic static string m_address { get; set; }/// <summary>/// 是否发送/// </summary>private bool IsSend;/// <summary>/// 是否接收/// </summary>private bool IsRecv;/// <summary>/// 是否关闭/// </summary>public bool IsClose { get; set; }//public string ReturnedMessage { get; set; }public string Message { get; set; }public string Recv { get; set; }private Queue<string> message_Queue = new Queue<string>();private Dictionary<string, WebSocket> m_socketDict = new Dictionary<string, WebSocket>();#endregion/// <summary>/// 使用协程去连接/// </summary>/// <param name="ws"></param>/// <returns></returns>IEnumerator StartConnect(string address){IsSend = false;IsRecv = false;IsClose = false;WebSocket ws = GetSocket(address);yield return ws.Connect();m_address = address;for (int i = 0; i < ws.m_Messages.Count; i++){Recv = ws.RecvString();}while (true){if (IsSend){//TODO发送信息ws.SendString(message_Queue.Dequeue());IsSend = false;IsRecv = true;}if (IsRecv){//TODO接收消息for (int i = 0; i < ws.m_Messages.Count; i++){Recv = ws.RecvString();}IsRecv = false;}if (IsClose){break;}if (ws.error != null){Debug.LogError("Error: " + ws.error);break;}yield return new WaitForEndOfFrame();}ws.Close();}#region Method/// <summary>/// 创建一个 WebSocket/// </summary>/// <param name="address">地址</param>/// <returns></returns>private WebSocket CreateSocket(string address){WebSocket ws = new WebSocket(new System.Uri(address));m_socketDict.Add(address, ws);return ws;}/// <summary>/// 得到一个WebSocket/// </summary>/// <param name="address">地址</param>/// <returns></returns>public WebSocket GetSocket(string address){if (m_socketDict.ContainsKey(address))return m_socketDict[address];return CreateSocket(address);}/// <summary>/// 连接服务器/// </summary>/// <param name="address">地址address</param>public void ConnectSocket(string address){StartCoroutine(StartConnect(address));}/// <summary>/// 发送消息/// </summary>/// <param name="message"></param>public void Send(string message){message_Queue.Enqueue(message);IsSend = true;}#endregion}}