關于c#異步傳輸，服務器假死

/////////////////////////////////////////////////////////////////////////服務器////////////////////////////////////////////////////////////////////
    class Serv
    {
        //監聽套接字
        public Socket listenfd;
        //客戶端連接
        public Conn[] conns;
        //最大連接數
        public int maxConn = 50;

        //獲取連接池索引，回傳負數表示獲取失敗
        public int NewIndex()
        {
            if (conns == null) return -1;

            for(int i = 0; i < conns.Length; i++)
            {
                if (conns[i] == null)
                {
                    conns[i] = new Conn();
                    return 1;
                }else if (conns[i].isUse == false)
                {
                    return i;
                }
            }

            return -1;
        }

        //開啟服務器
        public void Start(string host,int port)
        {
            //連接池
            conns = new Conn[maxConn];
            for(int i = 0; i < maxConn; i++)
            {
                conns[i] = new Conn();
            }

            //Socket
            listenfd = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //Bind
            IPAddress ipAdr = IPAddress.Parse(host);
            IPEndPoint ipEp = new IPEndPoint(ipAdr, port);
            listenfd.Bind(ipEp);

            //Listen
            listenfd.Listen(maxConn);

            //Accept
            listenfd.BeginAccept(AcceptCb, listenfd);
            Console.WriteLine("[服務器]啟動成功");
        }

        //Accept回呼，當有客戶端發起連接時的處理
        private void AcceptCb(IAsyncResult ar)
        {
            try
            {
                Console.WriteLine("！！有新的連接到來");
                //獲取連接套接字
                Socket socket = listenfd.EndAccept(ar);
                //獲取可用的連接物件
                int index = NewIndex();
                if (index < 0)
                {
                    socket.Close();
                    Console.WriteLine("[警告]連接已滿");
                }
                else
                {
                    Console.WriteLine("！！已經獲得可用的連接物件");
                    Conn conn = conns[index];
                    conn.Init(socket);
                    string adr = conn.GetAdress();
                    Console.WriteLine("客戶端連接[" + adr + "]  conn池ID:" + index);
                    //準備接收訊息
                    conn.socket.BeginReceive(conn.readBuff, conn.buffCount, conn.BuffRemain(), SocketFlags.None, ReceiveCb,conn);
                }

                Console.WriteLine("再次準備處理新的連接");
                //再次準備處理客戶端連接
                listenfd.BeginAccept(AcceptCb, listenfd);
            }
            catch (Exception e)
            {
                Console.WriteLine("AcceptCb失敗：" + e.Message);
            }
        }

        //接收訊息回呼
        private void ReceiveCb(IAsyncResult ar)
        {
            Conn conn = (Conn)ar.AsyncState;
            try
            {
                int count = conn.socket.EndReceive(ar);
                //關閉信號
                if (count <= 0)
                {
                    Console.WriteLine("收到[" + conn.GetAdress() + "]斷開連接");
                    conn.Close();
                    return;
                }
                
                //資料處理
                string str = Encoding.UTF8.GetString(conn.readBuff, 0, count);
                
                Console.WriteLine("收到[" + conn.GetAdress() + "]資料：" + str);
                str = conn.GetAdress() + ":" + str;
                byte[] bytes = System.Text.Encoding.UTF8.GetBytes(str);
                //將資料發送給所有的連接物件（即資料同步）
                for(int i = 0; i < conns.Length; i++)
                {
                    if (conns[i] == null) continue;
                    if (!conns[i].isUse) continue;
                    Console.WriteLine("將訊息轉播給 " + conns[i].GetAdress());
                    conns[i].socket.Send(bytes);
                }

                //繼續接收
                conn.socket.BeginReceive(conn.readBuff, conn.buffCount, conn.BuffRemain(), SocketFlags.None, ReceiveCb, conn);
            }catch(Exception e)
            {
                Console.WriteLine("收到 [" + conn.GetAdress() + "]斷開連接");
                conn.Close();
            }
        }
    }

////////////////////////////////////////////////////////////////端點類///////////////////////////////////////////////////////////////////
    class Conn
    {
        //緩沖區大小
        public const int BUFFER_SIZE = 1024;
        //Socket
        public Socket socket;
        //是否使用
        public bool isUse = false;
        //Buff
        public byte[] readBuff = new byte[BUFFER_SIZE];
        public int buffCount = 0;

        //建構式
        public Conn()
        {
            readBuff = new byte[BUFFER_SIZE];
        }

        //初始化
        public void Init(Socket socket)
        {
            this.socket = socket;
            isUse = true;
            buffCount = 0;
        }

        //緩沖區剩余的位元組數
        public int BuffRemain()
        {
            return BUFFER_SIZE - buffCount;
        }

        //獲取客戶端地址
        public string GetAdress()
        {
            if (!isUse) return "無法獲取地址";
            return socket.RemoteEndPoint.ToString();
        }

        //關閉
        public void Close()
        {
            if (!isUse) return;
            Console.WriteLine("[斷開鏈接]" + GetAdress());
            socket.Close();
            isUse = false;
        }
    }

