c# - TCP SOCKET : 非同期動作でストリームが 2 回送受信される

Question

現在、非同期 TCP プログラムに取り組んでいますが、次の問題があります。

• -サーバーが何らかのストリームを送信すると、クライアントは最初に空のバッファーを受信し、次にストリームを受信します。
• -最初のストリーム送信後、別のストリームを送信している場合、クライアントのバッファには最初に送信されたストリームと現在のストリームが含まれます。
• -別のストリームを送信している場合、バッファには以前に送信したストリームと現在のストリームが含まれます..など..

これは本当に面倒で、どこに問題があるのか​​ わかりません。ここに私のクライアントコードがあります:

Socket CLIENT;
byte[] _buffer;

private void button1_Click(object sender, EventArgs e)
{
    Start();
}
void Start()
{
    CLIENT = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    CLIENT.BeginConnect(IPAddress.Parse("the IPaddress"), 1234, new AsyncCallback(ConnectionCallBack), null);
}
private void ConnectionCallBack(IAsyncResult ar)
{
    try
    {
         CLIENT.EndConnect(ar);
         _buffer = new byte[CLIENT.ReceiveBufferSize];
         CLIENT.BeginReceive(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallBack), null);
    }
    catch (Exception Er)
    {
        MessageBox.Show("[[[[ERROR:1]]]]=>" + Er.Message);
    }

}
private void ReceiveCallBack(IAsyncResult ar)
{
    try
    {
        int lenght = CLIENT.EndReceive(ar);
        if (lenght == 0)  { return; }
        Array.Resize(ref _buffer, lenght);
        string stream = ASCIIEncoding.ASCII.GetString(_buffer);
        Array.Resize(ref _buffer, CLIENT.ReceiveBufferSize);

        CLIENT.BeginReceive(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallBack), null);

    }
    catch (Exception ex) { MessageBox.Show("[[[[hoERROR:2]]]]=>" + ex.Message); }
}

サーバーは次のとおりです。

private void button2_Click(object sender, EventArgs e)
        { 
            try
            {
                Socket socket = (Socket)listW.SelectedItems[0].Tag; //contains the socket
                socket.BeginSend(_buffer,0,_buffer.Length,SocketFlags.None,new AsyncCallback(SendingCallBack),socket);
                ServerSocket.BeginAccept(new AsyncCallback(AcceptCallBack),null);
            }
            catch (Exception er) { MessageBox.Show("[[[[ERROR:]]]]=>" + er.ToString()); }
        }
        private void SendingCallBack(IAsyncResult ar)
        {
            try
            {
                Socket socket = (Socket)ar.AsyncState;
                _buffer = ASCIIEncoding.ASCII.GetBytes(tx1.Text);
                socket.BeginSend(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(FinalCallBack),socket);
            }
            catch (Exception er) { MessageBox.Show("[[[[ERROR:3]]]]=>" + er.ToString()); }
        }
        private void Final(IAsyncResult ar)
        {
            Socket client = ar.AsyncState as Socket;
            client.EndSend(ar);
        }