多线程套接字服务器-接收数据

我有一个简单的TCP服务器，它使用异步套接字。我面临的挑战是：

我有以下TCP服务器类：

 public class tcp_server {
         const int max_clients = 300;
         const int max_buffer_size = 10;
         public AsyncCallback pfnWorkerCallBack;
         private Socket m_mainSocket;
         private Socket[] m_workerSocket = new Socket[max_clients];
         private int m_clientCount = 0;
          ... 
         public void OnClientConnect(IAsyncResult asyn) { }
         public void WaitForData(System.Net.Sockets.Socket soc, int socket_id) { }
         public void OnDataReceived(IAsyncResult asyn)
         public class SocketPacket
         {
            public System.Net.Sockets.Socket m_currentSocket;
            public byte[] dataBuffer = new byte[max_buffer_size];
            public int socket_id = -1;
         }
}

以下是OnDataRecived函数的完整代码：

    public void OnDataReceived(IAsyncResult asyn)
    {
        try
        {
            SocketPacket socketData = (SocketPacket)asyn.AsyncState; // cast
            int iRx = 0;
            iRx = socketData.m_currentSocket.EndReceive(asyn);
            char[] chars = new char[iRx + 1];
            System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder();
            int charLen = d.GetChars(socketData.dataBuffer, 0, iRx, chars, 0);
            WaitForData(socketData.m_currentSocket, socketData.socket_id);
        }
        catch (ObjectDisposedException)
        {
            log("OnDataReceived: Socket has been closed'n");
        }
        catch (SocketException se)
        {
            log(se.Message);
        }
    }

max_buffer_size设置为10。若我向服务器发送100个字节，onDataRecieve将执行10次。

我有3个问题：

1我需要"收集"所有100个字节，然后将其传递给另一个函数，该函数将检查接收到的数据中的命令。客户端在数据包末尾添加4字节的"数据包结束标识符"，因为数据大小并不总是事先已知的。我如何/在哪里定义这个临时缓冲区，以便onDataRecieve将其填满，如果找到end，则将数据传递给命令识别函数？

2客户端可能会从不同的线程（在同一连接上）向我发送大量数据。我需要一种方法，为收到的每个数据包提供多个临时缓冲区，这样我就可以等到它们填满，然后将先填满的缓冲区传递给命令识别功能，然后清除/移除缓冲区。

例如：

1. 客户端（线程/数据包#1）->服务器（数据不完整，线程由于某种原因挂起）
2. 客户端（线程/数据包#2）->服务器（完整数据，缓冲区传递给命令id funct）
3. 客户端（线程/数据包#1）->服务器（第一个数据包的其余数据到达，缓冲区传递给命令id func）

3我需要能够从外部（公共）访问这个缓冲区，这样我就可以在缓冲区填满时从另一个类开始使用它。

我希望这是有道理的。我怎样才能做到这一点？