Код для связи с биржей при помощи Websocket

@Steroid · Регистрация: 17.02.2016

Студворк — интернет-сервис помощи студентам

Привет

Пытаюсь написать код для связи с биржей при помощи Websocket

но почемуто выдает ошибку что хост неизвестен

System.Net.Sockets.SocketException (11001): Der angegebene Host ist unbekannt (заданный хост неизвестен)

причем даже если я задаю любой адресс wss:

через IPHostEntry тоже не определяется
постоянно одна и таже ошибка

помогите пожалуйста разобратся что не так

причем если задаю нормальный http: адресс то все определяется, но конечно нет соединения с вебсокетом биржи
для удобства задаю адресс и порт в окне WPF но это совершенно не важно в принципе

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
string testNet = "wss://stream-testnet.bybit.com/realtime";
        string mainNet1 = "wss://stream.bybit.com/realtime";
        string mainNetIP = "52.222.236.27";
        string mainNet2 = "wss://stream.bytick.com/realtime";
        string demoWebsocket = "wss://demo.piesocket.com/v3/channel_1?api_key=oCdCMcMPQpbvNjUIzqtvF1d2X2okWpDQj4AwARJuAgtjhzKxVEjQU6IdCjwm&notify_self";
        static int port = 443;
 
 
        public MainWindow()
        {
            InitializeComponent();
        }
        void VerbindungErstellen()
        {
            try
            {
                IPHostEntry entry = Dns.GetHostEntry(websocketAddressTxbox.Text); // ошибка тут выскакивает
                foreach (IPAddress address in entry.AddressList)
                {
                    textBox1.Text += "\n" + address.ToString() +  " Connected";
                }
                Debug.WriteLine("Connected");
            }
            catch (Exception e)
            {
 
                Debug.WriteLine(e);
            }
        }

пробовал также через

C#
1
TcpClient client = new TcpClient(testNet, port);

выдает такуюже ошибку

@QuakerRUS · 29.03.2022, 18:12

Steroid, а что именно содержится в websocketAddressTxbox.Text ?

@Steroid · 29.03.2022, 19:34 **[ТС]**

QuakerRUS, вот эти все пробовал

Кликните здесь для просмотра всего текста

C#
1
2
3
4
string testNet = "wss://stream-testnet.bybit.com/realtime";
        string mainNet1 = "wss://stream.bybit.com/realtime";
        string mainNet2 = "wss://stream.bytick.com/realtime";
        string demoWebsocket = "wss://demo.piesocket.com/v3/channel_1?api_key=oCdCMcMPQpbvNjUIzqtvF1d2X2okWpDQj4AwARJuAgtjhzKxVEjQU6IdCjwm&notify_self";

@QuakerRUS · 29.03.2022, 19:46

Сообщение от Steroid

вот эти все пробовал

https://docs.microsoft.com/ru-... ew=net-6.0
Этот метод запрашивает у DNS-сервера IP-адреса и псевдонимы, связанные с IP-адресом. Т.е. указывать в параметрах надо только сам адрес без указания протокола. Например:

C#
1
IPHostEntry entry = Dns.GetHostEntry("stream-testnet.bybit.com");

Сообщение от Steroid

пробовал также через

Тут у меня тоже ошибки нет:

C#
1
TcpClient client = new TcpClient("stream-testnet.bybit.com", 443);

@Steroid · 29.03.2022, 20:00 **[ТС]**

QuakerRUS,
да это работает
но это простой http адрес

я не совсем понимаю как мне "поздороватся" с сервером и получать данные в реальном времени

в документации от биржи нужно через вебсокет

ссылка на документацию

@QuakerRUS · 29.03.2022, 20:15

Сообщение от Steroid

в документации от биржи нужно через вебсокет

Тут почитайте.
https://docs.microsoft.com/ru-... etcore-3.1

@Steroid · 29.03.2022, 20:17 **[ТС]**

QuakerRUS,
благодарю за помошь

@IamRain · 29.03.2022, 22:44

Steroid, по ссылке это WebSocket на стороне сервера.
На стороне клиента нужно использовать ClientWebSocket.

