目的

C#とMetaTraderでデータのやり取りをする。

データのやり取りに関する実現方法について

データのやり取りに関する実現方法については，主に3種類あると考えられます。

共有メモリを使用する方法
ソケット通信による方法
ファイルによる方法

恐らく３番目が一番実装しやすいのではないでしょうか。
ただし，３番目の場合，ファイルアクセスのルールを決めないといけないため，少しコードの工夫が必要です。

本稿では，ソケット通信による実装方法について検討したいと思います。

ソケット通信によるC#とMetaTraderの連携方法について

ソケット通信による方法では，C#に限らすPythonなどでも実装可能なので，少し応用の幅が広いと思います。

データのやり取りに関しては次のように考えます。

C#からの要求に対しては，MetaTraderでは常に決まったポートで待ち受けるようにします。
MetaTraderからの要求に対しても，常に決まったポートで待ち受けるようにします。

これを行うことで，C#からの要求がMetaTraderからの要求とぶつからないようにすることができます。

実装時は，データをやりとりできることをしか検証していないため同じポートでやりました。

コード

C#側

        private void connect_ClickAsync(object sender, EventArgs e)//ボタン割り当て
        {
            ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());

            foreach (IPAddress ip in ipHostInfo.AddressList)
            {
                Console.WriteLine(ip.ToString());
                if (ip.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
                {

                    ipAddress = ip;
                    //break;
                }
            }
            //ipAddress = ipHostInfo.AddressList[0];
            ipAddress = IPAddress.Parse("127.0.0.1");
            Task task = Task.Run(async () => { await SocketServer(); });

            //接続が成功したら
            //disconnect.Enabled = true;
            //connect.Enabled = false;
        }



        public async Task SocketServer()//受信用のサーバを立ち上げる
        {
            //ここからIPアドレスやポートの設定
            // 着信データ用のデータバッファー。
            byte[] bytes = new byte[1024];

            await Task.Run(() =>
            {
                try
                {

                    Regex reg = new Regex("\0");
                    if (server == null)
                    {
                        //指定IP 指定ポートでサーバを起動
                        server = new TcpListener(new IPEndPoint(ipAddress, port));
                    }
                    server.Start();
                    while (startFlg)
                    {
                        if (!startFlg)
                        {
                            server.Stop();
                            break;
                        }

                        using (TcpClient tcpClient = server.AcceptTcpClient())
                        using (Stream stream = tcpClient.GetStream())
                        {
                            int i = 0;
                            while ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
                            {
                                string data1 = reg.Replace(Encoding.UTF8.GetString(bytes), "");



                                // 任意の処理
                                //データの受取をReceiveで行う。
                                //int bytesRec = handler.Receive(bytes);
                                //string data1 = Encoding.UTF8.GetString(bytes, 0, bytesRec);
                                if (data1.Length > 0)
                                {
                                    Console.WriteLine("data1の数:" + data1.Length);
                                    Console.WriteLine(data1);

                                    String[] sep = { "," };
                                    String[] sba = data1.Split(sep, StringSplitOptions.RemoveEmptyEntries);

                                    if (this.InvokeRequired)
                                    {
                                        //別スレッドによるUI操作
                                        this.Invoke((MethodInvoker)(() =>
                                        {
                                            bidTbx.Text = sba[1];
                                            askTbx.Text = sba[2];
                                        }));
                                    }
                                    else
                                    {
                                        //UIスレッドからのUI操作
                                        bidTbx.Text = sba[1];
                                        askTbx.Text = sba[2];
                                    }




                                    //大文字に変更
                                    data1 = data1.ToUpper();

                                    //クライアントにSendで返す。
                                    byte[] msg = Encoding.UTF8.GetBytes(data1);
                                    stream.Write(msg, 0, msg.Length);
                                    Array.Clear(bytes, 0, bytes.Length);
                                }
                            }
                        }

                        // break;
                    }
                }
                catch (Exception ex)

                {
                    Console.WriteLine(ex.ToString());
                }

            });

        }

        public static void SocketClient(string st)//クライアント側（C#からMetaTraderにアクセスするとき)
        {
            //IPアドレスやポートを設定している。
            IPHostEntry ipHostInfo1 = Dns.GetHostEntry(Dns.GetHostName());
            IPAddress ipAddress1 = ipHostInfo1.AddressList[0];

            foreach (IPAddress ip in ipHostInfo1.AddressList)
            {
                if (ip.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
                {
                    ipAddress1 = ip;
                    break;
                }
            }

            ipAddress1 = IPAddress.Parse("127.0.0.1");

            IPEndPoint remoteEP = new IPEndPoint(ipAddress1, 4545);

            //ソケットを作成
            Socket socket = new Socket(ipAddress1.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

            //接続する。失敗するとエラーで落ちる。
            socket.Connect(remoteEP);

            //Sendで送信している。
            byte[] msg = Encoding.UTF8.GetBytes(st + "<EOF>");
            socket.Send(msg);

            //Receiveで受信している。
            byte[] bytes = new byte[1024];
            int bytesRec = socket.Receive(bytes);
            string data1 = Encoding.UTF8.GetString(bytes, 0, bytesRec);
            Console.WriteLine(data1);

            //ソケットを終了している。
            socket.Shutdown(SocketShutdown.Both);
            socket.Close();
        }

MetaTrader側でどう受け取るかにもよりますが，


   SocketClient("buy,141.25,,,OK");

といった具合に要求することを考えています。

MQL4

MQL4側は，ここを参考にしながら実装していければと思います。

完成品

一応置いておきますが，共有メモリでの実装に移行している関係で，正しく動きません！

REFERENCEs

さいごに

投資は自己責任！

カレンダー参加者募集してます！

Have a good MQL Life!!!