C# websocketserver多线程处理

在C#中可以使用System.Net.WebSockets命名空间中的WebSocket类来创建WebSocket服务器。要实现多线程处理，可以使用Task类或Thread类来处理每个WebSocket连接。

以下是一个简单的示例代码，展示了如何使用Task类来处理WebSocket连接：

using System;using System.Net;using System.Net.WebSockets;using System.Threading.Tasks;class Program{    static async Task Main(string[] args)    {        HttpListener listener = new HttpListener();        listener.Prefixes.Add("http://localhost:8080/");        listener.Start();                Console.WriteLine("Listening for WebSocket connections...");        while (true)        {            HttpListenerContext context = await listener.GetContextAsync();            if (context.Request.IsWebSocketRequest)            {                ProcessWebSocketRequest(context);            }            else            {                context.Response.StatusCode = 400;                context.Response.Close();            }        }    }    static async void ProcessWebSocketRequest(HttpListenerContext context)    {        WebSocketContext webSocketContext = await context.AcceptWebSocketAsync(null);        WebSocket webSocket = webSocketContext.WebSocket;                Task.Run(async () =>        {            byte[] buffer = new byte[1024];            WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), System.Threading.CancellationToken.None);            while (!result.CloseStatus.HasValue)            {                //处理接收到的数据                //...                result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), System.Threading.CancellationToken.None);            }            await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, System.Threading.CancellationToken.None);        });    }}

在上面的示例中，使用Task.Run来创建一个新的任务来处理每个WebSocket连接。在任务中，首先接收来自客户端的数据，并在一个循环中持续接收数据直到连接关闭。处理接收到的数据的逻辑可以根据实际需求进行实现。

这样就可以实现多线程处理WebSocket连接，每个连接在一个独立的任务中进行处理，避免阻塞主线程。