Пример

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
internal class Program
    {
        private const int BUFFER_SIZE = 4096;
 
        static async Task Main(string[] args)
        {
            //trust it by now
            ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };
            ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls13;
 
            var urls = new[]
            {
                "wss://stream.bybit.com/realtime",
                "wss://stream-testnet.bybit.com/realtime",
                "wss://stream.bytick.com/realtime"
            };
 
            var connected = false;
            ClientWebSocket client = null;
            
            foreach (var url in urls)
            {
                try
                {
                    client = new ClientWebSocket();
                    Console.Write($"Connecting to {url}..");
                    await client.ConnectAsync(new Uri(url), CancellationToken.None);
                    Console.ForegroundColor = ConsoleColor.Green;
                    Console.WriteLine($"connected");
                    Console.ResetColor();
                    connected = true;
                    break;
                }
                catch (WebSocketException e)
                {
                    client.Dispose();
                    Console.ForegroundColor = ConsoleColor.Red;
                    Console.WriteLine("could not connect.Reason:");
                    Console.ResetColor();
                    Console.WriteLine($"{e}{Environment.NewLine}");
                }
            }
 
            if (!connected)
            {
                Console.ForegroundColor = ConsoleColor.Red;
                Console.WriteLine("Could not connect to any of possible hosts");
                Console.ResetColor();
                return;
            }
 
            //trade topic
            //string topicName = "trade";
            string topicName = "orderBookL2_25";
            var message = new CommandMessage
            {
                Operation = "subscribe",
                Args = new[] { $"{topicName}.BTCUSD" }
            };
 
            Console.Write($"Sending subscription to \"{topicName}\" topic..");
            await client.SendAsync(message.ToJsonWireFormat(), WebSocketMessageType.Text, true, CancellationToken.None);
            Console.WriteLine("sent");
            do
            {
                var memory = new Memory<byte>(new byte[BUFFER_SIZE]);
                var result = await client.ReceiveAsync(memory, CancellationToken.None);
                while (!result.EndOfMessage)
                    result = await client.ReceiveAsync(memory, CancellationToken.None);
 
                var json = BaseResponseMessage.ToJson(memory.ToArray());
                Console.WriteLine($"Got message: {json}");
            }
            while (client.State == WebSocketState.Open);
 
            Console.WriteLine("Connection closed.");
 
            Console.ReadLine();
        }
 
        class CommandMessage
        {
            [JsonPropertyName("Op")]
            public string Operation { get; set; }
 
            [JsonPropertyName("args")]
            public string[] Args { get; set; }
 
            public byte[] ToJsonWireFormat()
            {
                return Encoding.UTF8.GetBytes(JsonSerializer.Serialize(this));
            }
        }
 
        class BaseResponseMessage
        {
            protected static T FromJsonWireFormat<T>(byte[] wire) => JsonSerializer.Deserialize<T>(Encoding.UTF8.GetString(wire));
 
            protected static T FromJson<T>(string json) => JsonSerializer.Deserialize<T>(json);
 
            public static string ToJson(byte[] wire) => Encoding.UTF8.GetString(wire);
 
            public string ToJson<T>(T entity) => JsonSerializer.Serialize(entity);
        }
 
        class TradeResponseMessage: BaseResponseMessage
        {
            [JsonPropertyName("timestamp")]
            public DateTime Timestamp { get; set; }
 
            [JsonPropertyName("trade_time_ms")]
            public int TradeTimeMs { get; set; }
 
            [JsonPropertyName("side")]
            public string Side { get; set; }
 
            [JsonPropertyName("size")]
            public int Size { get; set; }
 
            [JsonPropertyName("price")]
            public decimal Price { get; set; }
 
            [JsonPropertyName("tick_direction")]
            public string TickDirection { get; set; }
 
            [JsonPropertyName("trade_id")]
            public string TradeId { get; set; }
 
            [JsonPropertyName("cross_seq")]
            public int CrossSequence { get; set; }
 
            public static TradeResponseMessage FromJsonWireFormat(byte[] wire) => FromJsonWireFormat<TradeResponseMessage>(wire);
 
            public static TradeResponseMessage FromJson(string json) => FromJson<TradeResponseMessage>(json);
 
            public string ToJson() => JsonSerializer.Serialize(this);
 
        }
 
        class OrderBookMessage
        {
            [JsonPropertyName("price")]
            public string Price { get; set; }
 
            [JsonPropertyName("symbol")]
            public string Symbol { get; set; }
 
            [JsonPropertyName("side")]
            public string Side { get; set; }
 
            [JsonPropertyName("size")]
            public int Size { get; set; }
        }
    }

Добавлено через 2 минуты
PS: В доках есть ссылка на гитхаб с python-репозиторием, где делаются запросы не на IP-адреса, а не доменные имена.
C IP-адресами проблемы с TLS возникают...

@Steroid · 31.03.2022, 15:36 **[ТС]**

