WebSocket API v1 — неожиданные разрывы соединения с потоками рыночных данных

Последнее обновление: 1 апр. 2025 г.

Наш WebSocket API v1 предназначен для предоставления постоянного источника наших рыночных данных (тикеры, книги ордеров, время и продажи и т. д.), но иногда соединения WebSocket неожиданно прерываются Cloudflare.

Разрывы соединения, инициированные Cloudflare, обычно приводят к сетевым ошибкам, таким как следующая ошибка 1006:

•
Ошибка чтения из веб-сокета: закрытие 1006 (аномальное закрытие): неожиданный конец файла

или следующая, когда Python выдает исключение при попытке прочитать новое сообщение рыночных данных из уже закрытого соединения:

•
websocket._exceptions.WebSocketConnectionClosedException: сокет уже закрыт

Хотя не существует решения, которое предотвращает такие неожиданные разрывы соединения, есть несколько очень эффективных обходных путей. В случае частых разрывов соединения WebSocket мы рекомендуем реализовать одно или несколько из следующих решений:

Альтернативный IP-адрес

Меры безопасности Cloudflare часто применяются к определенным IP-адресам, группам схожих IP-адресов (например, блок класса C) или определенным географическим местоположениям, поэтому изменение вашего IP-адреса иногда является простым, но эффективным решением.

Например, размещение вашего программного обеспечения API в другом регионе AWS или использование VPN в другом географическом местоположении значительно изменит локальный IP-адрес и потенциально решит проблему неожиданного разрыва соединения.

Логика переподключения

Использование одного соединения WebSocket, которое отслеживается на предмет любых непреднамеренных разрывов и при необходимости переподключается и повторно подписывается, является еще одним простым, но эффективным решением. Ниже приведен базовый пример кода Python, показывающий, как переподключать и повторно подписывать соединение WebSocket всякий раз, когда возникает исключение WebSocketConnectionClosed:

#!/usr/bin/env python3 import sys from websocket import create_connection ws = create_connection('wss://ws.kraken.com/') print(ws.recv()) ws.send('{"event":"subscribe", "subscription":{"name":"ticker"}, "pair":["XBT/USD"]}') print(ws.recv()) for count in range(100): if count == 30 or count == 60: ws.close() try: print(ws.recv()) except: ws = create_connection('wss://ws.kraken.com/') print(ws.recv()) ws.send('{"event":"subscribe", "subscription":{"name":"ticker"}, "pair":["XBT/USD"]}') print(ws.recv()) ws.close() sys.exit(0)

Как показано в следующем примере вывода, соединение WebSocket и подписка возобновляются всякий раз, когда соединение неожиданно прерывается (на 30-й и 60-й итерациях цикла):

Избыточные соединения

Использование нескольких (двух или более) избыточных соединений WebSocket обычно является наиболее эффективным решением для неожиданных разрывов соединения WebSocket, поскольку это позволяет потокам рыночных данных продолжать работу без перебоев, независимо от того, как часто прерываются базовые соединения.

Следующий базовый пример кода Python показывает, как реализовать несколько соединений WebSocket с автоматическим переключением при сбое:

#!/usr/bin/env python3 import sys from websocket import create_connection ws = [ None, None ] data = [ "", "" ] ws[0] = create_connection("wss://ws.kraken.com/") print("WebSocket (Primary): %s" % ws[0].recv()) ws[1] = create_connection("wss://ws.kraken.com/") print("WebSocket (Backup): %s" % ws[1].recv()) ws[0].send('{"event":"subscribe", "subscription":{"name":"spread"}, "pair":["XBT/USD"]}') print("WebSocket (Primary): %s" % ws[0].recv()) ws[1].send('{"event":"subscribe", "subscription":{"name":"spread"}, "pair":["XBT/USD"]}') print("WebSocket (Backup): %s" % ws[1].recv()) source = 0 for count in range(100): try: try: data[0] = ws[0].recv() except Exception: source = 1 try: data[1] = ws[1].recv() except Exception: source = 0 except KeyboardInterrupt: ws[0].close() print("WebSocket (%(source)s): %(data)s" % {"source":"Primary" if source == 0 else "Backup", "data":data[source]}) ws[source].close() sys.exit(1)

Приведенный выше код создает два соединения WebSocket и подписывает оба соединения на один и тот же поток рыночных данных. Основное соединение используется для вывода рыночных данных до тех пор, пока не будет сгенерировано прерывание с клавиатуры (например, с помощью Ctrl+C), которое закрывает основное соединение. Последующие чтения из основного соединения вызывают исключение, которое перехватывается и используется для изменения источника рыночных данных на резервное соединение, которое затем используется для вывода рыночных данных.

Следующий пример вывода показывает, как источник рыночных данных меняется с основного соединения на резервное без прерывания потока рыночных данных:

WebSocket (Primary): {"connectionID":6894434610526943167,"event":"systemStatus","status":"online","version":"1.0.1"} WebSocket (Backup): {"connectionID":11520162761468018366,"event":"systemStatus","status":"online","version":"1.0.1"} WebSocket (Primary): {"channelID":275,"channelName":"spread","event":"subscriptionStatus","pair":["XBT/USD"],"status":"subscribed","subscription":{"name":"spread"}} WebSocket (Backup): {"channelID":275,"channelName":"spread","event":"subscriptionStatus","pair":["XBT/USD"],"status":"subscribed","subscription":{"name":"spread"}} WebSocket (Primary): [275,["9674.90000","9675.00000","1591440118.120752","10.88476562","3.47935600"],"spread","XBT/USD"] WebSocket (Primary): {"event":"heartbeat"} WebSocket (Primary): {"event":"heartbeat"} WebSocket (Primary): [275,["9674.90000","9675.00000","1591440127.108830","10.98812533","3.47935600"],"spread","XBT/USD"] WebSocket (Primary): {"event":"heartbeat"} WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.406073","1.87412533","7.47935600"],"spread","XBT/USD"] WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.505372","0.77412533","7.47935600"],"spread","XBT/USD"] WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.572658","0.10335971","7.47935600"],"spread","XBT/USD"] WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.572658","0.10335971","7.47935600"],"spread","XBT/USD"] ^C WebSocket (Backup): [275,["9674.90000","9675.00000","1591440130.156840","0.10335971","8.27935600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9674.90000","9675.00000","1591440130.195899","0.10335971","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9675.00000","1591440130.459388","0.10335971","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9672.60000","9675.00000","1591440130.195899","0.00516924","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9675.00000","1591440130.764856","0.00400000","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9674.90000","1591440130.780514","0.00400000","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): {"event":"heartbeat"} WebSocket (Backup): [275,["9673.80000","9674.90000","1591440132.433940","4.00400000","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9674.90000","1591440132.519509","4.00000000","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.90000","9674.90000","1591440132.527887","0.10336612","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.90000","9675.00000","1591440132.527887","0.10336612","4.27935600"],"spread","XBT/USD"]

Обратите внимание, что избыточные соединения WebSocket являются наиболее сложным из трех решений, но это оптимальное решение с точки зрения надежности.

WebSocket API v1 — неожиданные разрывы соединения с потоками рыночных данных

Альтернативный IP-адрес

Логика переподключения

Избыточные соединения

Нужна дополнительная помощь?