Socket在异步接收数据时抛出nullreferenceexception

所以我有我的服务器 - 客户端协议,他们不能完美的,但是当客户端从服务器接收到数据时,它会抛出一个nullreference异常,这段代码处理接收到的数据:

private void AsyncReceive(IAsyncResult result)
    {
        int bytesTransferred;

        try
        {
            bytesTransferred = _handle.EndReceive(result); //throws the exception

            if (bytesTransferred <= 0)
                throw new Exception("no bytes transferred");
        }
        catch (NullReferenceException)
        {
            return;
        }
        catch (ObjectDisposedException)
        {
            return;
        }
        catch (Exception)
        {
            Disconnect();
            return;
        }

        byte[] received = new byte[bytesTransferred];

        try
        {
            Array.Copy(_readBuffer, received, received.Length);
        }
        catch (Exception ex)
        {
            OnClientFail(ex);
            return;
        }

        lock (_readBuffers)
        {
            _readBuffers.Enqueue(received);
        }

        lock (_readingPacketsLock)
        {
            if (!_readingPackets)
            {
                _readingPackets = true;
                ThreadPool.QueueUserWorkItem(AsyncReceive);
            }
        }

        try
        {
            _handle.BeginReceive(_readBuffer, 0, _readBuffer.Length, SocketFlags.None, AsyncReceive, null);
        }
        catch (ObjectDisposedException)
        {
        }
        catch (Exception ex)
        {
            OnClientFail(ex);
        }
    }

所以行bytesTransferred = _handle.EndReceive(result); 抛出异常。 我还应该注意到,我没有使用普通的套接字,我使用了ProxySocket(套接字类的extensioh),它可以在这里找到:ProxySocket,这里是客户端如何启动数据处理:`protected void Connect(string ip ,ushort端口){尝试{Disconnect();

            _handle = new ProxySocket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            _handle.SetKeepAliveEx(KEEP_ALIVE_INTERVAL, KEEP_ALIVE_TIME);
            _handle.ProxyType = ProxyTypes.Https;
            _handle.ProxyEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 54973);
            _handle.Connect(ip, port);

            if (_handle.Connected)
            {
                _handle.BeginReceive(_readBuffer, 0, _readBuffer.Length, SocketFlags.None, AsyncReceive, null);
                OnClientState(true);
            }
        }
        catch (Exception ex)
        {
            OnClientFail(ex);
        }
    }   `

如果我需要提供更多数据,可以在评论中问我。

谢谢

这是结果:

+       _handle {Org.Mentalis.Network.ProxySocket.ProxySocket}  Org.Mentalis.Network.ProxySocket.ProxySocket
    bytesTransferred    0   int
  • 结果{System.Net.Sockets.OverlappedAsyncResult} System.IAsyncResult {System.Net.Sockets.OverlappedAsyncResult}

  • AsyncCallback {Method = {Void AsyncReceive(System.IAsyncResult)}} System.AsyncCallback AsyncState null对象

  • AsyncWaitHandle {System.Threading.ManualResetEvent} System.Threading.WaitHandle {System.Threading.ManualResetEvent} CompletedSynchronously false bool IsCompleted true bool

  • 静态成员

  • 非公众成员

  • 这个{_4ng3l.Core.Networking.G0DClient} _4ng3l.Core.Networking.Client {_4ng3l.Core.Networking.G0DClient}

  • 链接地址: http://www.djcxy.com/p/75167.html

    上一篇: Socket throws nullreferenceexception while asynchrously receiving data

    下一篇: C# Null Conditional Operator alternative (conditional assignment)?