MQTTFive — MQTT 5.0 クライアントライブラリ - MetaTrader 5のためのライブラリ

MQTTFive — MQL5用MQTT 5.0クライアント

MetaTrader 5のエキスパートアドバイザーやスクリプトをMQTTブローカー（Mosquitto、EMQX、HiveMQ）に接続するためのライブラリ（#include）です。これを使用すると、価格やシグナルを配信したり、外部システムからのコマンドを受信したり、エキスパートアドバイザーの状態を監視したりすることができます。

DLL不要— 純粋なMQL5、独自のソケットAPI。MQTT v5.0プロトコル。

機能

• QoS 0、1、2（送信されなかったメッセージの自動再送信機能付き）
• CONNECT/CONNACKのプロパティ：セッションの有効期間、受信可能なパケットの最大数、トピックエイリアスの最大数。
• 配信遅延付きメッセージ
• トピックのエイリアス — 重複するトピックによるトラフィックを低減。
• フロー制御 — 受信データ量の最大クォータの管理。
• 購読オプション：no_local、retain_as_published、retain_handling
• TLS/SSL、バイナリペイロード、UTF-8

インストール

1. アーカイブ内の5つのファイルをMQL5/Include/MQTTFive/フォルダにコピーしてください。
2. コード内：#include <MQTTFive/MQTTClient.mqh>

例 - 価格のパブリッシュ

#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();
     }
  }

例 - シグナルの購読

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;
  }

主なメソッド

要件

• MetaTrader 5 (ビルド 3390 以上)
• MQTT 5.0 ブローカー (Mosquitto >= 5.0、EMQX、HiveMQ)

ドキュメント: github.com/chekh/MQTTFive

ライセンス： MIT