IamRain, спасибо
я себе уже голову поломал
уже 3-4 дня парюсь
тонну документации перерыл и видео прересмотрел но почти ничего не понял
твой пример открыл мне глаза, я именно так и хотел
подогнал под себя

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
public partial class MainWindow : Window
    {
        private const int BUFFER_SIZE = 4096;
        //wss urls
        string testNet = "wss://stream-testnet.bybit.com/realtime";
        string mainNet1 = "wss://stream.bybit.com/realtime";
        string mainNet2 = "wss://stream.bytick.com/realtime";
        string demoWebsocket = "wss://demo.piesocket.com/v3/channel_1?api_key=oCdCMcMPQpbvNjUIzqtvF1d2X2okWpDQj4AwARJuAgtjhzKxVEjQU6IdCjwm&notify_self";
        int port = 443;
        bool connected = false;
        ClientWebSocket wsClient;
 
 
        public MainWindow()
        {
            InitializeComponent();
        }
        void StartConnect()
        {
            VerbindungErstellen(websocketAddressTxbox.Text);
        }
        async void VerbindungErstellen(string uri)
        {
            //ServicePointManager.ServerCertificateValidationCallback = delegate {return true;};
            //ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls13;
 
            wsClient = new ClientWebSocket();
 
            textBox1.Text += $"\nConnecting to {uri}..";
 
            await wsClient.ConnectAsync(new Uri(uri), CancellationToken.None);
 
            if (wsClient.State == WebSocketState.Open)
            {
                connected = true;
                textBox1.Text += "\nconnected";
            }
            else
            {
                textBox1.Text += "\nNOTconnected";
            }
 
            statusTxtbox.Text = wsClient.State.ToString();
 
            DatenAbonieren();
        }
 
        async void DatenAbonieren()
        {
            string topicName = "instrument_info";
 
            CommandMessage command = new CommandMessage
            {
                Operation = "subscribe",
                Args = new[] { $"{topicName}.100ms.BTCUSD"
                }
            };
 
            textBox1.Text += $"Sending subscription to \"{topicName}\" topic..";
            await wsClient.SendAsync(command.ToJsonWireFormat(), WebSocketMessageType.Text, true, CancellationToken.None);
 
            try
            {
                do
                {
                    Memory<byte> memory = new Memory<byte>(new byte[BUFFER_SIZE]);
                    ValueWebSocketReceiveResult result = await wsClient.ReceiveAsync(memory, CancellationToken.None);
                    while (!result.EndOfMessage)
                    {
                        result = await wsClient.ReceiveAsync(memory, CancellationToken.None);
                    }
                    string json = BaseResponseMessage.ToJson(memory.ToArray());
                    textBox1.Text = $"Got message: {json}";
                }
                while (wsClient.State == WebSocketState.Open);
            }
            catch (Exception e)
            {
                Debug.WriteLine(e.ToString());
            }
            textBox1.Text = "Connection closed.";
        }
 
        void VerbindungSchliessen()
        {
            wsClient.Abort();
            if (wsClient.State != WebSocketState.Open)
            {
                textBox1.Text += "\nDisconnected";
            }
            statusTxtbox.Text = wsClient.State.ToString();
        }
 
        private void ConnectButton_Click(object sender, RoutedEventArgs e)
        {
            StartConnect();
        }
 
        private void DisconnectButton_Click(object sender, RoutedEventArgs e)
        {
            VerbindungSchliessen();
        }
    }
}
 
class CommandMessage
{
    [JsonPropertyName("Op")]
    public string Operation { get; set; }
 
    [JsonPropertyName("args")]
    public string[] Args { get; set; }
 
    public byte[] ToJsonWireFormat()
    {
        return Encoding.UTF8.GetBytes(JsonSerializer.Serialize(this));
    }
}

не понял что это делает

Кликните здесь для просмотра всего текста

C#
1
2
ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };
ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls13;

Добавлено через 3 минуты
IamRain, еще вопрос
как мне вытащить из пакета только ту информацию которую мне нужно
например last_price или чтото другое по отдельности?

Добавлено через 1 минуту

Сообщение от IamRain

не на IP-адреса, а не доменные имена.

да мне как раз надо на dns имена
как wss://stream.bybit.com/realtime

@IamRain · 31.03.2022, 17:42

Сообщение от Steroid

например last_price или чтото другое по отдельности?

Надо десериализовать в сущность (снизу там в листинге есть базовый класс передаваемых объектов - BaseResponseMessage, используйте его методы - FromJson<T> или FromJsonWireFormat<T>).
Там нужно немного подравить цикл получения данных. Исправленные версии (меньше аллокаций памяти) кода:

BaseResponseMessage

C#
1
2
3
4
5
6
7
8
9
10
11
12
class BaseResponseMessage
        {
            protected static T FromJsonWireFormat<T>(byte[] wire) => JsonSerializer.Deserialize<T>(Encoding.UTF8.GetString(wire));
 
            protected static T FromJson<T>(string json) => JsonSerializer.Deserialize<T>(json);
 
            public static string ToJson(byte[] wire) => Encoding.UTF8.GetString(wire);
 
            public static string ToJson(ReadOnlySpan<byte> wire) => Encoding.UTF8.GetString(wire);
 
            public string ToJson<T>(T entity) => JsonSerializer.Serialize(entity);
        }

