如何在 TcpListener 线程和主线程之间传输数据

本文关键字：线程 之间 传输 数据 TcpListener | 更新日期: 2023-09-27 18:37:03

我有一个基于 C# 的套接字通信线程。服务器中的缓冲区是 1024 字节，现在我需要一种方法在通信线程和主线程之间传输数据。 我该怎么做？ 我是否需要打开一个新的缓冲区，然后将数据复制到其中？或者我可以只从客户端或服务器的缓冲区获取数据吗？

private void ServerResponse()
    {
        byte[] buff = new byte[1024];
        string msg;
        int len;
        try
        {
            if (!Stream.CanRead)
            {
                return;
            }
            stopFlag = false;
            while (!stopFlag)
            {
              len = Stream.Read(buff, 0, buff.Length);
                if (len < 1                    
                  {
                    Thread.Sleep(200);
                    continue;
               }
            }
       }
 }

以上是服务器用于从客户端获取数据的函数。我的问题是我可以将此函数获取的数据发送到主线程，或者我应该在上述函数的定义之外设置一个新的缓冲区并将数据复制到其中。

如何在 TcpListener 线程和主线程之间传输数据

如果您的主线程是通常称为 UI 线程的内容，则此讨论将为您提供一些想法： 如何使用后台工作者更新 GUI

取决于数据需要如何传输到主线程。如果以字节为单位，则只需直接调用以下代码。如果没有，首先将数据转换为可呈现的形式，然后调用代码：

// Place this on the main thread's class initialization.
private static readonly SynchronizationContext _syncContext =
    SynchronizationContext.Current;
// Then your worked thread will be like this:
if (len < 1)                  
{
    Thread.Sleep(200);
    continue;
}
else
{
    _syncContext.Post(o => MainThreadClass.ReceiveData((byte[])buff), buff);
}

您需要将收到的消息写入主线程可访问的缓冲区。为此，您可以为每个收到的消息创建一个新的缓冲区（字节数组），并将该缓冲区添加到 ConcurrentQueue<>，这适用于多线程读取器/写入器方案。这样，侦听线程会将收到的消息写入队列，并且主线程可以以线程安全的方式从同一队列中读取消息。

根据您的用例，您可能能够构建一个更有意义的对象（例如请求对象）并将其传递给主线程，而不是传递字节。

编辑：基于评论

假设您在公共范围内定义了ConcurrentQueue<byte[]>：

public ConcurrentQueue<byte[]> ReceivedMsgs = new ConcurrentQueue<byte[]>();

您可以在侦听器线程中执行以下操作（在将消息字节读取到buff之后）：

var msg = new byte[len];
Buffer.BlockCopy(buff, 0, msg, 0, len);
this.ReceivedMsgs.Enqueue(msg);

然后在主线程中，您可以将消息取消排队：

byte[] msg;
if (server.ReceivedMsgs.TryDequeue(out msg))
{
    //use msg
}
相关文章：