////////////////////////////////////////////////////////服務器主程式//////////////////////////////////////////////////////////////////////
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("開啟服務器");
            Serv serv = new Serv();
            serv.Start("127.0.0.1", 1234);

            while (true) {
                Thread.Sleep(1);
            }
        }
    }
//////////////////////////////////////////////////////////////////////////客戶端////////////////////////////////////////////////////////////
public class Client02
{
    //客戶端收到的訊息
    private string recvStr;
    //發送到服務器的訊息
    private string sendStr;
    //Socket和接識訓沖區
    Socket socket;
    string host="127.0.0.1";
    int port=1234;
    const int BUFFER_SIZE = 1024;
    public byte[] readBuff = new byte[BUFFER_SIZE];

    public string RecvStr { get => recvStr; set => recvStr = value; }
    public string SendStr { get => sendStr; set => sendStr = value; }
     
    //連接
    public void Connection()
    {
        try {
            //Socket
            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //Connect
            socket.Connect(host, port);
            Console.WriteLine("客戶端地址 " + socket.LocalEndPoint.ToString());
            Console.WriteLine("服務器地址 " + socket.RemoteEndPoint.ToString());
            //Recv
            socket.BeginReceive(readBuff, 0, BUFFER_SIZE, SocketFlags.None, ReceiveCb, socket);
            Console.WriteLine("客戶端啟動成功");
        }
        catch (Exception)
        {
            Console.WriteLine("啟動失敗");
        } 
    }

    //接識訓呼
    private void ReceiveCb(IAsyncResult ar)
    { 
        try
        {
            //count是接收資料的大小
            int count = socket.EndReceive(ar);
            //資料處理
            RecvStr = System.Text.Encoding.UTF8.GetString(readBuff, 0, count);
            //繼續接收
            socket.BeginReceive(readBuff, 0, BUFFER_SIZE, SocketFlags.None, ReceiveCb, socket);
        }
        catch (Exception)
        {
            Console.WriteLine("連接已經斷開");
            socket.Close();
        }
    }

    //發送資料
    public void Send()
    {
        byte[] bytes = System.Text.Encoding.UTF8.GetBytes(SendStr);
        try
        {
            socket.Send(bytes);
        }
        catch
        {
        }
    }

///////////////////////////////////////客戶端主程式///////////////////////////////////////////
    class Program
    {
        static void Main(string[] args)
        {
            Client02 client = new Client02();
            client.Connection();

            while (true)
            {
                Console.WriteLine("[服務端]" + client.RecvStr);
                client.SendStr = Console.ReadLine();
                client.Send();
            }
        }
    }

//////////////////////////////////////////////////////////////////問題描述///////////////////////////////////////////////////////////////
1.服務器的功能：當一個用戶發起連接時就從連接池conns[]中取出一個可用的物件用于連接，當一個用戶發送訊息到服務端時，服務端將資訊轉發給所有其他的正在連接的用戶，測驗是本地環回測驗。
2.出現的問題：服務器總是不穩定，當發起連接時總是能正常連接，但是服務端常常沒有反應，比如或者很長一段時間（有時是幾分鐘）之后才有反應，回呼函式常常不執行，經過打樁發現處理接收的回呼函式沒有執行。
3.兩個重要的問題，（1）發起連接，處理accept的函式不執行。（2）發出訊息，服務器沒有轉發訊息，即接收訊息的回呼函式沒有執行
3.重要一點：即使服務器沒有沒有執行回呼，但還是能連接成功。
4.求助，第一次處理網路連接的問題，不知道怎么下手，回呼函式跟網路編程總是很難掌控。

uj5u.com熱心網友回復：

socket連接池這個概念有點不可思議。用池的主要目的是避免頻繁創建/銷毀造成的系統開銷，在你的應用里，有兩處涉及到創建和銷毀，一個是socket物件，一個是socket連接。socket物件可以重用，但是新創建的話并不會給系統帶來多大的負擔，而連接是沒有辦法重用的，避免不了重新創建。綜合來看，真的沒有什么必要使用這樣的設計（一般會產生影響的場景是極頻繁地發起請求，比如用syn泛洪來做ddos攻擊）。跟這個相對比，更合理的池的運用推薦了解一下資料庫連接池。
拋開上面的都不看，純用你的設計去看代碼：
一個conn，應該在連接的時候，才設定isUse=true;初始化的時候，因為連接還沒有建立，它的isUse設定為false才合理（順帶一提，NewIndex里， if (conns[i] == null) 的時候，你new了一個conn，應該回傳 i 而不是 1，當然你的代碼執行起來的時候，并不會走到這一步，因為只有連接被斷開了，socket本身還在，所以它并不會為null)。
關于發送的問題，你的代碼里用的是send，但它是阻塞的，所以你的代碼里應該使用異步的beginsend或者sendasync。可能群發無回應就是卡在這里。快速除錯的時候，可以不寫發送回呼，直接無腦異步發出去，先看看客戶端那邊的反應如何。

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/116917.html

標籤：網絡通信

上一篇：cisco 3660 的NAT配置問題,求助

下一篇：bind9域名服務器的轉發機制