Pantau beberapa node komunikasi terenkripsi.js/ccxt online melalui perpustakaan beragampengetahuan – Lainnya – 5 Juli 2025 – Beragampengetahuan

CCXTAPPSERVERLIB Dirancang untuk menggunakan semua pertukaran 100 cryptocurrency teratas dari beragampengetahuan melalui Node.js dan server aplikasi CCXT dan secara bertahap berkembang. Beta-versi terbaru mencakup cache “pasar” yang dioptimalkan (spesifikasi instrumen dan kondisi transaksi lainnya), pembacaan pesan websocket yang tidak memblokir, dan banyak lagi.

Contoh pengantar menggunakan perpustakaan – naskah Ccxtappsrvshowcase.mq5 – Diposting sebelumnya di blog.

Sebagai contoh lain dari pengembangan aplikasi kustom menggunakan pustaka, kami menyediakan skrip untuk memantau beberapa pertukaran jenis data jenis yang dipilih secara paralel. Dengan berlangganan Websocket tertentu melalui CCXT di Node.js, mis. WatchOrderbook,,,,, Pengintai,,,,, Perhatikan perdagangandll. Untuk informasi lebih lanjut, lihat dokumentasi CCXT umum di CCXT Pro dan lebih maju di CCXT Pro. Karena skrip hanya boleh menggunakan API publik, kredensial pengguna tidak terlibat di sini, tetapi perpustakaan dapat mendukung semuanya.

Pertama, sertakan judulnya.

#include "ccxtjsmtlib.mqh" 
#include "ccxtutil.mqh"
#include <MQL5Book/Comments.mqh>

Dalam input, pengaturan server node harus dibuat.

input group "Connection settings"
input string NodeServer = "http://127.0.0.1:8124";
input string NodeAuth = ""; 

Untuk mengisi input ini dengan benar dengan nilai yang disukai, Anda mungkin perlu mengeluarkan daftar pertukaran yang didukung dan pasar mereka di muka. Dapat dilihat dalam skrip contoh lain Ccxtappsrvshowcase.mq5dengan kebebasan.

input string Exchanges = "ascendex,bitmart,binance"; 
input string Ticker = "BCH/USDT";
input string Watch = "watchOrderBook";
input uint WatchingDuration = 10; 

Kemudian Mulai Penangan aktivitas menyelesaikan pekerjaan. Komentar inline menjelaskan prosesnya. Fungsi impor, kelas, dan metode dari perpustakaan disorot dengan warna kuning.

string Exchange[];

void OnStart()
{
   
   
   
   PrintFormat("CCXT AppSrvLibrary version: %.2f", AppSrvLibraryVersion());
   const static string status[] = "Can't deploy",
      "App server ZIP is deployed, but not extracted",
      "App server files are deployed";
   const int d = DeployCcxtAppServer();
   Print(status[d + 1]);
   if(d <= 0)
   
      return; 
   
   
   
   
   
   SetNodeServer(NodeServer, NodeAuth);

   CcxtLink *link = GetLink();
   
   
   

   
   
   AutoPtr<CcxtJsExchangeProIntf> ccxt[];
   const int n = StringSplit(Exchanges, ',', Exchange);
   ArrayResize(ccxt, n);
   
   for(int i = 0; i < n; i++)
    !ccxt[i][] 
   
   
   
   int active = 0;
   
   for(int i = 0; i < n; i++)
   
      
      if(ccxt[i][].upgrade())
      
         if(!ccxt[i][].watchAnything(StringFormat("%s(\"%s\")", Watch, Ticker)))
         
            PrintFormat("Can't start %s for %s", Watch, Exchange[i]);
            ccxt[i][].close(); 
            ccxt[i] = NULL;
         
         else
         
            active++;
         
      
      else
      
         if(ccxt[i][].isConnected())
         
            Print("Can't upgrade to websockets");
            string headers[][2];
            if(ccxt[i][].ws().getHeaders(headers))
            
               
            
            ccxt[i][].ws().close(); 
            ccxt[i][].close();
            ccxt[i] = NULL;
         
      
   
   
   if(!active) return;

   
   PrintFormat("* Monitoring %d subscriptions", active);

   const uint start = GetTickCount();
   while(!IsStopped() && (!WatchingDuration || GetTickCount() - start < WatchingDuration * 1000))
   
      for(int i = 0; i < n; i++)
      
         if(ccxt[i][] && ccxt[i][].isConnected())
         
            AutoPtr<JsValue> j = ccxt[i][].readMessage(false); 
            if(j[])
            
               ChronoComment(j[].stringify(0, 0)); 
            
         
      
   
  
   Print("* Unsubscribing...");
   for(int i = 0; i < n; i++)
   
      if(ccxt[i][] && ccxt[i][].isConnected())
      
         ccxt[i][].un().watchAnything(StringFormat("%s(\"%s\")", Watch, Ticker));
      
   
   
   
   GracefullClose(ccxt); // not presented here in the blog

   
   
   GracefullClose(ccxt, 5, true);
   
   Comment("");
}