Цикл получения

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
Console.Write($"Sending subscription to "{topicName}" topic..");
            await client.SendAsync(message.ToJsonWireFormat(), WebSocketMessageType.Text, true, CancellationToken.None);
            Console.WriteLine("sent");
            cts = new CancellationTokenSource();
            cts.CancelAfter(TimeSpan.FromSeconds(10));
            try
            {
                do
                {
                    var memory = new Memory<byte>(new byte[BUFFER_SIZE]);
                    var result = await client.ReceiveAsync(memory, CancellationToken.None);
                    var bytesReceived = result.Count;
                    while (!result.EndOfMessage)
                    {
                        result = await client.ReceiveAsync(memory, CancellationToken.None);
                        bytesReceived += result.Count;
                    }
 
                    var json = BaseResponseMessage.ToJson(memory.Slice(0, bytesReceived).Span);
                    Console.WriteLine(json);
 
                    if (cts.Token.IsCancellationRequested)
                        break;
                } 
                while (client.State == WebSocketState.Open);
            }
            catch (Exception exc)
            {
                Console.WriteLine("Unexpected error:");
                Console.WriteLine($"{exc}");
            }
            finally
            {
                await DisposeResources();
                Console.WriteLine("Connection closed.");
            }
 
            private static async Task DisposeResources()
           {
            await client?.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "Normal closure", CancellationToken.None);
            client?.Dispose();
            client = null;
           }

Добавлено через 6 минут

Сообщение от Steroid

не понял что это делает

Это нужно для проверки сертификата сервера при отправки запроса по https, (при отправке с использованеим IPAddress - ов были проблемы, игрался с этим просто, если у вас все и так работает, можете убрать).

Еще момент:

Сообщение от Steroid

private const int BUFFER_SIZE = 4096;

Сделайте в 2-3 раза больше (4096 * 3) - иногда первое сообщение приходит размером больше 4-килобайта, тут можно недописать данные в Memory<T> (затереть вроде нельзя, могу ошибаться, надо проверять).
+ Так вы наверняка уменьшите число чтений практически каждого сообщения до одного (один вызов client.ReceiveAsync потребуется).

Добавлено через 4 минуты
Можно даже рискнуть, сделав допущение, что конкретный топик не возвращает сообщения размером больше заданного, например (4096 * 3, индивидуально эмпирически подбирается для каждого топика, ятп).
И вообще убрать проверку на result.EndOfMessage, тем самым повысив пропускную способность вашего клиента.

@Steroid · 01.04.2022, 01:12 **[ТС]**

IamRain,
спасибо ты мне здорово помог на данном этапе

теперь я создал структуру(класс)

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
public class instrumentInfoApplication
    {
        public instrumentInfoApplication() { }
        public string topic { get; set; }
        public string type { get; set; }
        public instrumentInfoData data { get; set; }
        public double cross_seq { get; set; }
        public double timestamp_e6 { get; set; }
    }
 
    public class instrumentInfoData
    {
        public double id { get; set; }
        public string symbol { get; set; }
        public double last_price_e4 { get; set; }
        public string last_price { get; set; }
        public double bid1_price_e4 { get; set; }
        public string bid1_price { get; set; }
        public double ask1_price_e4 { get; set; }
        public string ask1_price { get; set; }
        public string last_tick_direction { get; set; }
        public double prev_price_24h_e4 { get; set; }
        public string prev_price_24h { get; set; }
        public double price_24h_pcnt_e6 { get; set; }
        public double high_price_24h_e4 { get; set; }
        public string high_price_24h { get; set; }
        public double low_price_24h_e4 { get; set; }
        public string low_price_24h { get; set; }
        public double prev_price_1h_e4 { get; set; }
        public string prev_price_1h { get; set; }
        public double price_1h_pcnt_e6 { get; set; }
        public double mark_price_e4 { get; set; }
        public string mark_price { get; set; }
        public double index_price_e4 { get; set; }
        public string index_price { get; set; }
        public double open_interest { get; set; }
        public double open_value_e8 { get; set; }
        public double total_turnover_e8 { get; set; }
        public double turnover_24h_e8 { get; set; }
        public double total_volume { get; set; }
        public double volume_24h { get; set; }
        public double funding_rate_e6 { get; set; }
        public double predicted_funding_rate_e6 { get; set; }
        public double cross_seq { get; set; }
        public string created_at { get; set; }
        public string updated_at { get; set; }
        public string next_funding_time { get; set; }
        public double countdown_hour { get; set; }
        public double funding_rate_interval { get; set; }
    }

