MQTTFive — MQTT 5.0 İstemci Kütüphanesi - MetaTrader 5 için kütüphane

MQTTFive — MQL5 için MQTT 5.0 istemcisi

MetaTrader 5 danışmanlarını ve komut dosyalarını MQTT brokerlerine (Mosquitto, EMQX, HiveMQ) bağlamak için kullanılan kütüphane (#include). Bu kütüphane, fiyatları ve sinyalleri yayınlamaya, harici sistemlerden komutlar almaya ve danışmanların durumunu izlemeye olanak tanır.

DLL içermez — saf MQL5, özel soket API'si. MQTT v5.0 protokolü.

Özellikler

• QoS 0, 1, 2 ile gönderilemeyen mesajların otomatik olarak tekrarlanması
• CONNECT/CONNACK özellikleri: oturum süresi, kabul edilen maksimum paket sayısı, maksimum tema takma adı sayısı.
• Yayın gecikmeli mesajlar
• Konu takma adları – yinelenen konularda trafik azaltma.
• Akış yönetimi — alınabilecek maksimum veri hacmi kotasının hesaplanması.
• Abonelik seçenekleri: no_local, retain_as_published, retain_handling
• TLS/SSL, ikili yük, UTF-8

Kurulum

1. Arşivdeki 5 dosyayı MQL5/Include/MQTTFive/ klasörüne kopyalayın
2. Kodda: #include <MQTTFive/MQTTClient.mqh>

Örnek - fiyat yayınlama

#include <MQTTFive/MQTTClient.mqh>

void OnStart ()
  {
   MQTTClient client;
   MQTTConnectParams params;
   params.Init();
   params.client_id = "price_pub" ;

   if (client.Connect( "127.0.0.1" , 1883 , params))
     {
       double bid = SymbolInfoDouble ( _Symbol , SYMBOL_BID );
      client.Publish( "mt5/price/" + _Symbol , DoubleToString (bid, _Digits ), 0 );
      client.Disconnect();
     }
  }

Örnek - Sinyallere abone olma

MQTTClient *mqtt;

void OnSignal( string &topic, uchar &payload[], uint payload_len)
  {
   string msg = CharArrayToString (payload, 0 , ( int )payload_len, CP_UTF8 );
   Print ( "Signal: " , topic, " = " , msg);
  }

void OnStart ()
  {
   mqtt = new MQTTClient();
   mqtt.SetCallback(OnSignal);
   MQTTConnectParams params;
   params.Init();
   params.client_id = "signal_sub" ;
   mqtt.Connect( "127.0.0.1" , 1883 , params);
   mqtt.Subscribe( "trade/signal/#" , 1 );
   while (! IsStopped ())
     {
      mqtt.Loop();
       Sleep ( 100 );
     }
   mqtt.Disconnect();
   delete mqtt;
  }

Temel yöntemler

Gereksinimler

• MetaTrader 5 (3390+ sürümü)
• MQTT 5.0 brokerı (Mosquitto >= 5.0, EMQX, HiveMQ)

Belgeler: github.com/chekh/MQTTFive

Lisans: MIT