API WebSocket v1 - ngắt kết nối không mong muốn từ các nguồn cấp dữ liệu thị trường

Cập nhật lần cuối: 1 thg 4, 2025

API WebSocket v1 của chúng tôi (WebSocket API v1) được thiết kế để cung cấp nguồn dữ liệu thị trường liên tục (mã giao dịch, sổ lệnh, thời gian và doanh số, v.v.), nhưng đôi khi các kết nối WebSocket bị Cloudflare chấm dứt đột ngột.

Các ngắt kết nối do Cloudflare khởi tạo thường dẫn đến lỗi mạng, chẳng hạn như lỗi 1006 sau đây:

•
Lỗi đọc từ websocket: đóng 1006 (đóng bất thường): EOF không mong muốn

hoặc lỗi sau đây khi Python đưa ra một ngoại lệ khi cố gắng đọc một thông báo dữ liệu thị trường mới từ một kết nối đã đóng:

•
websocket._exceptions.WebSocketConnectionClosedException: socket đã đóng

Mặc dù không có giải pháp nào ngăn chặn các loại ngắt kết nối đột ngột này, nhưng có một số cách khắc phục rất hiệu quả. Trong trường hợp bạn thường xuyên gặp phải tình trạng ngắt kết nối WebSocket, chúng tôi khuyên bạn nên thực hiện một hoặc nhiều giải pháp sau:

Địa chỉ IP thay thế

Các biện pháp phòng ngừa bảo mật của Cloudflare thường được áp dụng cho các địa chỉ IP cụ thể, các nhóm địa chỉ IP tương tự (chẳng hạn như khối lớp C) hoặc các vị trí địa lý nhất định, do đó việc thay đổi địa chỉ IP của bạn đôi khi là một giải pháp đơn giản nhưng hiệu quả.

Ví dụ, việc lưu trữ phần mềm API của bạn ở một khu vực AWS khác hoặc sử dụng VPN ở một vị trí địa lý khác, cả hai đều sẽ thay đổi đáng kể địa chỉ IP cục bộ và có khả năng giải quyết vấn đề ngắt kết nối không mong muốn.

Logic kết nối lại

Sử dụng một kết nối WebSocket duy nhất được giám sát để phát hiện bất kỳ ngắt kết nối không mong muốn nào và được kết nối lại và đăng ký lại khi cần thiết là một giải pháp đơn giản nhưng hiệu quả khác. Sau đây là ví dụ cơ bản về mã Python cho thấy cách kết nối lại và đăng ký lại kết nối WebSocket bất cứ khi nào một ngoại lệ WebSocketConnectionClosed được đưa ra:

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

Như được hiển thị trong đầu ra mẫu sau, kết nối WebSocket và đăng ký được gia hạn bất cứ khi nào kết nối bị chấm dứt đột ngột (ở 30 và 60 lần lặp của vòng lặp):

Các kết nối dự phòng

Sử dụng nhiều (hai hoặc nhiều hơn) kết nối WebSocket dự phòng thường là giải pháp hiệu quả nhất cho các ngắt kết nối WebSocket không mong muốn, vì nó cho phép các nguồn cấp dữ liệu thị trường tiếp tục không bị gián đoạn bất kể tần suất các kết nối cơ bản bị chấm dứt.

Mã Python ví dụ cơ bản sau đây cho thấy cách triển khai nhiều kết nối WebSocket với tính năng chuyển đổi dự phòng tự động:

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

Mã trên tạo hai kết nối WebSocket và đăng ký cả hai kết nối vào cùng một nguồn cấp dữ liệu thị trường. Kết nối chính được sử dụng để xuất dữ liệu thị trường, cho đến khi một ngắt bàn phím được tạo (ví dụ: qua Ctrl+C), điều này đóng kết nối chính. Các lần đọc tiếp theo từ kết nối chính sẽ đưa ra một ngoại lệ, ngoại lệ này được bắt và sử dụng để thay đổi nguồn dữ liệu thị trường sang kết nối dự phòng, sau đó được sử dụng để xuất dữ liệu thị trường.

Đầu ra mẫu sau đây cho thấy cách nguồn dữ liệu thị trường thay đổi từ kết nối chính sang kết nối dự phòng mà không làm gián đoạn nguồn cấp dữ liệu thị trường:

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

Lưu ý rằng các kết nối WebSocket dự phòng là giải pháp phức tạp nhất trong ba giải pháp, nhưng nó là giải pháp tối ưu về độ tin cậy.

API WebSocket v1 - ngắt kết nối không mong muốn từ các nguồn cấp dữ liệu thị trường

Địa chỉ IP thay thế

Logic kết nối lại

Các kết nối dự phòng

Bạn cần thêm trợ giúp?