问 应该调用多少次C# .BeginReceive()才能接收三个块--通过TCP对Linux C写()的3个调用？

        char msgBuffer[64];
        sprintf(msgBuffer, START_MSG_ENVELOPE, msgId++, ack);
        write(connection->fd, msgBuffer, strlen(msgBuffer));
        write(connection->fd, msg, strlen(msg));
        write(connection->fd, END_MSG_ENVELOPE, strlen(END_MSG_ENVELOPE));

        private static void makeConnection(Socket clientSocket, int iPortNo)
        TimeoutObject.Reset();
        socketexception = null;
        IPAddress ip;
        //create the end point 
        IPEndPoint ipEndPoint;
        ip = IPAddress.Parse(ipAddress);
            ipEndPoint = new IPEndPoint(ip, iPortNo);
            //connect to the remote host...
            clientSocket.BeginConnect(ip, iPortNo, new AsyncCallback(CallBackMethod), clientSocket);
            if (TimeoutObject.WaitOne(5 * 1000, false))    //5 secs connection timeout
                if (!IsConnectionSuccessful)
                    string msg = VNResourceManager.Instance.GetString(VNMessages.DAM_NOT_FOUND);
                    if (socketexception != null)
                        msg += ": " + socketexception.Message;
                    throw new Exception(msg);
                clientSocket.Close();
                throw new TimeoutException(VNResourceManager.Instance.GetString(VNMessages.CONNECTION_TO_DAM_TIMED_OUT));
            //watch for data ( asynchronously )...
            WaitForData();
        catch (SocketException e)
            socketexception = e;
            throw;
    private static void CallBackMethod(IAsyncResult asyncresult)
            IsConnectionSuccessful = false;
            Socket socket = asyncresult.AsyncState as Socket;
            if (socket.Connected)
                socket.EndConnect(asyncresult);
                IsConnectionSuccessful = true;
        catch (Exception ex)
            IsConnectionSuccessful = false;
            socketexception = ex;
        finally
            TimeoutObject.Set();
    public static void WaitForData()
            if (asyncCallBack == null)
                asyncCallBack = new AsyncCallback(OnDataReceived);
            CSocketPacket theSocPkt = new CSocketPacket();
            theSocPkt.thisSocket = clientSocket;
            asyncResult = clientSocket.BeginReceive(theSocPkt.dataBuffer, 0, theSocPkt.dataBuffer.Length, SocketFlags.None, asyncCallBack, theSocPkt);
        catch (SocketException se)
            notifyErrorEventSubscribers(se);
    public static void send(string message)
            byte[] byData = System.Text.Encoding.ASCII.GetBytes(message);
            clientSocket.Send(byData);
        catch (SocketException se)
            notifyErrorEventSubscribers(se);
            throw;
    //[MethodImpl(MethodImplOptions.Synchronized)]
    public static void OnDataReceived(IAsyncResult result)
            CSocketPacket theSockId = (CSocketPacket)result.AsyncState;
            //end receive...
            int messageSize = 0;
            messageSize = theSockId.thisSocket.EndReceive(result);
            Console.WriteLine(">>>>>>>>>  messageSize = " + messageSize); // !!!
            char[] chars = new char[messageSize + 1];
            System.Text.Decoder d = System.Text.Encoding.ASCII.GetDecoder();
            int charLen = d.GetChars(theSockId.dataBuffer, 0, messageSize, chars, 0);
            string replyMessage = new System.String(chars);
            lock (syncLock)  //LastIndexOf function accesses the current culture info and we clear it in WM_TIMECHANGE handler (protecting from that race condition here)
                if (replyMessage.LastIndexOf("\0") > 0)
                    replyMessage = replyMessage.Remove(replyMessage.LastIndexOf("\0"), 1);
                if (replyMessage.LastIndexOf(Terminator) > 0)
                    replyMessage = replyMessage.Remove(replyMessage.LastIndexOf(Terminator), 1);
            // Continue the waiting for data on the Socket
            WaitForData();
            receivedMsg += replyMessage;
            // only serialize when we feel we have a message or we have reached the message line limit  
            if (((receivedMsg.Contains("message") && receivedMsg.Contains("/>")) || receivedMsg.Contains("</message>")) /* || (mRecvdMsgLineCount == Message.kMaxLines) */ )
                List<XmlMessage> msgList = new List<XmlMessage>();
                int index = -1;
                    index = receivedMsg.IndexOf("</message>");
                    if (index != -1)
                        XmlMessage message;
                        string strMessage = receivedMsg.Substring(0, index + "</message>".Length);
                        //MessageBox.Show(strMessage);
                        strMessage = strMessage.TrimStart(new char[] { '\r', '\n' });
                        receivedMsg = receivedMsg.Remove(0, index + "</message>".Length);
                            message = (XmlMessage)XmlMessage.GetXmlSerializer().Deserialize(XmlReader.Create(new StringReader(strMessage)));
                        catch (InvalidOperationException error)
                            string strErrorMessage = error.Message;
                            if (error.InnerException != null)
                                strErrorMessage += "\r\n" + error.InnerException.Message;
                            notifyErrorEventSubscribers(new Exception(strErrorMessage + "\r\n-----------------------------------------------------------------\r\n" + strMessage));
                            return;
                        msgList.Add(message);
                } while (index != -1);
                StringWriter sw = new StringWriter();
                string serializedXml = string.Empty;
                string strXmlMessage = string.Empty;
                foreach (XmlMessage message in msgList)
                    if (message.ack_required && (message.update == null))
                        XmlMessage messageAcknowledge = new XmlMessage();
                        messageAcknowledge.ack_required = false;
                        messageAcknowledge.ack = new ack();
                        messageAcknowledge.ack.success = true;
                        messageAcknowledge.ack.id = message.id;
                            sendMessage(messageAcknowledge);
                        catch(Exception ex)
                            Logger.Log(EnumLoggingLevel.Error, "SocketCommunicationXMl.OnDataReceived", ex.Message);
                    if (dataReceivedEvent != null)
                        dataReceivedEvent(new object(), new DataReceivedEventArgs(message));
                    if ((ackRequiredMsg != null) && (message.ack != null))
                         if ((message.ack.id == ackRequiredMsg.id) && message.ack.success)
                             eventWaitForAck.Set();
        catch (ObjectDisposedException objectDisposedException)
            //              Dispatcher.dispatchDebug(Debug.Level_3,"Socket has been closed", this);
            notifyErrorEventSubscribers(objectDisposedException);
        catch (SocketException se)
            if (se.ErrorCode == 10054)
                for (int i = 0; i < 50; i++)
                    Thread.Sleep(1000);
                    SocketCommunicationDaq.Reconnect();
                catch(Exception ex)
                    VNMsgBox.Show(ex.Message, MsgButtonType.OkOnly, MsgIconType.Error);
                    return;
                clientSocket.Shutdown(SocketShutdown.Both);
                clientSocket.Close();
                for (int i = 0; i < 3; i++)
                        connect();
                        break;
                    catch (Exception ex)
                        System.Threading.Thread.Sleep(5000);
                Logger.Log(EnumLoggingLevel.Error, "OnDataReceived: ", se.ToString());
                notifyErrorEventSubscribers(se);
    }