c# 开发 webrtc websocket信令服务器 例子

以下是一个使用 C# 和 WebSocket 开发 WebRTC 信令服务器的示例代码：

using System;
using System.Collections.Concurrent;
using System.Net;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace WebRTCSignalingServer
{
    class Program
    {
        private static ConcurrentDictionary<string, WebSocket> _clients = new ConcurrentDictionary<string, WebSocket>();

        static async Task Main(string[] args)
        {
            var listener = new HttpListener();
            listener.Prefixes.Add("http://localhost:8080/"); // 设置监听的URL

            try
            {
                listener.Start();
                Console.WriteLine("Server started. Listening for incoming WebSocket connections...");

                while (true)
                {
                    var context = await listener.GetContextAsync();
                    if (context.Request.IsWebSocketRequest)
                    {
                        var webSocketContext = await context.AcceptWebSocketAsync(null);
                        var webSocket = webSocketContext.WebSocket;

                        var clientId = Guid.NewGuid().ToString(); // 为每个客户端生成唯一的ID
                        _clients.TryAdd(clientId, webSocket);

                        _ = HandleClientAsync(webSocket, clientId);
                    }
                    else
                    {
                        context.Response.StatusCode = 400; // Bad Request
                        context.Response.Close();
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("Server error: " + ex.Message);
            }
            finally
            {
                listener.Close();
            }
        }

        static async Task HandleClientAsync(WebSocket webSocket, string clientId)
        {
            var buffer = new byte[1024];

            try
            {
                while (webSocket.State == WebSocketState.Open)
                {
                    var receiveResult = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);

                    if (receiveResult.MessageType == WebSocketMessageType.Close)
                    {
                        await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
                        _clients.TryRemove(clientId, out _);
                    }
                    else
                    {
                        var message = Encoding.UTF8.GetString(buffer, 0, receiveResult.Count);

                        // 处理信令逻辑，例如解析信令类型和数据

                        // 示例：向其他客户端广播收到的消息
                        foreach (var pair in _clients)
                        {
                            var client = pair.Value;
                            if (client.State == WebSocketState.Open && pair.Key != clientId)
                            {
                                var responseBytes = Encoding.UTF8.GetBytes(message);
                                await client.SendAsync(new ArraySegment<byte>(responseBytes), WebSocketMessageType.Text, true, CancellationToken.None);
                            }
                        }
                    }
                }
            }
            catch (WebSocketException ex)
            {
                Console.WriteLine("WebSocket error: " + ex.Message);
            }
        }
    }
}

这个示例使用 `HttpListener` 监听指定的 URL（这里使用了 `http://localhost:8080/`），并在接收到 WebSocket 请求时使用 `AcceptWebSocketAsync` 方法来建立 WebSocket 连接。

在 `HandleClientAsync` 方法中，我们使用 `WebSocket` 的 `ReceiveAsync` 方法来接收客户端发送的消息，并处理相应的逻辑。你可以根据需要解析信令数据，执行对应的操作。在示例中，我们简单地将收到的消息广播给其他客户端。

请注意，这个示例只是一个简单的起点，实际开发中你可能需要根据你的需求进行更多的逻辑处理和错误处理。

希望这个示例对你有所帮助！如果你有任何其他问题，请随时提问。