正文

从零开始：轻松掌握C# WebSocket服务器开发技巧

/0 浏览量
0626

引言

WebSocket是一种在单个TCP连接上进行全双工通信的协议，它允许服务器和客户端之间进行实时数据交换。在C#中，开发WebSocket服务器是一个既有趣又有挑战性的任务。本文将带你从零开始，轻松掌握C# WebSocket服务器的开发技巧。

准备工作

在开始之前，请确保你的开发环境中已经安装了.NET SDK。以下是开发WebSocket服务器所需的基本步骤：

  1. 创建一个新的.NET Core控制台应用程序项目。
  2. 添加必要的NuGet包，例如Microsoft.AspNetCore.WebSockets。

创建WebSocket服务器

1. 创建WebSocket类

首先，我们需要创建一个WebSocket类来处理WebSocket连接。

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

public class WebSocketServer
{
    private readonly WebSocket _webSocket;
    private readonly CancellationTokenSource _cancellationTokenSource;

    public WebSocketServer(WebSocket webSocket)
    {
        _webSocket = webSocket;
        _cancellationTokenSource = new CancellationTokenSource();
    }

    public async Task StartAsync(CancellationToken cancellationToken)
    {
        var buffer = new byte[1024 * 4];
        var result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), cancellationToken);

        if (result.MessageType == WebSocketMessageType.Text)
        {
            Console.WriteLine($"Received message: {Encoding.UTF8.GetString(buffer, 0, result.Count)}");
        }

        var response = Encoding.UTF8.GetBytes("Hello from server!");
        await _webSocket.SendAsync(new ArraySegment<byte>(response), WebSocketMessageType.Text, true, cancellationToken);
    }

    public async Task StopAsync(CancellationToken cancellationToken)
    {
        await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Server closed the connection.", cancellationToken);
        _cancellationTokenSource.Cancel();
    }
}

2. 启动WebSocket服务器

接下来，我们需要创建一个WebSocket服务器来监听客户端的连接。

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

public class Program
{
    public static async Task Main(string[] args)
    {
        var httpListener = new HttpListener();
        httpListener.Prefixes.Add("http://+:/");
        httpListener.Start();

        Console.WriteLine("WebSocket server started. Press Enter to exit.");

        while (true)
        {
            var context = await httpListener.GetContextAsync();
            if (context.Request.IsWebSocketRequest)
            {
                var webSocket = await context.AcceptWebSocketAsync();
                var server = new WebSocketServer(webSocket);
                await server.StartAsync(new CancellationToken());
            }
        }
    }
}

3. 运行WebSocket服务器

编译并运行上述代码，然后使用WebSocket客户端（例如浏览器或Postman）连接到服务器。你应该能够看到服务器发送的“Hello from server!”消息。

总结

通过以上步骤，你已经成功创建了一个简单的C# WebSocket服务器。当然，这只是WebSocket服务器开发的基础。在实际应用中，你可能需要处理更复杂的功能，例如消息加密、多用户支持等。希望本文能帮助你轻松掌握C# WebSocket服务器开发技巧。

-- 展开阅读全文 --