在Asp.net core中实现websocket通信

在ASP.NET Core中实现WebSocket通信，可以采用ASP.NET Core中自带的WebSocket API或者使用第三方库SignalR进行实现。以下是基于ASP.NET Core原生WebSocket API实现的步骤：

使用WebSocket API实现WebSocket通信

第一步：创建一个ASP.NET Core Web应用程序

在Visual Studio中创建一个ASP.NET Core Web应用程序，可以选择“Web应用程序（.NET Core）”模板。

第二步：在Startup.cs文件中配置WebSocket中间件

在Configure方法中，添加WebSocket中间件的配置：

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    app.UseWebSockets();

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

    //其他配置
    //...
}

这段代码实现了对WebSocket请求的路由处理，当请求路径为/ws时，通过context.WebSockets.IsWebSocketRequest判断是否为WebSocket请求，若是，则调用AcceptWebSocketAsync()方法接受WebSocket连接，并使用HandleWebSocketRequestAsync()方法处理WebSocket消息；若不是，则返回400状态码。

第三步：处理WebSocket请求

在HandleWebSocketRequestAsync方法中，通过InputStream和OutputStream接受和发送消息，示例代码如下：

private async Task HandleWebSocketRequestAsync(WebSocket webSocket)
{
    byte[] buffer = new byte[1024 * 4];

    while (webSocket.State == WebSocketState.Open)
    {
        WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
        if (result.MessageType == WebSocketMessageType.Text)
        {
            string text = Encoding.UTF8.GetString(buffer, 0, result.Count);
            Console.WriteLine("接收到消息：" + text);

            byte[] messageBytes = Encoding.UTF8.GetBytes("收到消息：" + text);
            await webSocket.SendAsync(new ArraySegment<byte>(messageBytes), WebSocketMessageType.Text, true, CancellationToken.None);
        }
        else if (result.MessageType == WebSocketMessageType.Close)
        {
            await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
        }
    }
}

在这段代码中，通过WebSocket.ReceiveAsync()方法接受客户端发送的WebSocket消息；如果是文本类型，则将消息转为字符串，并在控制台上显示，并通过WebSocket.SendAsync()方法将消息返回给客户端。

第四步：实现客户端WebSocket代码

客户端代码可以采用JavaScript来实现，示例代码如下：

var webSocket = new WebSocket("ws://localhost:5000/ws");

//连接成功后执行的代码
webSocket.onopen = function (event) {
    console.log("WebSocket连接成功");
    webSocket.send("测试WebSocket连接");
};

//收到消息后执行的代码
webSocket.onmessage = function (event) {
    console.log("收到消息：" + event.data);
};

//发生错误后执行的代码
webSocket.onerror = function (event) {
    console.log("WebSocket错误");
};

//连接关闭后执行的代码
webSocket.onclose = function (event) {
    console.log("WebSocket连接关闭");
};

在这段代码中，通过创建WebSocket对象，并使用WebSocket的onopen、onmessage、onerror和onclose事件进行处理。

使用SignalR实现WebSocket通信

除了使用原生的WebSocket API之外，还可以使用第三方库SignalR来实现WebSocket通信，SignalR可以更加方便地实现实时Web应用程序。以下是基于SignalR实现的步骤：

第一步：安装SignalR

在Visual Studio中选择NuGet包管理器，搜索“Microsoft.AspNetCore.SignalR”并安装。

第二步：创建一个ASP.NET Core Web应用程序

同样，在Visual Studio中创建一个ASP.NET Core Web应用程序，选择“Web应用程序（.NET Core）”模板。

第三步：添加SignalR服务

在Startup.cs文件中添加SignalR服务：

public void ConfigureServices(IServiceCollection services)
{
    services.AddSignalR();

    //其他服务配置
    //...
}

第四步：创建SignalR Hub类

创建一个SignalR Hub类，用于处理客户端与服务器之间的通信，示例代码如下：

public class ChatHub : Hub
{
    public async Task SendMessage(string message)
    {
        Console.WriteLine("接收到消息：" + message);
        await Clients.All.SendAsync("ReceiveMessage", "收到消息：" + message);
    }
}

在这段代码中，SendMessage方法是客户端调用的方法，当接收到客户端发送的消息时，将消息显示在控制台上，并通过Clients.All.SendAsync()方法将消息广播给所有连接的客户端。

第五步：配置SignalR端点

在Configure方法中添加SignalR端点的配置：

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    app.UseRouting();

    app.UseEndpoints(endpoints =>
    {
        endpoints.MapHub<ChatHub>("/chathub");
    });

    //其他配置
    //...
}

在这段配置代码中，UseEndpoints()方法用于将请求路由到SignalR的处理器。当客户端连接到/chathub时，会自动调用ChatHub类中的方法。

第六步：实现客户端代码

客户端代码同样可以使用JavaScript实现，示例代码如下：

var connection = new signalR.HubConnectionBuilder().withUrl("/chathub").build();

//连接成功后执行的代码
connection.start().then(function () {
    console.log("SignalR连接成功");
    connection.invoke("SendMessage", "测试SignalR连接");
});

//收到消息后执行的代码
connection.on("ReceiveMessage", function (data) {
    console.log("收到消息：" + data);
});

//发生错误后执行的代码
connection.on("error", function (data) {
    console.log("SignalR错误");
});

//连接关闭后执行的代码
connection.on("close", function (data) {
    console.log("SignalR连接关闭");
});

在这段代码中，通过创建HubConnection对象，并使用start、invoke和on方法对连接、发送和接收消息进行处理。

以上就是ASP.NET Core中实现WebSocket通信的两种方法，可以根据需求选择使用。