Type/to search

Pemacu Pemecut WebSocket

Template
Created: 2024-10-24 18:11:09
Last modified: 6 months ago
11
Follow
651
Followers

Kelas templat kelajuan data keadaan sebenar berasaskan WebSocket

huraikan:

Strategi ini mengoptimumkan pemprosesan data real-time di pelbagai bursa melalui sambungan WebSocket berbilang helai. Penggunaan sambungan WebSocket dalam platform perdagangan kuantitatif FMZ untuk mendapatkan buku pesanan dan data perdagangan yang mendalam, secara signifikan mengurangkan kelewatan untuk mendapatkan data pasaran, dan meningkatkan prestasi sistem perdagangan frekuensi tinggi.

Ciri-ciri Utama:

  • Sokongan pertukaran berbilangStrategi ini menyokong sambungan WebSocket ke beberapa bursa seperti Binance, OKX, Bybit, Bitget, dan lain-lain, memberikan aliran data yang lebih cepat dan lebih stabil daripada tinjauan API REST tradisional.
  • Langganan boleh disesuaikan: Membenarkan langganan saluran pasaran tertentu (seperti kedalaman, dagangan, dsb.) dan pemprosesan data yang diterima dengan cekap untuk kegunaan segera oleh strategi dagangan.
  • Pengendalian Ralat Lanjutan: Penjejakan ralat terbina dalam dan mekanisme penyambungan semula WebSocket untuk memastikan kebolehpercayaan dan kesinambungan aliran data.
  • Pemeriksaan CRC32Untuk bursa seperti OKX, integrasi CRC32 untuk memastikan integriti data buku pesanan yang diterima.

Penyelesaian berasaskan WebSocket ini menggantikan tinjauan API tradisional dan sesuai untuk peniaga yang perlu meminimumkan kelewatan dan memaksimumkan kelajuan tindak balas pasaran.

Arah:

  1. permulaan: guna$.setupWebsocket() Mulakan sambungan WebSocket ke pertukaran sasaran.
  2. langganan: Sistem akan secara automatik melanggan saluran yang berkaitan (seperti kedalaman, perdagangan, dll.) untuk produk yang anda berdagang.
  3. Pemerolehan Data: Dengan menelefonGetDepth() danGetTrades() Berfungsi, secara automatik menggunakan data masa nyata WebSocket untuk mengembalikan kedalaman pasaran dan rekod transaksi.
  4. Ralat pengendalian: Dasar ini termasuk mekanisme penjejakan yang merekodkan ralat sambungan dan data dan secara automatik cuba menyambung semula jika sambungan terputus.

Skrip ini direka untuk berjalan di platform kuantitatif FMZ, yang menyediakan akses data pasaran yang cepat, boleh dipercayai dan boleh diperluaskan untuk pelbagai bursa.

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

$.setupWebsocket = function (main_exchanges) {
    let crc32 = function (r) {
        for (var a, o = [], c = 0; c < 256; c++) {
            a = c;
            for (var f = 0; f < 8; f++) a = 1 & a ? 3988292384 ^ a >>> 1 : a >>> 1;
            o[c] = a
        }
        for (var n = -1, t = 0; t < r.length; t++) n = n >>> 8 ^ o[255 & (n ^ r.charCodeAt(t))];
        return (-1 ^ n) >>> 0
    }
Comment
All comments (4)

    Warning: __Thread is deprecated. Please use threading.Thread instead.
    麻烦能否更新到threading.Thread的版本?

    6 months ago

    已更

    6 months ago

    大佬动作好快,能否加上获取K线的代码呢?感激不尽!

    6 months ago

    K线没有做websocket这个完全没必要最后一根闭合了才生效

    6 months ago
  • 1
iPhone Download
Forums
PINE Language
© 2015 - ∞ INVENTOR PTE LTD (SG)