要简化C# WebSocket服务器的代码,可以使用一些现成的库和框架,例如Microsoft.AspNetCore.Http.WebSocket
。以下是一个简单的示例,展示了如何使用ASP.NET Core创建一个基本的WebSocket服务器:
- 首先,确保已安装以下NuGet包:
Microsoft.AspNetCore.Http.Abstractions Microsoft.AspNetCore.Http.Core Microsoft.AspNetCore.WebSockets
- 创建一个名为
Startup.cs
的文件,并添加以下内容:
using Microsoft.AspNetCore.Builder; using Microsoft.AspNetCore.Hosting; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Hosting; using System.Threading.Tasks; namespace WebSocketServer { public class Startup { public void ConfigureServices(IServiceCollection services) { services.AddControllers(); services.AddEndpointsApiExplorer(); services.AddSwaggerGen(); } public void Configure(IApplicationBuilder app, IWebHostEnvironment env) { if (env.IsDevelopment()) { app.UseDeveloperExceptionPage(); app.UseSwagger(); app.UseSwaggerUI(); } app.UseRouting(); app.UseEndpoints(endpoints => { endpoints.MapControllers(); endpoints.MapWebSocket("/ws", async (client, context) => { await Echo(client, context); }); }); } private async Task Echo(WebSocketClient client, WebSocketContext context) { byte[] buffer = new byte[1024 * 4]; WebSocketReceiveResult result; do { result = await client.ReceiveAsync(new ArraySegment(buffer), CancellationToken.None); if (result.CloseStatus != null) { break; } await client.SendAsync(new ArraySegment (buffer, 0, result.Count), result.CloseStatus.Value, CancellationToken.None); } while (!result.CloseStatus.HasValue); await client.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None); } } }
这个示例中,我们创建了一个简单的WebSocket服务器,监听/ws
路径。当客户端连接到该路径时,服务器会将接收到的消息原样发送回客户端。
- 创建一个名为
Program.cs
的文件,并添加以下内容:
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Hosting;
namespace WebSocketServer
{
public class Program
{
public static void Main(string[] args)
{
CreateHostBuilder(args).Build().Run();
}
public static IHostBuilder CreateHostBuilder(string[] args) =>
Host.CreateDefaultBuilder(args)
.ConfigureWebHostDefaults(webBuilder =>
{
webBuilder.UseStartup();
});
}
}
- 运行
Program.cs
文件,启动WebSocket服务器。
现在,你已经创建了一个简单的C# WebSocket服务器。你可以根据需要扩展此示例,例如添加身份验证、消息处理等。