如何在asp.net core中使用websocket

我正在尝试开发一个游戏，其中我将记分板存储在存储在服务器上（当前在本地主机上）的文本文件中。我正在使用 http get 和 post 调用来与服务器通信并获取和发送我想要的数据。现在我想实现 websockets 以便将通知从服务器发送到 c# 客户端。该通知只会在控制台上向用户显示一条消息，例如在 mu 情况下，我想在每次将用户添加到记分板时、每次调用 UpdateScoreBoard 方法时向用户显示一条消息。根据我在网上找到的教程，我已经成功构建了以下代码，任何人都可以让我更清楚地了解如何为服务器构建 websocket 以及如何在客户端上初始化 websocket？谢谢

Startup.cs（服务器）

        public void Configure(IApplicationBuilder app, IHostEnvironment env)
        {
          //deleted code

            var webSocketOptions = new WebSocketOptions()
            {
                KeepAliveInterval = TimeSpan.FromSeconds(120),
                ReceiveBufferSize = 4 * 1024
            };


            app.UseWebSockets(webSocketOptions);
        
            app.Use(async (context, next) =>
            {
                if (context.Request.Path == "/ws")
                {
                    if (context.WebSockets.IsWebSocketRequest)
                    {
                        WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
                        await Echo(context, webSocket);
                    }
                    else
                    {
                        context.Response.StatusCode = 400;
                    }
                }
                else
                {
                    await next();
                }

            });
        }

        private async Task Echo(HttpContext context, WebSocket webSocket)
        {
            var 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);
        }

HttpClass.cs（客户端）-我在其中调用 http post 请求

public async override Task<List<Scoreboard>> UpdateScoreBoards(string username, int attempts, int seconds, DateTime date)
            {
                HttpResponseMessage response = null;
                //Creating a new instance of object Scoreboard
                //deleted code

                var url = "http://localhost:5000/api/Scoreboard";

                var socket_url = new Uri("ws://localhost:5000"); 
                var exitEvent = new ManualResetEvent(false);
                using (var client = new WebsocketClient(socket_url))
                {
                    client.ReconnectTimeout = TimeSpan.FromSeconds(30);
                    client.ReconnectionHappened.Subscribe(info =>
                        Log.Information($"Reconnection happened, type: {info.Type}"));

                    client.MessageReceived.Subscribe(msg => Log.Information($"Message received: {msg}"));
                    await client.Start();

                    await Task.Run(() => client.Send("test"));

                    exitEvent.WaitOne();
                }

// deleted code
            }

谁能更清楚地告诉我如何为服务器构建 websocket 以及如何在客户端上初始化 websocket？

正如您引用的示例所示，利用 ASP.NET Core 中的 WebSocket，我们可以添加WebSockets 中间件 https://learn.microsoft.com/ru-ru/dotnet/api/microsoft.aspnetcore.builder.websocketmiddlewareextensions.usewebsockets?view=aspnetcore-3.1#Microsoft_AspNetCore_Builder_WebSocketMiddlewareExtensions_UseWebSockets_Microsoft_AspNetCore_Builder_IApplicationBuilder_ in the Configure方法，然后添加/配置请求委托来检查和处理传入的 WebSocket 请求。

将请求转换为 WebSocket 连接后AcceptWebSocketAsync()方法中，我们可以使用返回的WebSocket对象来发送和接收消息。

In Echo方法中，我们还可以执行自定义代码逻辑来根据收到的消息生成和发送回复消息/通知。

//received message
var mes = Encoding.UTF8.GetString(buffer, 0, result.Count);

//code logic here
//...

//create reply message
var reply_mes = $"You sent {mes}.";

byte[] reply_mes_buffer = Encoding.UTF8.GetBytes(reply_mes);

await webSocket.SendAsync(new ArraySegment<byte>(reply_mes_buffer, 0, reply_mes.Length), result.MessageType, result.EndOfMessage, CancellationToken.None);

此外，ASP.NET Core SignalR 是一个开源库，可以简化实时通信功能的实现。它确实支持 WebSockets 传输，我们可以轻松地向所有连接的客户端或连接的客户端的指定子集推送消息/通知。

有关 ASP.NET Core SignalR 的更多信息，您可以查看此文档：https://learn.microsoft.com/en-us/aspnet/core/fundamentals/websockets?view=aspnetcore-3.1 https://learn.microsoft.com/en-us/aspnet/core/fundamentals/websockets?view=aspnetcore-3.1