.netcore websocket

.NET Core 提供了内置的 WebSocket 支持，可以通过使用 Microsoft.AspNetCore.WebSockets 包来实现 WebSocket 通信。

首先，需要在 Startup.cs 文件的 ConfigureServices 方法中添加 WebSocket 服务：

services.AddWebSocketManager();

然后，在 Configure 方法中添加 WebSocket 中间件：

app.UseWebSockets();
app.MapWebSocketManager("/ws", serviceProvider.GetService<MyWebSocketHandler>());

其中，MapWebSocketManager 方法用于将 WebSocket 请求路由到指定的处理程序，"/ws" 是 WebSocket 的路径，MyWebSocketHandler 是自定义的 WebSocket 处理程序。

接下来，需要创建 WebSocket 处理程序 MyWebSocketHandler。可以继承 WebSocketHandler 类并实现 OnConnected、OnDisconnected 和 ReceiveAsync 方法来处理 WebSocket 连接、断开和消息接收事件。

public class MyWebSocketHandler : WebSocketHandler
{
    public MyWebSocketHandler(WebSocketConnectionManager webSocketConnectionManager) : base(webSocketConnectionManager)
    {
    }

    public override Task OnConnected(WebSocket socket)
    {
        return base.OnConnected(socket);
    }

    public override Task OnDisconnected(WebSocket socket)
    {
        return base.OnDisconnected(socket);
    }

    public override Task ReceiveAsync(WebSocket socket, WebSocketReceiveResult result, byte[] buffer)
    {
        return base.ReceiveAsync(socket, result, buffer);
    }
}

最后，在 Controller 中可以使用 WebSocketConnectionManager 来管理 WebSocket 连接，向客户端发送消息等操作。

public class MyController : Controller
{
    private readonly WebSocketConnectionManager _webSocketConnectionManager;

    public MyController(WebSocketConnectionManager webSocketConnectionManager)
    {
        _webSocketConnectionManager = webSocketConnectionManager;
    }

    public async Task<IActionResult> SendMessage(string message)
    {
        await _webSocketConnectionManager.SendMessageToAllAsync(message);
        return Ok();
    }
}

上面的代码演示了如何向所有 WebSocket 连接发送消息。可以根据需要自定义更多的操作。