我可以对 C# 中的基本异步套接字编程有一些建议吗？

Question

我正在开发（或者无论如何尝试）一个使用异步套接字的程序，据说可以随时在服务器和客户端之间传递字符串。

该程序要求不超过一个客户端连接到服务器。我尝试了套接字编程，但我发现它会阻塞程序，直到任何一方收到某些内容。

由于我对异步套接字编程只有基本的了解，因此我只是选择我能找到的最简单的一种，或者至少是我能理解的最简单的一种。

这是我的服务器代码：

    public Socket g_server_conn;
    public byte[] g_bmsg;
    public bool check = false;  

    private void net_As_Accept(IAsyncResult iar)
    {
        Socket server_conn = (Socket)iar.AsyncState;
        g_server_conn = server_conn.EndAccept(iar);
        g_bmsg = new byte[1024];
        check = true;
        g_server_conn.BeginReceive(g_bmsg, 0, g_bmsg.Length, SocketFlags.None, new AsyncCallback(net_As_Receive), g_server_conn);
    }

    private void net_As_Send(IAsyncResult iar)
    {
        Socket server_conn = (Socket)iar.AsyncState;
        server_conn.EndSend(iar);
    }

    private void net_As_Receive(IAsyncResult iar)
    {
        try
        {
            Socket server_conn = (Socket)iar.AsyncState;
            server_conn.EndReceive(iar);
            if (g_bmsg.Length != 0)
            {
                net_Data_Receive(Encoding.ASCII.GetString(g_bmsg, 0, g_bmsg.Length));
                check = false;
            }
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.ToString(), "GG");
        }
    }

    public void net_Data_Send(string msg2snd) // Function for sending through socket
    {
        MessageBox.Show(msg2snd);
        byte[] byData = System.Text.Encoding.ASCII.GetBytes(msg2snd);
        g_server_conn.BeginSend(byData, 0, byData.Length, SocketFlags.None, new AsyncCallback(net_As_Send), g_server_conn);
        g_server_conn.BeginReceive(g_bmsg, 0, g_bmsg.Length, SocketFlags.None, new AsyncCallback(net_As_Receive), g_server_conn);
    }

    private void net_Data_Receive(string txt)
    {
        if (lblBuffer.InvokeRequired)
            lblBuffer.Invoke(new MethodInvoker(delegate { net_Data_Receive(txt); }));
        else
            lblBuffer.Text = txt;

        if (txt.StartsWith("&"))
        {
            // Do something              
        }
    }

这是我的客户端代码：

    private void net_As_Connect(IAsyncResult iar)
    {
        try
        {
                Socket client_conn = (Socket)iar.AsyncState;
                client_conn.EndConnect(iar);
                g_bmsg = new byte[1024];
                check = true;
                string toSendData = "&" + net_Name;
                net_Data_Send(toSendData);
                g_client_conn.BeginReceive(g_bmsg, 0, g_bmsg.Length, SocketFlags.None, new AsyncCallback(net_As_Receive), g_client_conn);
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.ToString(), "GG");
        }
    }

    private void net_As_Send(IAsyncResult iar)
    {
        Socket client_conn = (Socket)iar.AsyncState;
        client_conn.EndSend(iar);
    }

    private void net_As_Receive(IAsyncResult iar)
    {
        if (g_bmsg.Length != 0)
        {
            net_Data_Receive(Encoding.ASCII.GetString(g_bmsg, 0, g_bmsg.Length));
            check = false;
        }
    }

    public void net_Data_Send(string msg2snd)
    {
        byte[] byData = System.Text.Encoding.ASCII.GetBytes(msg2snd);

        g_client_conn.BeginSend(byData, 0, byData.Length, SocketFlags.None, new AsyncCallback(net_As_Send), g_client_conn);
        g_client_conn.BeginReceive(g_bmsg, 0, g_bmsg.Length, SocketFlags.None, new AsyncCallback(net_As_Receive), g_client_conn);
    }

    private void net_Data_Receive(string txt)
    {
        if (lblBuffer.InvokeRequired)
            lblBuffer.Invoke(new MethodInvoker(delegate { net_Data_Receive(txt); }));
        else
            lblBuffer.Text = txt;

        if (txt.StartsWith("&"))
        {
            // Do Something              
        }
        else if (txt.StartsWith("$"))
        {
            // Do something Else
        }

    }

