AJAX在C#中处理WebSocket消息

发布时间：2024-09-09 16:23:58 作者：小樊
来源：亿速云阅读：80

在C#中，您可以使用ASP.NET Core的WebSocket API来处理WebSocket消息

首先，确保已安装ASP.NET Core。如果尚未安装，请访问 https://dotnet.microsoft.com/download 并按照说明进行操作。
创建一个新的ASP.NET Core Web应用程序项目。在命令提示符或终端中，运行以下命令：

dotnet new webapp -o WebSocketExample
cd WebSocketExample

打开Startup.cs文件，然后在Configure方法中添加以下代码以启用WebSocket中间件：

app.UseWebSockets();

在Startup.cs文件中，导入以下命名空间：

using System.Net.WebSockets;
using System.Threading.Tasks;

创建一个新的控制器类（例如WebSocketController.cs），并添加以下代码：

using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;

[Route("api/websocket")]
public class WebSocketController : ControllerBase
{
    [HttpGet]
    public async Task Get()
    {
        if (HttpContext.WebSockets.IsWebSocketRequest)
        {
            using var webSocket = await HttpContext.WebSockets.AcceptWebSocketAsync();
            await ProcessWebSocket(webSocket);
        }
        else
        {
            HttpContext.Response.StatusCode = 400;
        }
    }

    private async Task ProcessWebSocket(WebSocket webSocket)
    {
        var buffer = new byte[1024 * 4];
        var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);

        while (!result.CloseStatus.HasValue)
        {
            // Process the received message
            var message = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
            Console.WriteLine($"Received message: {message}");

            // Send a response to the client
            var response = "Message received";
            var responseBytes = System.Text.Encoding.UTF8.GetBytes(response);
            await webSocket.SendAsync(new ArraySegment<byte>(responseBytes), WebSocketMessageType.Text, true, CancellationToken.None);

            // Wait for the next message
            result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
        }

        await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
    }
}

现在，您可以运行Web应用程序并通过WebSocket连接到/api/websocket端点。您可以使用JavaScript的WebSocket对象来实现客户端连接。以下是一个简单的HTML和JavaScript示例：

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
   <title>WebSocket Example</title>
</head>
<body>
   <script>
        const socket = new WebSocket('ws://localhost:5000/api/websocket');

        socket.onopen = (event) => {
            console.log('WebSocket connection opened:', event);
            socket.send('Hello, server!');
        };

        socket.onmessage = (event) => {
            console.log('Received message from server:', event.data);
        };

        socket.onclose = (event) => {
            console.log('WebSocket connection closed:', event);
        };

        socket.onerror = (event) => {
            console.error('WebSocket error:', event);
        };
    </script>
</body>
</html>

将此HTML代码保存为index.html文件，并在浏览器中打开它。查看浏览器的开发者工具中的控制台，您应该会看到与服务器的WebSocket连接以及发送和接收的消息。

这就是如何在C#中使用ASP.NET Core处理WebSocket消息。您可以根据需要修改ProcessWebSocket方法以处理不同类型的消息和响应。

AJAX在C#中处理WebSocket消息

相关阅读