1. 当然，我们需要导出价格跳动，最好是使用自有结构 MqlTick；
2. 最好知道当前导出的交易品种列表。

我们开始吧...

1. 通用类和契约

    [StructLayout(LayoutKind.Sequential)]
    [DataContract]
    public struct MqlTick
    {
        [DataMember] 
        public Int64 Time { get; set; }
        [DataMember]
        public Double Bid { get; set; }
        [DataMember]
        public Double Ask { get; set; }
        [DataMember]
        public Double Last { get; set; }
        [DataMember]
        public UInt64 Volume { get; set; }
    
}

    [ServiceContract(CallbackContract = typeof(IExportClient))]
    public interface IExportService
    {
        [OperationContract]
        void Subscribe();

        [OperationContract]
        void Unsubscribe();

        [OperationContract]
        String[] GetActiveSymbols();
    
}

    [ServiceContract]
    public interface IExportClient
    {
        [OperationContract(IsOneWay = true)]
        void SendTick(String symbol, MqlTick tick);

        [OperationContract(IsOneWay = true)]
        void ReportSymbolsChanged();
    
}

让我们通过服务器契约实施为服务创建名为 Qexport.Service.dll 的新的结构。

    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single,
        ConcurrencyMode = ConcurrencyMode.Multiple,
        UseSynchronizationContext = false,
        IncludeExceptionDetailInFaults = true)]
    public class ExportService : IExportService, IDisposable
    {

        public void Open()
        {
            _ExportHost = new ServiceHost(this);

            // 服务节点
            _ExportHost.AddServiceEndpoint(typeof(IExportService),  // 协议
                new NetNamedPipeBinding(),                          // 绑定
                new Uri(_ServiceAddress));                          // 地址

            // 去除队列16个请求的限制
            ServiceThrottlingBehavior bhvThrot = new ServiceThrottlingBehavior();
            bhvThrot.MaxConcurrentCalls = Int32.MaxValue;
            _ExportHost.Description.Behaviors.Add(bhvThrot);

            _ExportHost.Open();
        
}

        public void Close()
        {
            Dispose(true);
        
}
       
        private void Dispose(bool disposing)
        {
            try
            {
                // 关闭每个客户端的通道
                // ...

                // 关闭主机
                _ExportHost.Close();
            
}
            finally
            {
                _ExportHost = null;
            
}

            // ...
        
}

接下来，是 IExportService 方法的实施：

        public void Subscribe()
        {
            // 获取回调通道
            IExportClient cl = OperationContext.Current.GetCallbackChannel<IExportClient>();
            lock (lockClients)
                _Clients.Add(cl);
        
}

        public void Unsubscribe()
        {
            // 获取回调通道
            IExportClient cl = OperationContext.Current.GetCallbackChannel<IExportClient>();
            lock (lockClients)
                _Clients.Remove(cl);
        
}

        public String[] GetActiveSymbols()
        {
            return _ActiveSymbols.ToArray();
        
}

现在，我们需要添加发送价格跳动和注册及删除导出交易品种的方法。

     public void RegisterSymbol(String symbol)
        {
            if (!_ActiveSymbols.Contains(symbol))
                _ActiveSymbols.Add(symbol);

              // 向所有客户端发送激活的交易品种改变的通知
              //...
        
}

        public void UnregisterSymbol(String symbol)
        {
            _ActiveSymbols.Remove(symbol);

             // 向所有客户端发送激活的交易品种改变的通知
             //...
        
}

        public void SendTick(String symbol, MqlTick tick)
        {
            lock (lockClients)
                for (int i = 0; i < _Clients.Count; i++)
                    try
                    {
                        _Clients[i].SendTick(symbol, tick);
                    
}
                    catch (CommunicationException)
                    {
                        // 客户端连接已经丢失-移除客户端
                        _Clients.RemoveAt(i);
                        i--;
                    
}
        
}

我们总结了主要服务器函数列表，如下所示（仅限我们需要的函数）：

3. 客户端实施

我认为我们已经对服务器进行了充分的讨论，接下来是时候考虑客户端了。让我们来构建 Qexport.Client.dll。客户端契约将在此实施。首先，应使用定义其行为的 CallbackBehavior 属性对其加以标记。它具有以下修饰符：

对我而言，衡量两个 .NET 应用程序间的传送速度十分有趣；事实上，它的吞吐量通过每秒价格跳动次数衡量。我编写了几个控制台应用程序来衡量服务性能：第一个应用程序用于服务器，另外一个用于客户端。我在服务器的 Main() 函数中添加了以下代码：

            ExportService host = new ExportService("mt5");
            host.Open();

            Console.WriteLine("Press any key to begin tick export");
            Console.ReadKey();

            int total = 0;

            Stopwatch sw = new Stopwatch();

            for (int c = 0; c < 10; c++)
            {
                int counter = 0;
                sw.Reset();
                sw.Start();

                while (sw.ElapsedMilliseconds < 1000)
                {
                    for (int i = 0; i < 100; i++)
                    {
                        MqlTick tick = new MqlTick { Time = 640000, Bid = 1.2345 };
                        host.SendTick("GBPUSD", tick);
                    
}
                    counter++;
                
}

                sw.Stop();
                total += counter * 100;

                Console.WriteLine("{0} ticks per second", counter * 100);
            
}

            Console.WriteLine("Average {0:F2} ticks per second", total / 10);
            
            host.Close();

5. 创建“层次”

现在，是时候考虑如何将其连接至客户端了。我们来看一下在 MetaTrader 5 中第一次调用函数的情形：.NET 运行环境 (CLR) 加载至进程，应用程序域默认创建。有趣的是，CLR 在代码执行后并未卸载。

从进程卸载 CLR 的唯一方法是将其终止（关闭客户端），这将迫使 Windows 清除所有进程资源。因此，我们可以创建我们的对象，这些对象将一直存在，直到它们被“垃圾回收器”销毁或应用程序域卸载。

您可以说这看上去不错，但即使我们防止对象被“垃圾回收器”销毁，我们也无法从 MQL5 访问对象。幸运的是，这样的访问可以轻松实现。诀窍如下：对应于每个应用程序域都存在一个“垃圾回收器”句柄表（GC 句柄表），应用程序使用该表来追踪对象的使用期以及手动控制对象。

应用程序通过使用类型System.Runtime.InteropServices.GCHandle 从表中添加和删除元素。我们要做的就是使用这样的描述符包装我们的对象，并且我们可以通过属性 GCHandle.Target 对其进行访问。因此，我们可以获得对对象 GCHandle 的引用，该对象位于句柄表中并保证不会被“垃圾回收器”移动或删除。由于通过描述符引用，包装的对象还会避免回收。

现在到了我们实践检验理论时候了。为此，我们创建一个名为 QExpertWrapper.dll 的新 win32 dll，并将 CLR 支持、System.dll、QExport.dll、Qexport.Service.dll 添加至结构引用。我们还需要创建一个辅助类 ServiceManaged 用于管理 - 执行编组，通过句柄等接收对象。

ref class ServiceManaged
{
        public:
                static IntPtr CreateExportService(String^);
                static void DestroyExportService(IntPtr);
                static void RegisterSymbol(IntPtr, String^);
                static void UnregisterSymbol(IntPtr, String^);
                static void SendTick(IntPtr, String^, IntPtr);
};

让我们来看一看这些方法的实施。CreateExportService 方法创建服务，通过使用 GCHandle.Alloc 将其包装在 GCHandle 中并返回其引用。如果出现故障，将显示出错的 MessageBox 。我将它用于调试，我不确定是不是真有必要，将它留在这里是为了以防万一。

IntPtr ServiceManaged::CreateExportService(String^ serverName)
{
        try
        {
                ExportService^ service = gcnew ExportService(serverName);
                service->Open();
        
                GCHandle handle = GCHandle::Alloc(service);
                return GCHandle::ToIntPtr(handle);
        
}
        catch (Exception^ ex)
        {
                MessageBox::Show(ex->Message, "CreateExportService");
        
}

}

DestroyExportService 方法获得指向服务的 GCHandle 的指针，从目标属性获得服务并调用其方法 Close()。通过调用其方法 Free() 来释放服务对象是很重要的。否则它将留在内存中，“垃圾回收器”不会删除它。

void ServiceManaged::DestroyExportService(IntPtr hService)
{
        try
        {
                GCHandle handle = GCHandle::FromIntPtr(hService);

                ExportService^ service = (ExportService^)handle.Target;
                service->Close();

                handle.Free();
        
}
        catch (Exception^ ex)
        {
                MessageBox::Show(ex->Message, "DestroyExportService");
        
}

}

RegisterSymbol 方法将交易品种添加至导出交易品种列表：

void ServiceManaged::RegisterSymbol(IntPtr hService, String^ symbol)
{
        try
        {
                GCHandle handle = GCHandle::FromIntPtr(hService);
                ExportService^ service = (ExportService^)handle.Target;

                service->RegisterSymbol(symbol);
        
}
        catch (Exception^ ex)
        {
                MessageBox::Show(ex->Message, "RegisterSymbol");
        
}

}

UnregisterSymbol 方法从交易品种列表删除交易品种：

void ServiceManaged::UnregisterSymbol(IntPtr hService, String^ symbol)
{
        try
        {
                GCHandle handle = GCHandle::FromIntPtr(hService);
                ExportService^ service = (ExportService^)handle.Target;

                service->UnregisterSymbol(symbol);
        
}
        catch (Exception^ ex)
        {
                MessageBox::Show(ex->Message, "UnregisterSymbol");
        
}

}

接下来是 SendTick 方法。我们可以看到，指针通过 Marshal 类转换成 MqlTick 结构。另一要点：catch 代码块中没有任何代码 - 这样做是为了在发生错误时避免一般价格跳动队列的滞后。

void ServiceManaged::SendTick(IntPtr hService, String^ symbol, IntPtr hTick)
{
        try
        {
                GCHandle handle = GCHandle::FromIntPtr(hService);
                ExportService^ service = (ExportService^)handle.Target;
        
                MqlTick tick = (MqlTick)Marshal::PtrToStructure(hTick, MqlTick::typeid);

                service->SendTick(symbol, tick);
        
}
        catch (...)
        {
        
}

}

接下来我们讨论函数的实施，这些函数将从我们的 ex5 程序中调用：

#define _DLLAPI extern "C" __declspec(dllexport)

// ---------------------------------------------------------------
// 创建并打开服务 
// 返回指针
// ---------------------------------------------------------------
_DLLAPI long long __stdcall CreateExportService(const wchar_t* serverName)
{
        IntPtr hService = ServiceManaged::CreateExportService(gcnew String(serverName));
        
        return (long long)hService.ToPointer(); 

}

// ----------------------------------------- ----------------------
// 关闭服务
// ---------------------------------------------------------------
_DLLAPI void __stdcall DestroyExportService(const long long hService)
{
        ServiceManaged::DestroyExportService(IntPtr((HANDLE)hService));

}

// ---------------------------------------------------------------
// 发送报价
// ---------------------------------------------------------------
_DLLAPI void __stdcall SendTick(const long long hService, const wchar_t* symbol, const HANDLE hTick)
{
        ServiceManaged::SendTick(IntPtr((HANDLE)hService), gcnew String(symbol), IntPtr((HANDLE)hTick));

}

// ---------------------------------------------------------------
// 注册输出的交易品种
// ---------------------------------------------------------------
_DLLAPI void __stdcall RegisterSymbol(const long long hService, const wchar_t* symbol)
{
        ServiceManaged::RegisterSymbol(IntPtr((HANDLE)hService), gcnew String(symbol));

}

// ---------------------------------------------------------------
// 将交易品种从输出交易品种列表中移除
// ---------------------------------------------------------------
_DLLAPI void __stdcall UnregisterSymbol(const long long hService, const wchar_t* symbol)
{
        ServiceManaged::UnregisterSymbol(IntPtr((HANDLE)hService), gcnew String(symbol));

}

代码已准备就绪，现在我们需要对其进行编译和构建。在项目选项中，我们将输出目录指定为 "C:\Program Files\MetaTrader 5\MQL5\Libraries"。编译后，指定的文件夹中将出现三个库。

mql5 程序仅使用其中一个库，即 QExportWrapper.dll，另外的两个库由它使用。由于这个原因，我们需要将库 Qexport.dll 和 Qexport.Service.dll 放在 MetaTrader 的根文件夹中。这不是很方便。

解决方案是创建配置文件，并为库指定路径。我们在 MetaTrader 的根文件夹中创建名为 terminal.exe.config 的文件，并写下以下内容：

<configuration>
   <runtime>
      <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
         <probing privatePath="mql5\libraries" />
      </assemblyBinding>
   </runtime>
</configuration>

好了，现在 CLR 将在文件夹中搜索我们指定的库。

 6. 以 MQL5 实施服务器部分

最后，我们讨论以 mql5 进行的服务器部分编程。我们创建新文件 QService.mqh 并定义 QExpertWrapper.dll 的导入函数：

#import "QExportWrapper.dll"
   long  CreateExportService(string);
   void DestroyExportService(long);
   void RegisterSymbol(long, string);
   void UnregisterSymbol(long, string);
   void SendTick(long, string, MqlTick&);
#import
 

//+------------------------------------------------------------------+
//|                                                    QExporter.mq5 |
//|                                             Copyright GF1D, 2010 |
//|                                             garf1eldhome@mail.ru |
//+------------------------------------------------------------------+
#property copyright "GF1D, 2010"
#property link      "garf1eldhome@mail.ru"
#property version   "1.00"

#include "QService.mqh"
//--- 输入参数
input string  ServerName = "mt5";

QService* service;

//+------------------------------------------------------------------+
//| EA交易初始化函数                                                  |
//+------------------------------------------------------------------+
int OnInit()
{
   service = new QService();
   service.Create(ServerName);
   return(0);

}

//+------------------------------------------------------------------+
//| EA交易去初始化函数                                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
{
   service.Close();
   delete service;
   service = NULL;

}

//+------------------------------------------------------------------+
//| EA的订单函数                                                          |
//+------------------------------------------------------------------+
void OnTick()
{
   MqlTick tick;
   SymbolInfoTick(Symbol(), tick);
   
   service.SendTick(Symbol(), tick);

}
//+------------------------------------------------------------------+