c# - 异步套接字客户端接收

Question

我正在处理 C# 中的套接字编程。我需要构建一个客户端应用程序，它与具有给定协议(protocol)的服务器通信。

我成功实现了异步发送方法，但在实现接收算法时遇到了麻烦。同步接收方法工作正常。

首先，我需要不断地读取传入的消息并确认它们。为了正确，每条收到的消息都必须有一个终止符(0x0c)

我用三个线程构建了一个名为 MessageFlow 的多线程类:一个负责发送消息，另一个负责接收消息，第三个负责解释接收到的消息并做一些事情。

接收线程的工作函数如下所示

private void ReadSocketWorker()
{
    while (this.canRun)
    {
    xComClient.Receive();
    xComClient.receiveDone.WaitOne();
    Thread.Sleep(10);
    }
}

XComClient 是我的类，具有套接字和发送和接收消息的所有方法。

public void Receive()
{
    try
    {
        StateObject state = new StateObject();
        state.workSocket = socketClient;
        socketClient.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
    }
    catch (Exception e)
    {
        throw e;
    }
}

private void ReceiveCallback(IAsyncResult ar)
        {
            try
            {
                StateObject state = (StateObject)ar.AsyncState;
                Socket client = state.workSocket;

                // Read data from the remote device.
                int iReadBytes = client.EndReceive(ar);

                if (iReadBytes > state.GetBufferSize())
                {
                    byte[] bytesReceived = new byte[iReadBytes];
                    Buffer.BlockCopy(state.buffer, 0, bytesReceived, 0, iReadBytes);
                    state.responseList.Enqueue(bytesReceived);
                    client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
                        new AsyncCallback(ReceiveCallback), state);
                }
                else
                {
                    byte[] bytesReceived = new byte[iReadBytes];
                    Buffer.BlockCopy(state.buffer, 0, bytesReceived, 0, iReadBytes);
                    state.responseList.Enqueue(bytesReceived);
                    BuildReceivedMessage(state);
                    receiveDone.Set();
                }
            }
            catch (Exception e)
            {
                throw e;
            }
        }

public class StateObject
{
    public Socket workSocket = null;
    public const int BufferSize = 20480;
    public byte[] buffer = new byte[BufferSize];

    public Queue<byte[]> responseList = new Queue<byte[]>();

    public int GetBufferSize()
    {
        return BufferSize;
    }
}

我究竟做错了什么？

Answer 1

在无事可做的线程中使用异步 I/O 确实没有任何意义。我会重新考虑这个设计决定。