使用.NET实现消息管理中心

数据共享平台

using System;

using System.Collections.Generic;

using System.Net.WebSockets;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

public class MessageCenterServer

{

private static readonly List _clients = new List();

public async Task StartAsync()

{

var listener = new HttpListener();

listener.Prefixes.Add("http://localhost:8080/");

listener.Start();

Console.WriteLine("Listening for connections on http://localhost:8080/");

while (true)

{

var context = await listener.GetContextAsync();

if (context.Request.HttpMethod == "GET" && context.Request.RawUrl == "/ws")

{

var ws = await context.AcceptWebSocketAsync(null);

_clients.Add(ws);

await HandleClientAsync(ws);

}

}

}

private async Task HandleClientAsync(WebSocket ws)

{

var buffer = new byte[1024 * 4];

WebSocketReceiveResult result;

do

{

result = await ws.ReceiveAsync(new ArraySegment(buffer), CancellationToken.None);

if (result.MessageType == WebSocketMessageType.Close)

{

_clients.Remove(ws);

break;

}

string message = Encoding.UTF8.GetString(buffer, 0, result.Count);

Console.WriteLine($"Received: {message}");

// Broadcast the message to all connected clients

foreach (var client in _clients)

{

await client.SendAsync(new ArraySegment(Encoding.UTF8.GetBytes(message)), WebSocketMessageType.Text, true, CancellationToken.None);

}

} while (!result.CloseStatus.HasValue);

}

}

]]>