и пытаюсь десериализовать полученные данные чтобы вывести последнюю цену в текстбоксе
но возникает NullReferenceException
никак не пойму в чем дело
десериализация проходит нормально
все данные передаются
даже текстбокс получает эти данные
но тутже выскакивает ошибка
не могу понять почему

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
async void DatenAbonieren()
        {
            string topicName = "instrument_info";
            CommandMessage command = new CommandMessage
            {
                Operation = "subscribe",
                Args = new[] { $"{topicName}.100ms.BTCUSD"
                }
            };
            textBox1.Text += $"Sending subscription to \"{topicName}\" topic..";
            await wsClient.SendAsync(command.ToJsonWireFormat(), WebSocketMessageType.Text, true, CancellationToken.None);
            try
            {
                do
                {
                    Memory<byte> memory = new Memory<byte>(new byte[BUFFER_SIZE]);
                    ValueWebSocketReceiveResult result = await wsClient.ReceiveAsync(memory, CancellationToken.None);
                    instrumentInfoApplication resultat = new instrumentInfoApplication();
                    var byteRecieved = result.Count;
                    while (!result.EndOfMessage)
                    {
                        result = await wsClient.ReceiveAsync(memory, CancellationToken.None);
                        byteRecieved += result.Count;
                    }
 
                    string json = Encoding.UTF8.GetString(memory.Slice(0, byteRecieved).Span);
                    //bytestxtbox.Text += "\n" + byteRecieved.ToString() + " " + DateTime.Now.Second.ToString();
                    resultat = JsonSerializer.Deserialize<instrumentInfoApplication>(json);
                    textBox1.Text += $"BTCUSD: {resultat.data.last_price.ToString()}";
                    StatusLine();
                }
                while (wsClient.State == WebSocketState.Open);
            }
            catch (Exception e)
            {
                Debug.WriteLine(e.ToString());
            }
            StatusLine();
            textBox1.Text = "Connection closed.";
        }

@IamRain · 01.04.2022, 09:24

Сообщение от Steroid

не могу понять почему

Там же написано: last_price свойство не получило значение - то есть оно возвращает NULL. А вы пытаетесь вызвать ToString на пустой ссылке.
Другой вопрос - почему так произошло. Некорректно десериализовали? Мб что-то еще.

@Steroid · 04.04.2022, 12:48 **[ТС]**

Сообщение от IamRain

почему так произошло

[quote="IamRain;16151037"]

LOL

оказывается с биржи приходят разные данные с какойто переодичностью
часто прилетает такой пакет

Кликните здесь для просмотра всего текста

JSON
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
{
    "topic": "instrument_info.100ms.BTCUSD",
    "type": "delta",
    "data": {
        "delete": [],
        "update": [
            {
                "id": 1,
                "symbol": "BTCUSD",
                "prev_price_24h_e4": 81565000,
                "prev_price_24h": "81565000",
                "price_24h_pcnt_e6": -4904,
                "open_value_e8": 2000479681106,
                "total_turnover_e8": 2029370495672976,
                "turnover_24h_e8": 9066215468687,
                "volume_24h": 735316391,
                "cross_seq": 1053192657,
                "created_at": "2018-11-14T16:33:26Z",
                "updated_at": "2020-01-12T18:25:25Z"
            }
        ],
        "insert": []
    },
    "cross_seq": 1053192657,
    "timestamp_e6": 1578853525691123
}

и время от времени тот который мне нужет с данными о цене

Кликните здесь для просмотра всего текста

JSON
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
{
    "topic":"instrument_info.100ms.BTCUSD",
    "type":"snapshot",
    "data": {
         "id": 1,
         "symbol": "BTCUSD",                           //instrument name
         "last_price_e4": 81165000,                    //the latest price
         "last_price": "81165000",  
         "bid1_price_e4":400025000,                    // best bid price
         "bid1_price":"400025000",
         "ask1_price_e4":475450000,                    // best ask price
         "ask1_price":"475450000",
         "last_tick_direction": "ZeroPlusTick",        //the direction of last tick:PlusTick,ZeroPlusTick,MinusTick,ZeroMinusTick
         "prev_price_24h_e4": 81585000,                //the price of prev 24h
         "prev_price_24h": "81585000",
         "price_24h_pcnt_e6": -5148,                   //the current last price percentage change from prev 24h price
         "high_price_24h_e4": 82900000,                //the highest price of prev 24h
         "high_price_24h": "82900000",
         "low_price_24h_e4": 79655000,                 //the lowest price of prev 24h
         "low_price_24h": "79655000",
         "prev_price_1h_e4": 81395000,                 //the price of prev 1h
         "prev_price_1h": "81395000",
         "price_1h_pcnt_e6": -2825,                    //the current last price percentage change from prev 1h price
         "mark_price_e4": 81178500,                    //mark price
         "mark_price": "81178500",
         "index_price_e4": 81172800,                   //index price
         "index_price": "81172800",
         "open_interest": 154418471,                   //open interest quantity - Attention, the update is not immediate - slowest update is 1 minute
         "open_value_e8": 1997561103030,               //open value quantity - Attention, the update is not immediate - the slowest update is 1 minute
         "total_turnover_e8": 2029370141961401,        //total turnover
         "turnover_24h_e8": 9072939873591,             //24h turnover
         "total_volume": 175654418740,                 //total volume
         "volume_24h": 735865248,                      //24h volume
         "funding_rate_e6": 100,                       //funding rate
         "predicted_funding_rate_e6": 100,             //predicted funding rate
         "cross_seq": 1053192577,                      //sequence
         "created_at": "2018-11-14T16:33:26Z",         
         "updated_at": "2020-01-12T18:25:16Z",         
         "next_funding_time": "2020-01-13T00:00:00Z",  //next funding time
                                                       //the rest time to settle funding fee
         "countdown_hour": 6,                           //the remaining time to settle the funding fee
         "funding_rate_interval": 8
         },
    "cross_seq":9267002,
    "timestamp_e6":1615794861826248
}

