MQTTFive — MQTT 5.0 클라이언트 라이브러리 - MetaTrader 5용 라이브러리

MQTTFive — MQL5용 MQTT 5.0 클라이언트

MetaTrader 5의 Expert Advisors 및 스크립트를 MQTT 브로커(Mosquitto, EMQX, HiveMQ)에 연결하기 위한 라이브러리(#include)입니다. 이를 통해 시세 및 신호를 게시하고, 외부 시스템으로부터 명령을 수신하며, Expert Advisors의 상태를 모니터링할 수 있습니다.

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