基于WebSocket的实时行情数据加速模板类库

Mô tả：

Chiến lược này tối ưu hóa việc xử lý dữ liệu thời gian thực từ nhiều sàn giao dịch thông qua kết nối WebSocket đa luồng. Sử dụng kết nối WebSocket trên nền tảng giao dịch định lượng FMZ để lấy dữ liệu sổ lệnh độ sâu và giao dịch, giảm đáng kể độ trễ khi lấy dữ liệu thị trường và cải thiện hiệu suất của hệ thống giao dịch tần suất cao.

Đặc điểm chính：

• Hỗ trợ nhiều sàn：Chiến lược này hỗ trợ kết nối WebSocket với nhiều sàn giao dịch như Binance, OKX, Bybit, Bitget, cung cấp luồng dữ liệu nhanh hơn và ổn định hơn so với phương pháp polling API REST truyền thống.
• Đăng ký tùy chỉnh：Cho phép đăng ký các kênh thị trường cụ thể (ví dụ: độ sâu, giao dịch, v.v.) và xử lý hiệu quả dữ liệu nhận được để sử dụng ngay lập tức trong chiến lược giao dịch.
• Xử lý lỗi nâng cao：Tích hợp cơ chế theo dõi lỗi và kết nối lại WebSocket, đảm bảo độ tin cậy và liên tục của luồng dữ liệu.
• Kiểm tra CRC32：Đối với các sàn giao dịch như OKX, tích hợp chức năng kiểm tra CRC32 để đảm bảo tính toàn vẹn của dữ liệu sổ lệnh nhận được.

Giải pháp dựa trên WebSocket này thay thế phương pháp polling API truyền thống, phù hợp cho các nhà giao dịch cần giảm thiểu độ trễ và tối đa hóa tốc độ phản hồi thị trường.

Cách sử dụng：

1. Khởi tạo：Sử dụng $.setupWebsocket() để khởi tạo kết nối WebSocket với sàn giao dịch mục tiêu.
2. Đăng ký：Hệ thống sẽ tự động đăng ký các kênh liên quan (ví dụ: độ sâu, giao dịch, v.v.) cho các cặp giao dịch của bạn.
3. Lấy dữ liệu：Bằng cách gọi các hàm GetDepth() và GetTrades(), tự động sử dụng dữ liệu thời gian thực từ WebSocket để trả về độ sâu thị trường và lịch sử giao dịch.
4. Xử lý lỗi：Chiến lược bao gồm cơ chế theo dõi để ghi lại lỗi kết nối và dữ liệu, và tự động thử kết nối lại khi mất kết nối.

Script này được thiết kế để chạy trên nền tảng định lượng FMZ, cung cấp truy cập dữ liệu thị trường nhanh, đáng tin cậy và có thể mở rộng cho nhiều sàn giao dịch.

            javascript
            
            
function main() {
    $.setupWebsocket()
    while (true) {
        exchanges.map(e=>{
            Log(e.GetName(), e.GetDepth())
            Log(e.GetName(), e.GetTrades())
            // support custom and auto subscribe Eg: e.GetDepth('ETH_USDT')
        })
        EventLoop(100) // trigger by websocket or use Sleep control delay
    }
}