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 Field

public 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

}
}