net-core-使用-websocket-主动推送信息

要使用 WebSocket 在 .NET Core 中进行主动推送信息，您需要遵循以下步骤：

安装 Microsoft.AspNetCore.WebSockets 包。
在 Startup.cs 文件的 ConfigureServices 方法中添加以下代码：

services.AddWebSocketManager();

在 Startup.cs 文件的 Configure 方法中添加以下代码：

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

创建一个 WebSocketHandler 类并实现 IWebSocketHandler 接口。在这个类中，您可以编写处理 WebSocket 连接和消息的代码。以下是一个基本示例：

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

    public override async Task OnConnectedAsync(WebSocket socket)
    {
        await base.OnConnectedAsync(socket);

        // 推送消息到新连接的客户端
        await SendMessageAsync(socket, "欢迎加入聊天室！");
    }

    public override async Task ReceiveAsync(WebSocket socket, WebSocketReceiveResult result, byte[] buffer)
    {
        var message = Encoding.UTF8.GetString(buffer, 0, result.Count);

        // 处理接收到的消息
        await SendMessageToAllAsync($"{socket} 说: {message}");
    }
}

在您的控制器中，您可以使用以下代码向 WebSocket 客户端推送消息：

var webSocketHandler = serviceProvider.GetService<MyWebSocketHandler>();
await webSocketHandler.SendMessageToAllAsync("有新消息！");

以上就是在 .NET Core 中使用 WebSocket 进行主动推送信息的基本步骤。您可以根据自己的需求进行修改和扩展。