通过C#代码实现的WebSocket Bitfinex

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

class Program
{
    static async Task Main(string[] args)
    {
        using (ClientWebSocket socket = new ClientWebSocket())
        {
            // 连接到Bitfinex的WebSocket API
            await socket.ConnectAsync(new Uri("wss://api.bitfinex.com/ws/2"), CancellationToken.None);

            // 订阅相关频道
            string subscribeMessage = "{\"event\":\"subscribe\",\"channel\":\"trades\",\"symbol\":\"tBTCUSD\"}";
            await SendMessage(socket, subscribeMessage);

            // 接收数据
            while (socket.State == WebSocketState.Open)
            {
                string message = await ReceiveMessage(socket);
                Console.WriteLine(message);
            }
        }
    }

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

    static async Task<string> ReceiveMessage(ClientWebSocket socket)
    {
        byte[] buffer = new byte[1024];
        WebSocketReceiveResult result = await socket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
        return System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
    }
}