当前位置：首页 > 行业动态 > 正文

C WebSocket服务器端实现细节与问题解析

admin
行业动态
2025-03-02
6

“

csharp，using System;，using System.Net.WebSockets;，using System.Threading.Tasks;class Program，{， static async Task Main(string[] args)， {， var server = new WebSocketServer();， await server.StartAsync();， }，}public class WebSocketServer，{， private const string Url = "ws://localhost:8080"; public async Task StartAsync()， {， using (var listener = new WebSocketListener(Url))， {， listener.ConnectionReceived += OnConnectionReceived;， await listener.StartAsync();， Console.WriteLine($"WebSocket server started at {Url}");， Console.ReadLine();， }， } private async void OnConnectionReceived(object sender, ConnectionReceivedEventArgs e)， {， using (var webSocket = e.Connection)， {， Console.WriteLine("Client connected"); var buffer = new byte[1024];， WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment(buffer), CancellationToken.None);， while (!result.CloseStatus.HasValue)， {， Console.WriteLine(Encoding.UTF8.GetString(buffer, 0, result.Count));， result = await webSocket.ReceiveAsync(new ArraySegment(buffer), CancellationToken.None);， } await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);， Console.WriteLine("Client disconnected");， }， }，}，

“

在C#中实现WebSocket服务器端，可以通过多种方式进行，以下是几种常见的方法及其详细步骤：

使用Fleck库实现WebSocket服务器端

1、安装Fleck库：

确保你的项目已经安装了Fleck库，你可以通过NuGet包管理器来安装它，在Visual Studio的“工具”菜单中选择“NuGet包管理器”，然后搜索“Fleck”并安装。

2、创建WebSocket服务器实例：

在你的项目中，创建一个类（例如Program.cs）并在其中编写代码以创建WebSocket服务器实例，以下是一个示例代码：

 using System;
     using Fleck;
     class Program
     {
         static void Main(string[] args)
         {
             var server = new WebSocketServer("ws://0.0.0.0:8181");
             server.Start(socket =>
             {
                 socket.OnOpen = () => Console.WriteLine("Open!");
                 socket.OnClose = () => Console.WriteLine("Close!");
                 socket.OnMessage = message => socket.Send(message);
             });
         }
     }

上述代码创建了一个新的WebSocket服务器实例，监听在所有网络接口的8181端口上，当有新的WebSocket连接时，会触发相应的事件处理程序。

C WebSocket服务器端实现细节与问题解析

3、运行服务器：

编译并运行你的项目，WebSocket服务器将开始监听指定的端口，等待客户端的连接。

使用ASP.NET Core实现WebSocket服务器端

1、创建ASP.NET Core Web应用程序：

打开Visual Studio，选择“创建新项目”，然后选择“ASP.NET Core Web应用程序”模板，为项目命名并选择合适的位置进行保存。

C WebSocket服务器端实现细节与问题解析

2、配置WebSocket服务：

在项目的Startup.cs文件中，配置WebSocket服务，在ConfigureServices方法中添加WebSocket服务到依赖注入容器中：

 public void ConfigureServices(IServiceCollection services)
     {
         services.AddWebSockets();
     }

在Configure方法中添加WebSocket中间件，并指定处理WebSocket请求的方法：

 public void Configure(IApplicationBuilder app, IHostingEnvironment env)
     {
         if (env.IsDevelopment())
         {
             app.UseDeveloperExceptionPage();
         }
         else
         {
             app.UseHsts();
         }
         app.UseWebSockets();
         app.Use(async (context, next) =>
         {
             if (context.WebSockets.IsWebSocketRequest)
             {
                 WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
                 await HandleWebSocketConnection(webSocket);
             }
             else
             {
                 await next();
             }
         });
     }

实现HandleWebSocketConnection方法来接收和发送WebSocket消息：

 private async Task HandleWebSocketConnection(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);
         }
         await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
     }

3、运行服务器：

C WebSocket服务器端实现细节与问题解析