@IamRain · 04.04.2022, 13:10

Я бы на вашем месте хорошенько перечитал документацию на сайте (возможно, вы это уже сделали).
Тогда можно просто десериализовать в ваш тип и если его атрибут type="delta", то просто игнорировать сообщение (если оно действительно не нужно).
Вообще это все еще коленочное решение. По-хорошему надо:
1. Обернуть в тип, который бы имел список подключенных виртуальных подканалов.
1.1 Сделать подписку/отписку на подканал.
2. Правильно сделать закрытие соединения. Сейчас он просто посылает graceful close сообщение (которое принимающая сторона может игнорировать). Именно поэтому консолька продолжает висеть даже после завершения работы.
Возможно, надо насильно рвать соединение. А сервер на другой стороне сам уже освободит неиспользуемые ресурсы/закроет подключение.
3. В типе из п.1 добавить ограничение числа подканалов в одном канале (число подписок в одном физическом TCP-соединении).
Как-то так.

@Steroid · 04.04.2022, 13:24 **[ТС]**

Сообщение от IamRain

2. Правильно сделать закрытие соединения.

это я сделал

на отдельном батоне висит

Кликните здесь для просмотра всего текста

C#
1
wsClient.CloseAsync(WebSocketCloseStatus.NormalClosure,"close", CancellationToken.None);

с остальным надо думать, блин

Добавлено через 2 минуты
весь код

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Net.Sockets;
using System.Net.WebSockets;
using System.Net;
using System.Diagnostics;
using System.Threading;
using System.Text.Json.Serialization;
using System.Text.Json;
using System.IO;
 
namespace WebSocketTestBybit
{
    /// <summary>
    /// Interaction logic for MainWindow.xaml
    /// </summary>
    public partial class MainWindow : Window
    {
        private const int BUFFER_SIZE = 4096;
        //wss urls
        string testNet = "wss://stream-testnet.bybit.com/realtime";
        string mainNet1 = "wss://stream.bybit.com/realtime";
        string mainNet2 = "wss://stream.bytick.com/realtime";
        string demoWebsocket = "wss://demo.piesocket.com/v3/channel_1?api_key=oCdCMcMPQpbvNjUIzqtvF1d2X2okWpDQj4AwARJuAgtjhzKxVEjQU6IdCjwm&notify_self";
        int port = 443;
        bool connected = false;
        ClientWebSocket wsClient;
        Bybit_Instrument_Info_Application resultat { get; set; }
 
        public MainWindow()
        {
            InitializeComponent();
        }
        void StartConnect()
        {
            VerbindungErstellen(websocketAddressTxbox.Text);
        }
        private void StatusLine()
        {
            statusTxtbox.Text = wsClient.State.ToString();
        }
        async void VerbindungErstellen(string uri)
        {
            //ServicePointManager.ServerCertificateValidationCallback = delegate {return true;};
            //ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls13;
 
            wsClient = new ClientWebSocket();
 
            textBox1.Text += $"\nConnecting to {uri}..";
 
            await wsClient.ConnectAsync(new Uri(uri), CancellationToken.None);
 
            if (wsClient.State == WebSocketState.Open)
            {
                connected = true;
                textBox1.Text += "\nconnected";
            }
            else
            {
                textBox1.Text += "\nNOTconnected";
            }
            //StatusLine();
            DatenAbonieren("instrument_info", 100, "BTCUSD");
        }
 
