.NET8 webapi 使用 WebSocket 通信

1. 安装SignalR NuGet包

首先，需要安装SignalR库。在NuGet包中搜索Microsoft.AspNetCore.SignalR.Common并安装

2. 创建一个SignalR Hub

在您的ASP.NET Core应用程序中创建一个SignalR Hub类文件，用于处理WebSocket连接和消息传递。SignalR Hub是负责处理客户端连接和消息的中心枢纽。以下是一个简单的SignalR Hub示例：

using Microsoft.AspNetCore.SignalR;using System.Threading.Tasks;​public class ChatHub : Hub{    public async Task SendToAll(string message)    {        // 将收到的消息广播给所有连接的客户端        await Clients.All.SendAsync("ReceiveMessage", message);    }}

3. 配置Program.cs

// 添加Cors策略 允许所有源 builder.Services.AddCors(options =>{    options.AddPolicy("MyCorsPolicy", builder =>    {        builder.SetIsOriginAllowed(origin => true)               .AllowAnyHeader()               .AllowAnyMethod()               .AllowCredentials();    });});​// 添加SignalR服务builder.Services.AddSignalR();​app.UseCors("MyCorsPolicy"); // 使用MyCorsPolicy​// 添加SignalR端点app.UseEndpoints(endpoints =>{    _ = endpoints.MapHub("/ChatHub");});

4. 在控制器中触发SignalR消息

在您的消息控制器中，您可以通过注入IHubContext来触发SignalR消息，以便从控制器中将消息发送到所有连接的客户端。

namespace testMessage.Controllers{    [ApiController]    [Route("[controller]/[action]")]    public class MessageController : Controller    {​        private readonly DataContext _context;        private readonly IHubContext _hubContext;​        public MessageController(DataContext context, [FromServices] IHubContext hubContext)        {            _context = context;            _hubContext = hubContext;        }​        [HttpGet]        public async Task>> GetMessage()        {            var List = await _context.Message.ToListAsync();            return Ok(List);        }​        [HttpPost]         public async Task AddMessage(Message msg)        {                        if (ModelState.IsValid)            {                _context.Message.Add(msg);                 await _context.SaveChangesAsync();                // SignalR websocket 消息                await _hubContext.Clients.All.SendAsync("ReceiveMessage", msg);                // 返回成功消息                 return Content("添加成功！", "text/plain");            }            else            {                // 如果模型状态无效，返回错误消息                  return BadRequest("无效的请求数据。");            }        }    }}

5. 在前端建立WebSocket连接

最后，在前端代码中，您可以使用SignalR客户端库来建立WebSocket连接，并订阅来自服务端的消息。

以vue3项目为例 先通过npm安装 @microsoft/signalr

npm install @microsoft/signalr

import { HubConnectionBuilder } from '@microsoft/signalr';const connection = new HubConnectionBuilder()    .withUrl('https://localhost/ChatHub') // 你的接口地址/SignalR端点对应的地址    .build();​connection.start()    .then(() => {      console.log('SignalR Connected');    })    .catch(err => console.error(err));​connection.on('ReceiveMessage', message => {  console.log('Received message:', message); // 接受消息});

通过上述步骤，可以实现在ASP.NET Core中处理前端WebSocket请求，并使用SignalR来构建实时的消息传递系统。当客户端发送或接收消息时，SignalR将帮助您管理WebSocket连接和消息传递。

希望这些信息对您有所帮助，如果存在不正确的地方还请指出。