C# websocket atmosphere客户端示例

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

namespace WebSocketClientExample
{
    class Program
    {
        static async Task Main(string[] args)
        {
            using (ClientWebSocket client = new ClientWebSocket())
            {
                Uri serverUri = new Uri("wss://example.com/ws"); // WebSocket服务器的地址

                await client.ConnectAsync(serverUri, CancellationToken.None);

                // 连接成功后，可以发送和接收消息
                await SendMessage(client, "Hello, server!");
                await ReceiveMessage(client);
            }
        }

        static async Task SendMessage(ClientWebSocket client, string message)
        {
            byte[] buffer = System.Text.Encoding.UTF8.GetBytes(message);
            await client.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None);
        }

        static async Task ReceiveMessage(ClientWebSocket client)
        {
            byte[] buffer = new byte[1024];
            while (client.State == WebSocketState.Open)
            {
                WebSocketReceiveResult result = await client.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
                string message = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
                Console.WriteLine("Received message: " + message);
            }
        }
    }
}