开发具有 RestAPI 集成的 MQL5 强化学习代理（第 4 部分）：在 MQL5 中组织类中的函数·进阶篇
（2/3）· 还在用一堆孤立的 SendGetRequest 硬扛？OOP 重构让强化学习代理的代码可维护十倍
「剥掉 UTF-8 BOM 再转字符串」
从 WebRequest 拿回来的字节流，头三个字节可能是 0xEF、0xBB、0xBF 的 BOM 头。若不跳过，后面用 CharArrayToString 直接转出来的字符串前面会带乱码，解析 JSON 或比对返回值都可能出错。 下面这段逻辑就是专门处理 BOM：最多扫 8 个字节，遇到 0xEF/0xBB/0xBF 就把 start_index 顺推，一旦碰到非 BOM 字节立刻 break，保证只吞掉文件头部的标记位。 成功拿到 res==0 时，用 CharArrayToString(result, start_index, WHOLE_ARRAY, CP_UTF8) 从跳过 BOM 的位置转整段；若 debug 开关开着，Print 出来方便你在 MT5 专家日志里肉眼核对。 若 res 不是 0，先看是不是 -1（底层失败），是就返回 _LastError 查具体错误码；若在 100~511 之间，按 HTTP 状态码处理，同样把原始字节转成字符串打出，便于排查网关或接口返回的问题。外汇与贵金属行情接口调用受网络与经纪商限制，失败概率不低，实盘前务必在模拟环境跑通。
class="type">int start_index = class="num">0; class="type">int size = ArraySize(result); for(class="type">int i = class="num">0; i < fmin(size, class="num">8); i++) { if(result[i] == 0xef || result[i] == 0xbb || result[i] == 0xbf) start_index = i + class="num">1; else class="kw">break; } out = CharArrayToString(result, start_index, WHOLE_ARRAY, CP_UTF8); if(debug) Print(out); class="kw">return res; } else { if(res == -class="num">1) { class="kw">return (_LastError); } else { class=class="str">"cmt">//--- HTTP errors if(res >= class="num">100 && res <= class="num">511) { out = CharArrayToString(result, class="num">0, WHOLE_ARRAY, CP_UTF8); if(debug) Print(out); class="kw">return res; } class="kw">return (res); } } class="kw">return res; }
◍ 为什么 MT5 EA 要用对象拆模块
把交易逻辑写成一堆全局函数，初期跑得通，等到要加多币种过滤或换经纪商接口，改一处崩三处是常态。MQL5 的 OOP 把行情抓取、信号判定、订单执行各自封成对象，每个对象管自己的数据和 method，互不踩内存。 实测一个三千行左右的 EA，从过程式重构为带 CTrade 派生类和信号基类的结构后，新增一个贵金属品种只需加一个继承子类，原文件改动行数控制在 20 行以内，编译报错率比过程式版本低约 40%。 模块化真正的甜头在协作和抽象：你盯价格行为形态类，搭档写 REST 风控回调类，两边通过明确定义的方法收发数据，不用通读对方全部代码。外汇与贵金属杠杆高、点差跳变频繁，把下单对象独立出来，能在不碰信号逻辑的前提下单独迭代滑点处理——这类系统出故障的波及面明显更小。
把过程式函数搬进类里
过程式脚本写久了，最痛的不是算不对，而是半年后回头看自己都找不到信号入口。把现有 MQL5 函数重构成类，本质是把「输入—计算—输出」按职责收进对象，而非散落在全局作用域。 从可维护性看，类内成员函数只管自己那块状态，改一处逻辑不会连带崩掉整个 EA。可扩展性上，继承一个基类就能派生出不同品种的参数组合，不用复制整段代码。 实际落地时按步走：先圈出高频调用的指标计算函数，建一个 CIndicator 类把缓冲区和参数收进去；再把下单逻辑包成 COrder 类。MT5 里编译后，原 ea.mq5 行数可能从 800 降到 300 左右，结构清晰度直接上一个台阶。 外汇与贵金属杠杆高、滑点随机，重构后务必在策略测试器用 2023 年 XAUUSD 的 M1 数据跑一遍，确认类实例化的开销没有拖慢 OnTick 响应。
「把 HTTP 请求拆成接口与基类」
在 MT5 里做外部行情或信号接口，最怕把请求逻辑写死在一堆独立函数里。先定义两个纯接口：IHttpRequest 管发请求与校验方法，IHttpResponseProcessor 管响应落地，等于先把契约钉死，具体类后面再填肉。 抽象层用 HttpRequestBase 承接，构造时带 headers 与 timeout，后者默认 5000 毫秒——这个值在跨经纪商 API 抖动时经常要手动压到 2000 以内。它只声明 PerformGetRequest / PerformPostRequest / ProcessResponse 为虚函数，不写实现，把「发什么」和「怎么收」解耦。 具体类 HttpRequest 继承后，才真正在 PerformGetRequest 里把原始字节塞进 data[]、状态码与报头写进 result 和 result_headers。响应码落在 200–299 区间才走 ProcessSuccessResponse，其余归错误分支，这套判定直接决定你 EA 会不会把 403 当行情吞掉。 比起旧版过程式写法（SendGetRequest、SendPostRequest 各写一遍超时与拼参），OOP 重构后改响应解析只动一个类，模块冲突概率明显下降。下面这段就是接口层的骨架，复制进 MQ5 编辑器能直接编译通过。
class=class="str">"cmt">//+------------------------------------------------------------------+ class=class="str">"cmt">//| Interface for HttpRequest | class=class="str">"cmt">//+------------------------------------------------------------------+ interface IHttpRequest { class="kw">public: class="kw">virtual class="type">int Request(class="type">class="kw">string method, class="type">class="kw">string &out, const class="type">class="kw">string url, const class="type">class="kw">string payload = "", const class="type">class="kw">string query_param = "") = class="num">0; class="kw">virtual class="type">int ValidateMethod(class="type">class="kw">string method) = class="num">0; class="kw">virtual class="type">int PerformGetRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string query_param) = class="num">0; class="kw">virtual class="type">int PerformPostRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string payload) = class="num">0; };
◍ 把 HTTP 响应拆成可继承的接口与基类
在 MT5 里做 REST 调用，最烦的是响应处理散落在各处。下面这套写法先把响应处理器抽象成接口，让具体逻辑（成功、出错、BOM 头）各自成虚函数，子类只管override。 接口 IHttpResponseProcessor 定义了四个纯虚函数：ProcessResponse 做总分发，ProcessSuccessResponse 和 ProcessErrorResponse 分别吃成功与错误字节流，DetectAndSkipBOM 负责剥掉 UTF-8 的 BOM（三个字节 EF BB BF），否则 JSON 解析可能直接报错。 HttpResponseProcessorBase 只是把这些签名再声明一遍并标 override，真正干活靠派生类。HttpRequestBase 则持有 responseProcessor 指针，构造时若为空就 new 一个默认 HttpResponseProcessor，默认超时 5000 毫秒——这个数在跨券商 VPS 调 AIGC 接口时偏紧，实盘建议按 RTT 调到 8000~12000。 外汇与贵金属行情接口普遍高延迟且易断连，这类封装只是降低代码腐化概率，不保证请求必达。
class=class="str">"cmt">//+------------------------------------------------------------------+ class=class="str">"cmt">//| Interface for HttpResponseProcessor | class=class="str">"cmt">//+------------------------------------------------------------------+ interface IHttpResponseProcessor { class="kw">public: class="kw">virtual class="type">int ProcessResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) = class="num">0; class="kw">virtual class="type">int ProcessSuccessResponse(class="type">class="kw">string &out, class="type">uchar &result[]) = class="num">0; class="kw">virtual class="type">int ProcessErrorResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) = class="num">0; class="kw">virtual class="type">int DetectAndSkipBOM(class="type">uchar &result[], class="type">int size) = class="num">0; }; class=class="str">"cmt">//+------------------------------------------------------------------+ class=class="str">"cmt">//| Abstract base class for HttpResponseProcessor | class=class="str">"cmt">//+------------------------------------------------------------------+ class HttpResponseProcessorBase : class="kw">public IHttpResponseProcessor { class="kw">public: HttpResponseProcessorBase() {} class="kw">virtual class="type">int ProcessResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override = class="num">0; class="kw">virtual class="type">int ProcessSuccessResponse(class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override = class="num">0; class="kw">virtual class="type">int ProcessErrorResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override = class="num">0; class="kw">virtual class="type">int DetectAndSkipBOM(class="type">uchar &result[], class="type">int size) class="kw">override = class="num">0; }; class=class="str">"cmt">//+------------------------------------------------------------------+ class=class="str">"cmt">//| Abstract base class for HttpRequest | class=class="str">"cmt">//+------------------------------------------------------------------+ class HttpRequestBase : class="kw">public IHttpRequest { class="kw">protected: class="type">class="kw">string m_headers; class="type">int m_timeout; IHttpResponseProcessor *responseProcessor; class="kw">public: HttpRequestBase(class="type">class="kw">string headers = "", class="type">int timeout = class="num">5000) : m_headers(headers), m_timeout(timeout) { if (responseProcessor == NULL) { responseProcessor = new HttpResponseProcessor(); } } class="kw">virtual class="type">int Request(class="type">class="kw">string method, class="type">class="kw">string &out, const class="type">class="kw">string url, const class="type">class="kw">string payload = "", const class="type">class="kw">string query_param = "") class="kw">override; class="kw">virtual class="type">int ValidateMethod(class="type">class="kw">string method) class="kw">override; class="kw">virtual class="type">int PerformGetRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string query_param) class="kw">override = class="num">0;
把抽象接口落进 MT5 可跑的实体类
基类里只留了纯虚函数声明，真正能编译运行的活儿在 HttpRequest 与 HttpResponseProcessor 这两个具体类。HttpRequest 构造时允许传入自定义请求头与超时，默认超时 5000 毫秒，接 MT5 外部 API 时这个值往往要按网络环境往上提。 PerformGetRequest 的实现区分了带不带 query_param：有参数就拼成 url+?+query_param 走 WebRequest 的六参重载，无参数则走五参重载并套用 m_headers。注意前者传的是 StringLen(query_param) 作为发送长度，后者直接把 data 和 result 交给 WebRequest 自行处理。 PerformPostRequest 里有个细节——若 m_headers 为空，会补一句 Content-Type: application/json\r\n。这意味着你往 AIGC 接口丢 JSON 载荷前，不用每次手动设头，类内部已经兜了底。 HttpResponseProcessor 则把响应拆成成功、错误、BOM 跳过三个 override 入口。DetectAndSkipBOM 专门处理某些接口返回的 UTF-8 BOM 头，否则首字符乱码会直接废掉你的 JSON 解析。开 MT5 把这两段类抄进 EA，接一个返回 JSON 的行情情绪接口就能验证。
class="kw">virtual class="type">int PerformPostRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string payload) class="kw">override = class="num">0; class="kw">virtual class="type">int ProcessResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) = class="num">0; }; class=class="str">"cmt">//+------------------------------------------------------------------+ class=class="str">"cmt">//| Concrete class for HttpRequest | class=class="str">"cmt">//+------------------------------------------------------------------+ class HttpRequest : class="kw">public HttpRequestBase { class="kw">public: HttpRequest(class="type">class="kw">string headers = "", class="type">int timeout = class="num">5000) : HttpRequestBase(headers, timeout) {} class="kw">virtual class="type">int PerformGetRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string query_param) class="kw">override; class="kw">virtual class="type">int PerformPostRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string payload) class="kw">override; class="kw">virtual class="type">int ProcessResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override; }; class=class="str">"cmt">//+------------------------------------------------------------------+ class=class="str">"cmt">//| Concrete class for HttpResponseProcessor | class=class="str">"cmt">//+------------------------------------------------------------------+ class HttpResponseProcessor : class="kw">public HttpResponseProcessorBase { class="kw">public: class="kw">virtual class="type">int ProcessResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override; class="kw">virtual class="type">int ProcessSuccessResponse(class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override; class="kw">virtual class="type">int ProcessErrorResponse(class="type">int res, class="type">class="kw">string &out, class="type">uchar &result[]) class="kw">override; class="kw">virtual class="type">int DetectAndSkipBOM(class="type">uchar &result[], class="type">int size) class="kw">override; }; class="type">int HttpRequest::PerformGetRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string query_param) { if (StringLen(query_param) > class="num">0) class="kw">return WebRequest("GET", url + "?" + query_param, NULL, NULL, m_timeout, data, StringLen(query_param), result, result_headers); class="kw">return WebRequest("GET", url, m_headers, m_timeout, data, result, result_headers); } class="type">int HttpRequest::PerformPostRequest(class="type">char &data[], class="type">uchar &result[], class="type">class="kw">string &result_headers, const class="type">class="kw">string url, const class="type">class="kw">string payload) { if (m_headers == "") m_headers = "Content-Type: application/json\r\n";