《Unity3D網絡遊戲實踐》（第2版）要點摘錄 - 「通信協議與消息隊列基礎」

書名：《Unity3D網絡遊戲實踐》（第2版）

作者：羅培羽

所讀版本：機械工業出版社

通信協議與消息隊列

通信協議：把協議名、客戶端標識、具體參數組成一個固定格式的字符串，在服務端和客戶端之間傳輸，再根據協議格式解析出數據使用/轉發
- 如：消息名|客戶端IP與端口, 參數1, 參數2, 參數n
消息隊列：在Unity裡只有主線程可以操作UI組件，多線程消息處理容易導致各種奇怪的混亂，因此可以使用消息隊列讓主線程去處理Socket異步接收到的信息
- C#異步通信由線程池實現，不同的BeginReceive不一定在同一線程中執行
- 創建一個由主線程讀取的消息列表，每當收到消息便在列表末端添加數據
  - 數據從頂端讀取，讀取處理後將其從頂端移除

public static class NetManager {
    static Socket socket;
    //接收緩沖區
    static byte[] readBuff = new byte[1024];
    //委托類型
    public delegate void MsgListener(string str);
    //監聽列表（各個消息名對應的處理方法）
    private static Dictionary<string, MsgListener> listeners = new Dictionary<string, MsgListener>();
    //消息隊列
    static List<string> msgList = new List<string>();
    
    //記錄消息對應的處理方法
    public static void AddListener(string msgName, MsgListener listener)
    {
        listeners[msgName] = listener;
    }

    public static void Connect(string ip, int port)
    {
        socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        socket.Connect(ip, port); //同步連接
        socket.BeginReceive(readBuff, 0, 1024, 0, ReceiveCallback, socket); //異步接收信息
    }

    static void ReceiveCallback(IAsyncResult ar)
    {
        try
        {
            Socket socket = (Socket)ar.AsyncState;
            int count = socket.EndReceive(ar);
            string recvStr = System.Text.Encoding.UTF8.GetString(readBuff, 0, count);

            //消息隊列更新
            msgList.Add(recvStr);

            socket.BeginReceive(readBuff, 0, 1024, 0, ReceiveCallback, socket);
        }
        catch(SocketException ex)
        {
            Debug.Log("Socket Receive Failed: " + ex.ToString());
        }
    }

    public static void Send(string sendStr)
    {
        if (socket == null) { return; }
        if (!socket.Connected) { return; }

        //同步發送
        byte[] sendBytes = System.Text.Encoding.UTF8.GetBytes(sendStr);
        socket.Send(sendBytes);
    }

    //每幀更新，持續處理消息隊列中的消息
    public static void Update()
    {
        if (msgList.Count <= 0) { return; }
        string msgStr = msgList[0];
        msgList.RemoveAt(0);

        string[] split = msgStr.Split('|');
        string msgName = split[0];
        string msgArgs = split[1];

        if (listeners.ContainsKey(msgName))
        {
            listeners[msgName](msgArgs);
        }
    }
}