Native Websocket

Пример кода ниже:

//Включить WSMQL.mqh — файл со всеми объявлениями, необходимыми для взаимодействия с библиотекой
#include <WSMQL.mqh>
// Или импортировать объявления WebsocketClient.ex5
//#import "WebSocketClient.ex5"
//   WSHANDLE Initialize(void);
//   ENUM_WEBSOCKET_STATE ClientState(WSHANDLE handle);
//   void SetMaxSendSize(WSHANDLE handle, int max_send_size);
//   bool Connect(const WSHANDLE handle, const string url, const uint port = 443, const uint timeout = 5000, bool use_tls = true, ENUM_LOG_LEVEL log_level = LOG_LEVEL_ERROR);
//   bool Disconnect(WSHANDLE handle, ENUM_CLOSE_CODE close_code = NORMAL_CLOSE, const string msg = "");
//   int  SendString(WSHANDLE handle, const string message);
//   int  SendData(WSHANDLE handle, uchar& message_buffer[]);
//   int  SendPong(WSHANDLE handle, const string msg = "");
//   int  SendPing(WSHANDLE handle, const string msg);
//   uint ReadString(WSHANDLE handle, string& out);
//   uint ReadBinary(WSHANDLE handle, uchar& out[]);
//   uint ReadStrings(WSHANDLE handle, string& out[]);
//   uint OnReceiveString(WSHANDLE handle, OnMessage callback);
//   uint OnReceiveBinary(WSHANDLE handle, OnBinaryMessage callback);
//#import

//+------------------------------------------------------------------+
//| Script program start function                                    |
//+------------------------------------------------------------------+
void OnStart() {
  // дескриптор библиотеки можно получить с помощью метода инициализации, прежде чем использовать его в библиотечных методах.
   WSHANDLE handle = WebSocketClient::Initialize();
   if(handle == 0)
      return;

   string url = "stream.binance.com/ws";//Or wss://stream.binance.com/ws
   string msg = "{\"params\":[\"btcusdt@bookTicker\"],\"method\":\"SUBSCRIBE\",\"id\":27175}";

   //ВНИМАНИЕ: убедитесь, что stream.binance.com добавлен в список WebRequest в меню «Параметры» -> вкладка «Советники».
   if(!WebSocketClient::Connect(handle, url))
      return;

   WebSocketClient::SendString(handle, msg);

   while(true) {
      if(IsStopped())
         break;

      uint frames = WebSocketClient::OnReceiveString(handle, OnMessage);
      Print("Обработано кадров : ", frames);
   }
   Print("Отключение...");
   if(WebSocketClient::Disconnect(handle))
      Print("Отключено!");
}
//+------------------------------------------------------------------+
void OnMessage(string message) {
   Print(message);
}
//+------------------------------------------------------------------+
//Примеры выходных данных:
//{"result":null,"id":27175}
//Обработано кадров : 1
//---
//{"u":35893555769,"s":"BTCUSDT","b":"27812.78000000","B":"7.14299000","a":"27812.79000000","A":"0.81665000"}
//{"u":35893555770,"s":"BTCUSDT","b":"27812.78000000","B":"7.14299000","a":"27812.79000000","A":"0.82309000"}
//{"u":35893555771,"s":"BTCUSDT","b":"27812.78000000","B":"7.14964000","a":"27812.79000000","A":"0.82309000"}
//Обработано кадров : 3

Feel free to contact me for support and questions before/after purchase.

https://www.mql5.com/en/users/nikkirachael