        async void DatenAbonieren(string topicName, int pushfrequency, string symbol)
        {
            CommandMessage command = new CommandMessage
            {
                Operation = "subscribe",
                Args = new[] { $"{topicName}.{pushfrequency}ms.{symbol}"
                }
            };
            textBox1.Text += $"Sending subscription to \"{topicName}\" topic..";
            await wsClient.SendAsync(command.ToJsonWireFormat(), WebSocketMessageType.Text, true, CancellationToken.None);
            
            StatusLine();
            textBox1.Text += "\nConnection Open.";
        }
 
        async void DatenHollen()
        {
            try
            {
                resultat = new Bybit_Instrument_Info_Application();
                do
                {
                    Memory<byte> memory = new Memory<byte>(new byte[BUFFER_SIZE]);
                    ValueWebSocketReceiveResult result = await wsClient.ReceiveAsync(memory, CancellationToken.None);
                    int byteRecieved = result.Count;
                    do
                    {
                        result = await wsClient.ReceiveAsync(memory, CancellationToken.None);
                        byteRecieved += result.Count;
                    }
                    while (!result.EndOfMessage);
                    string json = Encoding.UTF8.GetString(memory.Slice(0, byteRecieved).Span);
                    bytestxtbox.Text += "\n" + byteRecieved.ToString() + " " + DateTime.Now.Minute.ToString() + ":" + DateTime.Now.Second.ToString();
 
                    textBox1.Text = $"BTCUSD: {json}";
                    await Task.Delay(1000);
                    StatusLine();
                }
                while (wsClient.State == WebSocketState.Open);
                StatusLine();
            }
            catch (Exception e)
            {
                Debug.WriteLine(e.ToString());
            }
        }
 
        void VerbindungSchliessen()
        {
            wsClient.CloseAsync(WebSocketCloseStatus.NormalClosure,"close", CancellationToken.None);
            StatusLine();
        }
 
        private void ConnectButton_Click(object sender, RoutedEventArgs e)
        {
            StartConnect();
        }
 
        private void DisconnectButton_Click(object sender, RoutedEventArgs e)
        {
            VerbindungSchliessen();
        }
 
        private void Checktxbox_Click(object sender, RoutedEventArgs e)
        {
            DatenHollen();
        }
    }
}
 
class CommandMessage
{
    [JsonPropertyName("Op")]
    public string Operation { get; set; }
 
    [JsonPropertyName("args")]
    public string[] Args { get; set; }
 
    public byte[] ToJsonWireFormat()
    {
        return Encoding.UTF8.GetBytes(JsonSerializer.Serialize(this));
    }
}

Добавлено через 1 минуту
класс для десериализации

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
using System;
using System.Collections.Generic;
using System.Text;
using System.Text.Json.Serialization;
 
namespace WebSocketTestBybit
{
    public class Bybit_Instrument_Info_Application
    {
        public string topic { get; set; }
        public string type { get; set; }
        public Bybit_Instrument_Info_Data data { get; set; }
        public double cross_seq { get; set; }
        public double timestamp_e6 { get; set; }
    }
    public class Bybit_Instrument_Info_Data
    {
        public double id { get; set; }
        public string symbol { get; set; }
        public double last_price_e4 { get; set; }
        public string last_price { get; set; }
        public double bid1_price_e4 { get; set; }
        public string bid1_price { get; set; }
        public double ask1_price_e4 { get; set; }
        public string ask1_price { get; set; }
        public string last_tick_direction { get; set; }
        public double prev_price_24h_e4 { get; set; }
        public string prev_price_24h { get; set; }
        public double price_24h_pcnt_e6 { get; set; }
        public double high_price_24h_e4 { get; set; }
        public string high_price_24h { get; set; }
        public double low_price_24h_e4 { get; set; }
        public string low_price_24h { get; set; }
        public double prev_price_1h_e4 { get; set; }
        public string prev_price_1h { get; set; }
        public double price_1h_pcnt_e6 { get; set; }
        public double mark_price_e4 { get; set; }
        public string mark_price { get; set; }
        public double index_price_e4 { get; set; }
        public string index_price { get; set; }
        public double open_interest { get; set; }
        public double open_value_e8 { get; set; }
        public double total_turnover_e8 { get; set; }
        public double turnover_24h_e8 { get; set; }
        public double total_volume { get; set; }
        public double volume_24h { get; set; }
        public double funding_rate_e6 { get; set; }
        public double predicted_funding_rate_e6 { get; set; }
        public double cross_seq { get; set; }
        public string created_at { get; set; }
        public string updated_at { get; set; }
        public string next_funding_time { get; set; }
        public double countdown_hour { get; set; }
        public double funding_rate_interval { get; set; }
    }
}

@IamRain · 04.04.2022, 13:35

Сообщение от Steroid

с остальным надо думать, блин

Сообщение от Steroid