现在，客户端可以很好地连接到服务器。客户端甚至可以将包含用户名的字符串发送到服务器，然后该字符串将显示在服务器上。然后，服务器将其用户名发送给客户端，客户端接收并显示该用户名。发送的任何内容都存储在标签（lblBuffer）中

但是之后，假设我有以下代码：

    private void btnSendData_Click(object sender, EventArgs e)
    {
        string posMov = "Stuff to send";
        net_Data_Send(posMov);
    }

客户端什么也没有收到。将消息框放入 net_Data_Send(msg2snd) 函数中表明服务器实际上确实发送了消息。事实上，由于我不知道的原因，将消息框放入该函数中使其可以工作（客户端收到它）。由于我还没有尝试从客户端向服务器发送消息（除了客户端连接时的名称），我认为客户端在发送到服务器时也会遇到同样的问题。

此外，当它发送第二条消息时（通过将消息框放入 net_Data_Send 函数中），只有部分标签 (lblBuffer) 会被覆盖。因此，如果我的名字是“Anon E. Moose”，并且服务器在客户端连接时发送该信息，并且我尝试发送“0.0”（通过按下按钮），则客户端上的标签将读取“0.0” n E.驼鹿”。

我做错了什么？我可以帮忙吗？

也许我对 net_Data_Receive 和 net_Data_Send 有问题？

Answer 1

我认为您需要再次在客户端上调用 BeginReceive ，看起来您只调用它一次，因此在它收到服务器名称后，它也不再侦听来自服务器的任何数据

private void net_As_Receive(IAsyncResult iar)
{
    var bytesRead = g_client_conn.EndReceive(iar);


    if (bytesRead != 0)
    {
        net_Data_Receive(Encoding.ASCII.GetString(g_bmsg, 0, bytesRead));
        check = false;
    }

    g_client_conn.BeginReceive(g_bmsg, 0, g_bmsg.Length, SocketFlags.None, new AsyncCallback(net_As_Receive), g_client_conn);
}

，正如我在我的文章中提到的注释，使用 bytesRead 值来计算需要使用多少缓冲区。

您需要确定从套接字接收到的数据是否是全部，或者是否需要读取更多数据来弥补来自另一端的当前消息。

Answer 2

BeginReceive 不仅仅在新数据包（在您的情况下为字符串）到达时调用其回调。实际上。 BeginReceive 或任何原始套接字方法以基于流的方式工作，而不是基于数据包。请参阅http://msdn.microsoft.com/en-us/library/bew39x2a。 aspx 为例。

您需要做的是在“net_As_Receive”回调方法中（在我看来，命名很糟糕），您需要首先调用 socket.EndRecieve(IAsyncResult)，这又返回当前可用的总字节数。之后，您必须决定是否接收更多数据。

例如：

private StringBuilder packetBuilder;
{ 
    if (packetBuilder == null)
        packetBuilder = new StringBuilder();

    // finalyze the receive
    int length = g_server_conn.EndReceive(iar);

    if (length != 0) 
    { 
        // get the total bytes received. Note that the length property is of that of the number of bytes received rather than that of the buffer
        packetBuilder.Append(Encoding.ASCII.GetString(g_bmsg, 0, length));

        net_Data_Receive(packetBuilder.ToString()); 
        check = false; 
    } 

    // receive the next part
    g_server_conn.BeginReceive(g_bmsg, 0, g_bmsg.Length, SocketFlags.None, new AsyncCallback(net_As_Receive), g_server_conn);  
} 

请注意，此示例不关心包。如果你幸运的话它会起作用，但有一个很好的变化，要么显示字符串的一部分，要么组合 2 个不同的字符串。一个好的实现将查找字符串结尾并仅显示该部分，同时缓冲其余部分，直到找到新的字符串结尾。您还可以使用 StreamReader 让您的生活更轻松