Socket.Receive方法接收不完整的问题？

sandy1231

[C#] 纯文本查看 复制代码

byte[] buffer = new byte[1024 * 1024 * 2];
                   //int receiveLength = newSocket.Receive(buffer);
                    //if (receiveLength>0)
                    //{
dosomething.....
}

发现用上面的代码，如果发送的数据过大，读取到的数据就会不完整。如果改为while循环接收，但是只要Receive方法没接收到数据就会阻塞了，无法跳出，请问怎么解决？贴下我下面的代码

[C#] 纯文本查看 复制代码

  int receiveLength=0;
                    byte[] buffer = new byte[1024];
                    while (true)
                    {
                        receiveLength = newSocket.Receive(buffer);
                        if (receiveLength < 1)
                        {
                            break;
                        } 
                    }

站长苏飞

用线程接受，就不会卡了

sandy1231

站长苏飞 发表于 2014-6-7 23:08
用线程接受，就不会卡了

这是开了一个线程来接收的，有数据发过来时Receive才会往下执行，没有的话就一直等待

sandy1231

站长苏飞 发表于 2014-6-7 23:08
用线程接受，就不会卡了

我贴一下具体代码吧

[C#] 纯文本查看 复制代码

 public void RecevieMsg(object socket)
        {
            Socket newSocket = socket as Socket;
            while (true)
            {
              byte[] buffer1 = new byte[1024 * 1024 * 2];
                try 
                {
//这个一次接收不完整，一次只接收1024，
                   //int receiveLength = newSocket.Receive(buffer);
                    //if (receiveLength>0)
                    //{
                    //    string str = Encoding.Default.GetString(buffer);
                    //    MemoryStream mStream = new MemoryStream();
                    //    BinaryFormatter bFormat = new BinaryFormatter();
                    //    mStream.Write(buffer, 0, buffer.Length);
                    //    mStream.Flush();
                    //    mStream.Position = 0;
                    //    AgreementInfo agm = new AgreementInfo();
                    //    agm = (AgreementInfo)bFormat.Deserialize(mStream);
                    //    this.ReceiveEvent(agm);
                    //}
                    int receiveLength=0;
                    byte[] buffer = new byte[1024];
                    while (true)
                    {
//循环几次后就会被Receive阻塞
                        receiveLength = newSocket.Receive(buffer);
                        if (receiveLength < 1)
                        {
                            break;
                        } 
                    }
                    MemoryStream mStream = new MemoryStream();
                    BinaryFormatter bFormat = new BinaryFormatter();
                    mStream.Write(buffer, 0, buffer.Length);
                    mStream.Flush();
                    mStream.Position = 0;
                    AgreementInfo agm = new AgreementInfo();
                    agm = (AgreementInfo)bFormat.Deserialize(mStream);
                    this.ReceiveEvent(agm);

                }
                catch (SocketException ex)
                {
                    SocketEx.Write(ex.Message);
                    break;
                }
                catch (ObjectDisposedException ex)
                {
                    SocketEx.Write(ex.Message);
                    break;
                }  
                catch (Exception ex)
                {
                    SocketEx.Write(ex.Message);
                    break;
                }
            }
        }

sandy1231

@站长苏飞 飞哥帮帮忙

站长苏飞

没见你开线程啊

sandy1231

站长苏飞 发表于 2014-6-8 10:15
没见你开线程啊

[C#] 纯文本查看 复制代码

    private Socket sck;
        private Socket newSocket;
        public void Begin(int port)
        {
            sck = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint endpoint = new IPEndPoint(IPAddress.Any,port);
            sck.Bind(endpoint);
            sck.Listen(10);
            Thread thread = new Thread(ConnectAccept);
            thread.IsBackground = true;
            thread.Start();
        } public void ConnectAccept()
        {
            while (true)
            {
                newSocket = sck.Accept();
                this.ConnectedEvent(newSocket.RemoteEndPoint.ToString());
                //socketDir.Add(newSoket.RemoteEndPoint.ToString(), newSoket);
                ParameterizedThreadStart par = new ParameterizedThreadStart(RecevieMsg);
                Thread thread = new Thread(par);
                thread.IsBackground = true;
                thread.Start(newSocket);
            }
        }

sandy1231

解决了，把发收的字节长度设大就可以了