《Unity3D網絡遊戲實踐》（第2版）要點摘錄 – 「異步和多路復用」

狀態檢測（Poll）

• Poll

  • public bool Pool(int microSeconds, SelectMode mode)

    • microSeconds：等待回應的時間（微秒），如果參數為-1，表示無限期等待響應（阻塞）；如果參數為0，表示不阻塞

    • mode：

      • SelectMode.SelectRead：如果Socket可讀（緩沖區有數據可以讀取），返回true

      • SelectMode.SelectWrite：如果Socket可寫（緩沖區有數據可以發送），返回true

      • SelectMode.SelectError：連接失敗返回true

  • 原理：

    • 通過SelectMode檢查Socket的狀態是否可讀/可寫/連接失敗

    • 在指定時段內阻止執行

    • 目的：解決同步程序的阻塞問題，在阻塞方法前做判斷，有數據讀時才Receive，有數據寫時才Send

• 客戶端Poll

  • private void Update()
    {
        if (socket == null) { return; }
    ​
        //有可讀數據
        if(socket.Poll(0, SelectMode.SelectRead))
        {
            byte[] readBuff = new byte[1024];
            int count = socket.Receive(readBuff);
            string recvStr = System.Text.Encoding.UTF8.GetString(readBuff, 0, count);
            responseText.text = recvStr;
        }
    }

• 服務端Poll

  • static void Main(string[] args)
    {
        //Create Socket ...
        //Bind ...
        //Listen ...
    ​
        while (true)
        {
            //檢查有沒有客戶端連接
            if(listenSocket.Poll(0, SelectMode.SelectRead))
            {
                ReadListenfd(listenSocket);
            }
    ​
            foreach (ClientState state in clients.Values)
            {
                Socket clientfd = state.socket;
                //檢查客戶端Socket有沒有可讀的信息
                if(clientfd.Poll(0, SelectMode.SelectRead))
                {
                    if (!ReadClientfd(clientfd))
                    {
                        break;
                    }
                }
            }
            System.Threading.Thread.Sleep(1);
        }
    }
    ​
    public static void ReadListenfd(Socket listenSocket)
    {
        Console.WriteLine("Accept");
        Socket clientfd = listenSocket.Accept();
        ClientState cs = new ClientState();
        cs.socket = clientfd;
        clients.Add(clientfd, cs);
    }
    ​
    public static bool ReadClientfd(Socket clientSocket)
    {
        ClientState cs = clients[clientSocket];
    ​
        //接收數據
        int count = 0;
        try
        {
            count = clientSocket.Receive(cs.readBuff);
        }
        catch(SocketException ex)
        {
            clientSocket.Close();
            clients.Remove(clientSocket);
            Console.WriteLine("Receive Socket Exception: " + ex.ToString());
            return false;
        }
    ​
        //客戶端關閉
        if(count == 0)
        {
            clientSocket.Close();
            clients.Remove(clientSocket);
            Console.WriteLine("Socket Closed");
            return false;
        }
    ​
        //廣播信息至所有客戶端
        string recvStr = System.Text.Encoding.UTF8.GetString(cs.readBuff, 0, count);
        Console.WriteLine("Receive: " + recvStr);
        string sendStr = clientSocket.RemoteEndPoint.ToString() + ":" + recvStr;
        byte[] sendBytes = System.Text.Encoding.UTF8.GetBytes(sendStr);
        foreach (ClientState state in clients.Values)
        {
            state.socket.Send(sendBytes);
        }
    ​
        return true;
    }

• 弊端

  • 如果沒有收到數據，Poll客戶端/服務端的循環也會一直在做檢測，造成浪費