public string type { get; set; }

Я не вникал в эти торги криптовалютой, наверняка на сайте есть информация по этому поводу. Для чего нужно delta-сообщение, как оно связывается с предыдущими snapshot сообщениями, и т.д.
Вообщем, дальше сами.

@Steroid · 04.04.2022, 13:44 **[ТС]**

Сообщение от IamRain

торги криптовалютой

да это то ни причем
принцип то один

Огромно спасибо за помошь и подсказки
Очень помог

Новые блоги и статьи Все статьи Все блоги /
Хочу заставить корпорации вкладываться в здоровье сотрудников: делаю мат модель здравосохранения anaschu 22.03.2026 e7EYtONaj8Y Z4Tv2zpXVVo https:/ / github. com/ shumilovas/ med2. git	1С: Программный отбор элементов справочника по группе Maks 22.03.2026 Установка программного отбора элементов справочника "Номенклатура" из модуля формы документа. В качестве фильтра для отбора справочника служит группа номенклатуры. Отбор по наименованию группы. . .	Как я обхитрил таблицу Word Alexander-7 21.03.2026 Когда мигает курсор у внешнего края таблицы, и нам надо перейти на новую строку, а при нажатии Enter создается новый ряд таблицы с ячейками, то мы вместо нервных нажатий Энтеров мы пишем любые буквы. . .	Krabik - рыболовный бот для WoW 3.3.5a AmbA 21.03.2026 без регистрации и смс. Это не торговля, приложение не содержит рекламы. Выполняет свою непосредственную задачу - автоматизацию рыбалки в WoW - и ничего более. Однако если админы будут против -. . .
1С: Программный отбор элементов справочника по значению перечисления Maks 21.03.2026 Установка программного отбора элементов справочника "Сотрудники" из модуля формы документа. В качестве фильтра для отбора служит значение перечислений. / / Событие "НачалоВыбора" реквизита на форме. . .	Переходник USB-CAN-GPIO Eddy_Em 20.03.2026 Достаточно давно на работе возникла необходимость в переходнике CAN-USB с гальваноразвязкой, оный и был разработан. Однако, все меня терзала совесть, что аж 48-ногий МК используется так тупо: просто. . .	Оттенки серого Argus19 18.03.2026 Оттенки серого Нашёл в интернете 3 прекрасных модуля: Модуль класса открытия диалога открытия/ сохранения файла на Win32 API; Модуль класса быстрого перекодирования цветного изображения в оттенки. . .	SDL3 для Desktop (MinGW): Рисуем цветные прямоугольники с помощью рисовальщика SDL3 на Си и C++ 8Observer8 17.03.2026 Содержание блога Финальные проекты на Си и на C++: finish-rectangles-sdl3-c. zip finish-rectangles-sdl3-cpp. zip

@QuakerRUS 1469 / 1010 / 456 Регистрация: 30.10.2017 Сообщений: 2,799
	29.03.2022, 18:12
	Steroid, а что именно содержится в websocketAddressTxbox.Text ? 0

@Steroid 296 / 217 / 86 Регистрация: 17.02.2016 Сообщений: 1,276 Записей в блоге: 1
	29.03.2022, 20:00 [ТС]
	QuakerRUS, да это работает но это простой http адрес я не совсем понимаю как мне "поздороватся" с сервером и получать данные в реальном времени в документации от биржи нужно через вебсокет ссылка на документацию 0

@Steroid 296 / 217 / 86 Регистрация: 17.02.2016 Сообщений: 1,276 Записей в блоге: 1
	29.03.2022, 20:17 [ТС]
	QuakerRUS, благодарю за помошь 0

@IamRain 4694 / 2702 / 734 Регистрация: 02.08.2011 Сообщений: 7,233
	04.04.2022, 13:10
	Я бы на вашем месте хорошенько перечитал документацию на сайте (возможно, вы это уже сделали). Тогда можно просто десериализовать в ваш тип и если его атрибут type="delta", то просто игнорировать сообщение (если оно действительно не нужно). Вообще это все еще коленочное решение. По-хорошему надо: 1. Обернуть в тип, который бы имел список подключенных виртуальных подканалов. 1.1 Сделать подписку/отписку на подканал. 2. Правильно сделать закрытие соединения. Сейчас он просто посылает graceful close сообщение (которое принимающая сторона может игнорировать). Именно поэтому консолька продолжает висеть даже после завершения работы. Возможно, надо насильно рвать соединение. А сервер на другой стороне сам уже освободит неиспользуемые ресурсы/закроет подключение. 3. В типе из п.1 добавить ограничение числа подканалов в одном канале (число подписок в одном физическом TCP-соединении). Как-то так. 1

Код для связи с биржей при помощи Websocket

Решение