请问下作者，为什么我这边EA无法加载到MT4里面

[iizx]

如题

[huyuxuan-peter]

我在复现作者的项目的时候也出现了类似的问题然后我改了一些东西说不定可以帮助你

//+------------------------------------------------------------------+
//| ZeroMQ_MT4_EA_Template.mq4 |
//| Copyright 2017, Darwinex Labs |
//| https://www.darwinex.com/ |
//+------------------------------------------------------------------+
#property copyright "Copyright 2017, Darwinex Labs."
#property link "https://www.darwinex.com/"
#property version "1.00"
#property strict

// Required: MQL-ZMQ from https://github.com/dingmaotu/mql-zmq
#include <Zmq/Zmq.mqh>

extern string PROJECT_NAME = "DWX_ZeroMQ_Example";
extern string ZEROMQ_PROTOCOL = "tcp";
extern string HOSTNAME = "*";
extern int REP_PORT = 5555;
extern int PUSH_PORT = 5556;
extern int MILLISECOND_TIMER = 100; // 1 millisecond

extern string t0 = "--- Trading Parameters ---";
extern int MagicNumber = 123456;
extern int MaximumOrders = 1;
extern double MaximumLotSize = 0.01;
extern int Slippage = 3;
int Total, Ticket, Ticket2;
double StopLossLevel, TakeProfitLevel, StopLevel;

// CREATE ZeroMQ Context
Context context(PROJECT_NAME);

// CREATE ZMQ_REP SOCKET
Socket repSocket(context,ZMQ_REP);

// CREATE ZMQ_PUSH SOCKET
Socket pushSocket(context,ZMQ_PUSH);

// VARIABLES FOR LATER
uchar data[];
ZmqMsg request;

//+------------------------------------------------------------------+
//| Expert initialization function |
//+------------------------------------------------------------------+
int OnInit()
{
EventSetMillisecondTimer(MILLISECOND_TIMER);
Print("[REP] Binding MT4 Server to Socket on Port " + REP_PORT + "..");
Print("[PUSH] Binding MT4 Server to Socket on Port " + PUSH_PORT + "..");

repSocket.bind(StringFormat("%s://%s:%d", ZEROMQ_PROTOCOL, HOSTNAME, REP_PORT));
pushSocket.bind(StringFormat("%s://%s:%d", ZEROMQ_PROTOCOL, HOSTNAME, PUSH_PORT));

repSocket.setLinger(5000);
repSocket.setSendHighWaterMark(20);

return(INIT_SUCCEEDED);
}

//+------------------------------------------------------------------+
//| Expert deinitialization function |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
{
Print("[REP] Unbinding MT4 Server from Socket on Port " + REP_PORT + "..");
repSocket.unbind(StringFormat("%s://%s:%d", ZEROMQ_PROTOCOL, HOSTNAME, REP_PORT));

Print("[PUSH] Unbinding MT4 Server from Socket on Port " + PUSH_PORT + "..");
pushSocket.unbind(StringFormat("%s://%s:%d", ZEROMQ_PROTOCOL, HOSTNAME, PUSH_PORT));
}

//+------------------------------------------------------------------+
//| Expert timer function |
//+------------------------------------------------------------------+
void OnTimer()
{
repSocket.recv(request,true);
ZmqMsg reply = MessageHandler(request);
repSocket.send(reply);
}

//+------------------------------------------------------------------+
ZmqMsg MessageHandler(ZmqMsg &request) {
ZmqMsg reply;
string components[];

if(request.size() > 0) {
ArrayResize(data, request.size());
request.getData(data);
string dataStr = CharArrayToString(data);
ParseZmqMessage(dataStr, components);
InterpretZmqMessage(pushSocket, components);
ZmqMsg ret(StringFormat("[SERVER] Processing: %s", dataStr));
reply = ret;
}

return(reply);
}

