C # Асинхронный сетевой ввод-вывод и OutOfMemoryException - PullRequest
Новая
       17

C # Асинхронный сетевой ввод-вывод и OutOfMemoryException

3 голосов
/ 25 апреля 2010

Я работаю над клиент-серверным приложением в C #, и мне нужно, чтобы асинхронные сокеты работали так, чтобы я мог обрабатывать несколько соединений одновременно. Технически это работает так, как сейчас, но я получаю OutOfMemoryException примерно через 3 минуты работы. MSDN говорит использовать WaitHandler для WaitOne() после socket.BeginAccept(), но на самом деле это не позволяет мне сделать это. Когда я пытаюсь сделать это в коде, он говорит, что WaitHandler - это абстрактный класс или интерфейс, и я не могу создать его экземпляр. Я подумал, может быть, я попробую статическую ссылку, но у нее нет метода WaitOne(), просто WaitAll() и WaitAny(). Основная проблема заключается в том, что в документах он не дает полного фрагмента кода, поэтому вы не можете увидеть, откуда происходит их «обработчик ожидания». это просто переменная с именем allDone, которая также содержит метод Reset() во фрагменте, которого нет у обработчика ожидания.

Покопавшись в их документах, я нашел кое-что связанное с AutoResetEvent в пространстве имен Threading. Он имеет WaitOne() и Reset() метод. Так что я попробовал это вокруг while(true) { ... socket.BeginAccept( ... ); ... }. К сожалению, это заставляет принимать только одно соединение за раз. Так что я не совсем уверен, куда идти. Вот мой код: 

 class ServerRunner
    {
        private Byte[] data = new Byte[2048];
        private int size = 2048;
        private Socket server;
        static AutoResetEvent allDone = new AutoResetEvent(false);

        public ServerRunner()
        {
            server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint iep = new IPEndPoint(IPAddress.Any, 33333);
            server.Bind(iep);
            Console.WriteLine("Server initialized..");
        }

        public void Run()
        {

            server.Listen(100);
            Console.WriteLine("Listening...");
            while (true)
            {
                //allDone.Reset();
                server.BeginAccept(new AsyncCallback(AcceptCon), server);
                //allDone.WaitOne();
            }
        }

        void AcceptCon(IAsyncResult iar)
        {
            Socket oldserver = (Socket)iar.AsyncState;
            Socket client = oldserver.EndAccept(iar);
            Console.WriteLine(client.RemoteEndPoint.ToString() + " connected");
            byte[] message = Encoding.ASCII.GetBytes("Welcome");
            client.BeginSend(message, 0, message.Length, SocketFlags.None, new AsyncCallback(SendData), client);
        }

        void SendData(IAsyncResult iar)
        {
            Socket client = (Socket)iar.AsyncState;
            int sent = client.EndSend(iar);
            client.BeginReceive(data, 0, size, SocketFlags.None, new AsyncCallback(ReceiveData), client);
        }

        void ReceiveData(IAsyncResult iar)
        {
            Socket client = (Socket)iar.AsyncState;
            int recv = client.EndReceive(iar);
            if (recv == 0)
            {
                client.Close();
                server.BeginAccept(new AsyncCallback(AcceptCon), server);
                return;
            }
            string receivedData = Encoding.ASCII.GetString(data, 0, recv);
            //process received data here
            byte[] message2 = Encoding.ASCII.GetBytes("reply");
            client.BeginSend(message2, 0, message2.Length, SocketFlags.None, new AsyncCallback(SendData), client);
        }
    }

1 Ответ

...