WebSocket API v1 – nieoczekiwane rozłączenia z kanałów danych rynkowych

Ostatnia aktualizacja: 1 kwi 2025

Nasze WebSocket API v1 ma na celu zapewnienie stałego źródła naszych danych rynkowych (tickerów, ksiąg zleceń, czasu i sprzedaży itp.), ale czasami połączenia WebSocket są nieoczekiwanie przerywane przez Cloudflare.

Rozłączenia inicjowane przez Cloudflare zazwyczaj skutkują błędami sieciowymi, takimi jak następujący błąd 1006:

•
Błąd odczytu z websocket: zamknięcie 1006 (nieprawidłowe zamknięcie): nieoczekiwany EOF

lub następujący, gdzie Python zgłasza wyjątek podczas próby odczytania nowej wiadomości z danymi rynkowymi z już zamkniętego połączenia:

•
websocket._exceptions.WebSocketConnectionClosedException: gniazdo jest już zamknięte

Chociaż nie ma rozwiązania, które zapobiegałoby tego typu nieoczekiwanym rozłączeniom, istnieją bardzo skuteczne obejścia. W przypadku częstych rozłączeń WebSocket zalecamy wdrożenie jednego lub więcej z poniższych rozwiązań:

Alternatywny adres IP

Środki bezpieczeństwa Cloudflare są często stosowane do określonych adresów IP, grup podobnych adresów IP (takich jak blok klasy C) lub określonych lokalizacji geograficznych, dlatego zmiana adresu IP jest czasami prostym, ale skutecznym rozwiązaniem.

Na przykład, hostowanie oprogramowania API w innym regionie AWS lub używanie VPN w innej lokalizacji geograficznej, znacząco zmieniłoby lokalny adres IP i potencjalnie rozwiązałoby problem nieoczekiwanego rozłączenia.

Logika ponownego połączenia

Użycie pojedynczego połączenia WebSocket, które jest monitorowane pod kątem wszelkich niezamierzonych rozłączeń i w razie potrzeby ponownie łączone i subskrybowane, jest kolejnym prostym, ale skutecznym rozwiązaniem. Poniżej znajduje się podstawowy przykład kodu Python, pokazujący, jak ponownie połączyć i ponownie zasubskrybować połączenie WebSocket za każdym razem, gdy zostanie zgłoszony wyjątek 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)

Jak pokazano w poniższym przykładzie wyjścia, połączenie WebSocket i subskrypcja są odnawiane za każdym razem, gdy połączenie zostanie nieoczekiwanie zakończone (przy 30 i 60 iteracjach pętli):

Redundantne połączenia

Użycie wielu (dwóch lub więcej) redundantnych połączeń WebSocket jest zazwyczaj najskuteczniejszym rozwiązaniem problemu nieoczekiwanych rozłączeń WebSocket, ponieważ pozwala na nieprzerwane dostarczanie danych rynkowych, niezależnie od tego, jak często podstawowe połączenia są przerywane.

Poniższy podstawowy przykład kodu Python pokazuje, jak zaimplementować wiele połączeń WebSocket z automatycznym przełączaniem awaryjnym:

#!/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)

Powyższy kod tworzy dwa połączenia WebSocket i subskrybuje oba połączenia do tego samego kanału danych rynkowych. Połączenie podstawowe jest używane do wyprowadzania danych rynkowych, dopóki nie zostanie wygenerowane przerwanie z klawiatury (np. za pomocą Ctrl+C), które zamyka połączenie podstawowe. Kolejne odczyty z połączenia podstawowego zgłaszają wyjątek, który jest przechwytywany i używany do zmiany źródła danych rynkowych na połączenie zapasowe, które jest następnie używane do wyprowadzania danych rynkowych.

Poniższy przykład wyjścia pokazuje, jak źródło danych rynkowych zmienia się z połączenia podstawowego na połączenie zapasowe bez przerywania strumienia danych rynkowych:

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"]

Należy pamiętać, że redundantne połączenia WebSocket są najbardziej złożonym z trzech rozwiązań, ale jest to optymalne rozwiązanie pod względem niezawodności.

WebSocket API v1 – nieoczekiwane rozłączenia z kanałów danych rynkowych

Alternatywny adres IP

Logika ponownego połączenia

Redundantne połączenia

Potrzebujesz więcej pomocy?