void InterpretZmqMessage(Socket &pSocket, string& compArray[]) {
Print("ZMQ: Interpreting Message..");
int switch_action = 0;

if(compArray[0] == "TRADE" && compArray[1] == "OPEN")
switch_action = 1;
if(compArray[0] == "RATES")
switch_action = 2;
if(compArray[0] == "TRADE" && compArray[1] == "CLOSE")
switch_action = 3;
if(compArray[0] == "DATA")
switch_action = 4;

string ret = "";
int ticket = -1;
bool ans = FALSE;
double price_array[];
ArraySetAsSeries(price_array, true);
int price_count = 0;

switch(switch_action)
{
case 1:
if (compArray[2] == "0") {
StopLossLevel = Ask - StrToDouble(compArray[4]) * Point;
TakeProfitLevel = Ask + StrToDouble(compArray[5]) * Point;
Ticket= OrderSend(compArray[3], OP_BUY, MaximumLotSize, Ask, Slippage, StopLossLevel,TakeProfitLevel, "Buy(#" + MagicNumber + ")", MagicNumber, 0, DodgerBlue);
if(Ticket > 0 && OrderSelect(Ticket, SELECT_BY_TICKET, MODE_TRADES)) {
Print("BUY order opened : ", OrderOpenPrice());
InformPullClient(pSocket, "OrderSend placed successfully");
} else {
InformPullClient(pSocket, "OrderSend failed");
Print("Error opening BUY order : ", GetLastError());
}
}
if (compArray[2] == "1") {
StopLossLevel = Bid + StrToDouble(compArray[4]) * Point;
TakeProfitLevel = Bid - StrToDouble(compArray[5]) * Point;
Ticket= OrderSend(compArray[3], OP_SELL, MaximumLotSize, Bid, Slippage, StopLossLevel,TakeProfitLevel, "Sell(#" + MagicNumber + ")", MagicNumber, 0, DodgerBlue);
if(Ticket > 0 && OrderSelect(Ticket, SELECT_BY_TICKET, MODE_TRADES)) {
Print("SELL order opened : ", OrderOpenPrice());
InformPullClient(pSocket, "OrderSend placed successfully");
} else {
InformPullClient(pSocket, "OrderSend failed");
Print("Error opening SELL order : ", GetLastError());
}
}
break;

  case 2: 
     ret = "N/A"; 
     if(ArraySize(compArray) > 1) 
        ret = GetBidAsk(compArray[1]); 
     InformPullClient(pSocket, ret); 
     break;

  case 3:
     if (compArray[2] == "0") {
        OrderSelect(Ticket, SELECT_BY_TICKET, MODE_TRADES);
        Ticket2=OrderClose(OrderTicket(), OrderLots(), Bid, Slippage, MediumSeaGreen);
        ret = StringFormat("Trade Closed (Ticket: %d)", ticket);
        InformPullClient(pSocket, ret);
     }
     if (compArray[2] == "1") {
        OrderSelect(Ticket, SELECT_BY_TICKET, MODE_TRADES);
        Ticket2 = OrderClose(OrderTicket(), OrderLots(), Ask, Slippage, DarkOrange);
     }
     break;

  case 4:
     price_count = CopyClose(compArray[1], StrToInteger(compArray[2]), 
                    StrToInteger(compArray[3]), StrToInteger(compArray[4]), 
                    price_array);
     if (price_count > 0) {
        ret = compArray[1] + "|" + DoubleToStr(price_array[0], 5);
        for(int i = 1; i < price_count; i++) {
           ret = ret + "|" + DoubleToStr(price_array[i], 5);
        }
        Print("Sending: " + ret);
        InformPullClient(pSocket, ret);
     }
     break;

}
}

void ParseZmqMessage(string& message, string& retArray[]) {
Print("Parsing: " + message);
string sep = "|";
ushort u_sep = StringGetCharacter(sep,0);
int splits = StringSplit(message, u_sep, retArray);
for(int i = 0; i < splits; i++) {
Print(i + ") " + retArray[i]);
}
}

string GetBidAsk(string symbol) {
double bid = MarketInfo(symbol, MODE_BID);
double ask = MarketInfo(symbol, MODE_ASK);
return(StringFormat("%f|%f", bid, ask));
}

void InformPullClient(Socket& pushSocket, string message) {
ZmqMsg pushReply(StringFormat("%s", message));
pushSocket.send(pushReply,true);
}