.net websocket 服务端

.NET中的WebSocket服务端是使用ASP.NET Core提供的WebSocket API来实现的。WebSocket是一种在单个TCP连接上提供全双工通信信道的协议，允许服务器和客户端之间进行实时双向通信。在.NET环境中，你可以通过以下步骤创建一个WebSocket服务端：

1. 创建ASP.NET Core Web应用程序。
2. 在Startup.cs文件中的Configure方法中，使用app.UseWebSockets()来启用WebSocket支持。
3. 在应用的中间件管道中添加一个处理WebSocket请求的中间件，这个中间件会处理WebSocket握手请求，并在成功后建立WebSocket连接。
4. 在中间件中，使用context.WebSocketFeatures.AspNetCoreWebSocketFeature.WebSocket对象来与客户端进行通信，包括接收和发送消息。
5. 开启后台服务或使用SignalR等库来管理WebSocket连接和消息的传递。

以下是一个简单的WebSocket服务端的代码示例：

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    if (env.IsDevelopment())
    {
        app.UseDeveloperExceptionPage();
    }

    app.UseWebSockets(); // 启用WebSocket支持

    app.Use(async (context, next) =>
    {
        if (context.Request.Path == "/ws")
        {
            if (context.WebSockets.IsWebSocketRequest)
            {
                WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
                await Echo(context, webSocket); // Echo方法用于处理消息
            }
            else
            {
                context.Response.StatusCode = 400; // 如果请求不是WebSocket请求，则返回400状态码
            }
        }
        else
        {
            await next();
        }
    });

    app.Run(async (context) =>
    {
        await context.Response.WriteAsync("Hello World!");
    });
}

private async Task Echo(HttpContext context, WebSocket webSocket)
{
    byte[] buffer = new byte[1024 * 4];
    WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);

    while (!result.CloseStatus.HasValue)
    {
        // 服务器接收到消息后回发给客户端
        await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, CancellationToken.None);

        result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    }

    await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
}

在这个示例中，服务器接受WebSocket握手请求，并通过Echo方法来回声服务器接收到的消息，直到连接关闭。