এফএমজেড প্ল্যাটফর্মের বহিরাগত সংকেত গ্রহণের অন্বেষণঃ এক্সটেনশান এপিআই বনাম কৌশল অন্তর্নির্মিত এইচটিটিপি পরিষেবা

উপস্থাপনা

প্ল্যাটফর্মের লাইব্রেরিতে বেশ কয়েকটি নিবন্ধ রয়েছে যা ট্রেডিং ভিউ ওয়েবহুকের সাথে সংযোগ স্থাপন করে, যা প্ল্যাটফর্মটি জাভাস্ক্রিপ্ট ভাষার অন্তর্নির্মিত HTTP পরিষেবাগুলিকে সমর্থন করে না এমন সময়ে কৌশলটির বাইরের সিস্টেমের সিগন্যাল চালিত লেনদেনের অনুমতি দেয়। প্ল্যাটফর্মের এক্সটেনশন এপিআই ইন্টারফেস ব্যবহার করেঃCommandRobotএটি কেবলমাত্র একটি বাহ্যিক সিগন্যালের একটি http/https অনুরোধ যা FMZ প্ল্যাটফর্মে প্রেরণ করা হয়, যা প্ল্যাটফর্মটি সিগন্যালটি রূপান্তর করে, কৌশলগত ইন্টারঅ্যাকশন বার্তাগুলির বিজ্ঞপ্তি হিসাবে কৌশলগত প্রোগ্রামগুলিতে।

প্ল্যাটফর্মের বিকাশ, পুনরাবৃত্তি এবং আপগ্রেডের সাথে সাথে অনেকগুলি নতুন বৈশিষ্ট্য আপডেট করা হয়েছে। বাহ্যিক সংকেতগুলি গ্রহণের জন্যও নতুন বিকল্প রয়েছে। বিভিন্ন বিকল্পের নিজস্ব সুবিধা রয়েছে, আমরা এই বিষয়টি নিয়ে একসাথে আলোচনা করব।

এফএমজেড প্ল্যাটফর্ম ব্যবহার করে এপিআই সম্প্রসারণ

এই পদ্ধতিতে বাইরের সিস্টেমগুলির সাথে সংযোগ স্থাপনের সুবিধা হ'ল তুলনামূলকভাবে সহজ, শক্তিশালী সুরক্ষা এবং প্ল্যাটফর্ম-নির্ভর এক্সটেনশান এপিআই ইন্টারফেসের স্থিতিশীলতা।

বাইরের সিগন্যাল গ্রহণের প্রক্রিয়াঃ

বাহ্যিক সিস্টেম (ট্রেডিং ভিউ ওয়েবহুক) > FMZ এক্সটেনশন এপিআই পরিষেবা > কৌশল বাস্তব ডিস্ক

১, বহিরাগত সিস্টেম (ট্রেডিং ভিউ ওয়েবহুক): উদাহরণস্বরূপ ট্রেডিং ভিউতে চালিত পাইন স্ক্রিপ্টটি একটি অ্যালার্ম সেট করতে পারে, যা ট্রিগার হওয়ার পরে সেট করা ওয়েবহুকের ইউআরএল ঠিকানায় একটি HTTP অনুরোধ পাঠায়, একটি সংকেত হিসাবে। ২. FMZ এক্সটেনশন এপিআই পরিষেবাঃ ইন্টারফেসটি সফলভাবে অ্যাক্সেস করার পরে, প্ল্যাটফর্মটি বার্তাটি পুনরায় প্রেরণ করে, যা একটি ইন্টারঅ্যাকশন বার্তা হিসাবে কৌশলগত বাস্তব ডিস্কের কাছে প্রেরণ করা হয়। ৩. নীতির বাস্তব ড্রাইভঃ নীতির বাস্তব ড্রাইভে, GetCommand ফাংশনটি ইন্টারঅ্যাকশন বার্তাগুলি শোনার জন্য ডিজাইন করা যেতে পারে, যা বার্তাটি সনাক্ত করার পরে একটি নির্ধারিত ক্রিয়াকলাপ সম্পাদন করে।

বিল্ট-ইন এইচটিটিপি পরিষেবা ব্যবহার করে সরাসরি পরিষেবা গ্রহণের সংকেত তৈরি করার তুলনায় মাঝখানে আরও একটি পদক্ষেপ (প্ল্যাটফর্মের মধ্যবর্তী স্থানান্তর) ।

নীতিগতভাবে বিল্ট-ইন HTTP পরিষেবা

প্ল্যাটফর্মটি জাভাস্ক্রিপ্ট ভাষার অন্তর্নির্মিত এইচটিটিপি পরিষেবা বৈশিষ্ট্য সমর্থন করার পরে, সরাসরি একটি সমান্তরাল পরিষেবা মনিটরিং বহিরাগত সংকেত তৈরি করতে পারে। সুবিধাগুলি হ'লঃ তৈরি করা এইচটিটিপি পরিষেবাটি পৃথক থ্রেড, মূল ফাংশনের যুক্তিকে প্রভাবিত করে না, এটি গেটকমান্ড ফাংশনের মতোই বার্তাগুলির অনুরূপ মনিটরিং করতে পারে এবং সরাসরি বহিরাগত সংকেতগুলিকে মনিটর করতে পারে, এক্সটেনশন এপিআই প্রোগ্রাম ব্যবহারের তুলনায় মধ্যবর্তী ট্রান্সফার লিংকগুলি বাদ দেয়।

বাইরের সিগন্যাল গ্রহণের প্রক্রিয়াঃ

বাহ্যিক সিস্টেম (ট্রেডিং ভিউ ওয়েবহুক) ট্যাব> কৌশল বাস্তব ডিস্ক

১, বহিরাগত সিস্টেম (ট্রেডিং ভিউ ওয়েবহুক): উদাহরণস্বরূপ, ট্রেডিং ভিউতে চালিত পাইন স্ক্রিপ্টটি একটি অ্যালার্ম সেট করতে পারে, যা ট্রিগার হওয়ার পরে সেট করা ওয়েবহুকের ইউআরএল ঠিকানায় একটি সিগন্যাল হিসাবে একটি HTTP অনুরোধ প্রেরণ করে। ২, কৌশলগত ডিস্কঃ কৌশলগতভাবে একটি HTTP পরিষেবা চালানো হয় যা সরাসরি বহিরাগত সংকেত গ্রহণ করে।

এই পদ্ধতিটি একটি ধাপ এড়ায়, তবে সুরক্ষা বাড়ানোর জন্য, https পরিষেবাটি কনফিগার করা ভাল, যা একটি এক্সটেনশন এপিআই ব্যবহারের তুলনায় প্রোগ্রামের কিছুটা ঝামেলা।

কোড পরীক্ষা

দুটি পদ্ধতি পরীক্ষা করা হয়, নিম্নলিখিত নীতিটি প্রতি রাউন্ডে 10 টি HTTP / HTTPS অনুরোধ পাঠিয়ে দেয়, যা বহিরাগত সংকেতগুলিকে অনুকরণ করতে ব্যবহৃত হয়। তারপর কৌশলটি "ইন্টারঅ্যাকশন বার্তা" এবং "HTTPS সার্ভিস থ্রেড দ্বারা প্রেরিত বার্তা" এর উপর নজর রাখে। তারপরে নীতিটি বার্তাটি একের পর এক বহিরাগত সংকেতগুলির সাথে মেলে, কোনও সংকেত হারাতে পারে কিনা তা সনাক্ত করে, গণনা সময় নেয়।

var httpUrl = "http://123.123.123.123:8088/CommandRobot"
var accessKey = ""
var secretKey = ""

function serverFunc(ctx) {
    var path = ctx.path()
    if (path == "/CommandRobot") {
        var body = ctx.body()
        threading.mainThread().postMessage(body)
        ctx.write("OK")
        // 200
    } else {
        ctx.setStatus(404)
    }
}

function createMsgTester(accessKey, secretKey, httpUrl) {
    var tester = {}
    
    tester.currentRobotId = _G()
    tester.arrSendMsgByAPI = []
    tester.arrSendMsgByHttp = []
    tester.arrEchoMsgByAPI = []
    tester.arrEchoMsgByHttp = []
    tester.idByAPI = 0
    tester.idByHttp = 0

    var sendMsgByAPI = function(msgByAPI, robotId, accessKey, secretKey) {
        var headers = {
            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_9_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/35.0.1916.153 Safari/537.36",
            "Content-Type": "application/json"
        }
        HttpQuery(`https://www.fmz.com/api/v1?access_key=${accessKey}&secret_key=${secretKey}&method=CommandRobot&args=[${robotId},+""]`, {"method": "POST", "body": JSON.stringify(msgByAPI), "headers": headers})
    }

    var sendMsgByHttp = function(msgByHttp, httpUrl) {
        HttpQuery(httpUrl, {"method": "POST", "body": JSON.stringify(msgByHttp)})
    }

    tester.run = function() {
        var robotId = tester.currentRobotId

        for (var i = 0; i < 10; i++) {
            var msgByAPI = {"ts": new Date().getTime(), "id": tester.idByAPI, "way": "ByAPI"}            
            tester.arrSendMsgByAPI.push(msgByAPI)
            tester.idByAPI++
            threading.Thread(sendMsgByAPI, msgByAPI, robotId, accessKey, secretKey)

            var msgByHttp = {"ts": new Date().getTime(), "id": tester.idByHttp, "way": "ByHttp"}
            tester.arrSendMsgByHttp.push(msgByHttp)
            tester.idByHttp++
            threading.Thread(sendMsgByHttp, msgByHttp, httpUrl)
        }
    }

    tester.getEcho =function(msg) {
        if (msg["way"] == "ByAPI") {
            tester.arrEchoMsgByAPI.push(msg)
        } else {
            tester.arrEchoMsgByHttp.push(msg)
        }
    }

    tester.deal = function() {
        var tbls = []
        for (var pair of [[tester.arrEchoMsgByHttp, tester.arrSendMsgByHttp, "ByHttp"], [tester.arrEchoMsgByAPI, tester.arrSendMsgByAPI, "ByAPI"]]) {
            var receivedMessages = pair[0]
            var sentMessages = pair[1]
            var testType = pair[2]

            var receivedMap = new Map()
            receivedMessages.forEach(message => {
                receivedMap.set(message["id"], message)
            })
            
            var matchedPairs = []
            var timeDifferences = []
            for (var sentMessage of sentMessages) {
                var receivedMessage = receivedMap.get(sentMessage["id"])
                if (receivedMessage) {
                    matchedPairs.push([JSON.stringify(sentMessage), JSON.stringify(receivedMessage), receivedMessage["ts"] - sentMessage["ts"]])
                    timeDifferences.push(receivedMessage["ts"] - sentMessage["ts"])
                } else {
                    Log("no matched sentMessage:", sentMessage, "#FF0000")
                }
            }
            
            var averageTimeDifference = timeDifferences.reduce((sum, diff) => sum + diff, 0) / timeDifferences.length
            
            var tbl = {
                "type": "table",
                "title": testType + " / averageTimeDifference:" + averageTimeDifference,
                "cols": ["send", "received", "ts diff"],
                "rows": []
            }

            for (var pair of matchedPairs) {
                tbl["rows"].push(pair)
            }

            tbls.push(tbl)
            Log(testType, ", averageTimeDifference:", averageTimeDifference, "ms")
        }

        tester.arrSendMsgByAPI = []
        tester.arrSendMsgByHttp = []
        tester.arrEchoMsgByAPI = []
        tester.arrEchoMsgByHttp = []

        return tbls
    }

    return tester
}

function main() {
    __Serve("http://0.0.0.0:8088", serverFunc)

    var t = createMsgTester(accessKey, secretKey, httpUrl)
    while (true) {
        Log("测试开始...", "#FF0000")
        t.run()

        var beginTS = new Date().getTime()
        while (new Date().getTime() - beginTS < 60 * 1000) {
            var cmd = GetCommand()
            if (cmd) {
                try {
                    var obj = JSON.parse(cmd)
                    obj["ts"] = new Date().getTime()
                    t.getEcho(obj)
                } catch (e) {
                    Log(e)
                }
            }
            
            var msg = threading.mainThread().peekMessage(-1)
            if (msg) {
                try {
                    var obj = JSON.parse(msg)
                    obj["ts"] = new Date().getTime()
                    t.getEcho(obj)                
                } catch (e) {
                    Log(e)
                }
            }
        }
        Log("等待结束...", "#FF0000")
                
        var tbls = t.deal()
        LogStatus(_D(), "\n`" + JSON.stringify(tbls) + "`")
        Sleep(20000)
    }
}

যদি পরীক্ষা করা হয়, তবে নির্দিষ্ট সার্ভারের আইপি ঠিকানা পূরণ করতে হবে, এফএমজেড প্ল্যাটফর্মের এক্সটেনশন এপিআই কী।

var httpUrl = "http://123.123.123.123:8088/CommandRobot"
var accessKey = "xxx"
var secretKey = "xxx"

১. সার্ভার ফাংশনটি একটি সমান্তরাল HTTP পরিষেবা তৈরি করে যা বহিরাগত সংকেতগুলির উপর নজর রাখতে ব্যবহৃত হয়।

• এইচটিটিপি সার্ভিসের থ্রেড থেকে পাঠানো বার্তাঃ দ্বারাvar msg = threading.mainThread().peekMessage(-1)মিডিয়ার খবর।

• এক্সটেনশান এপিআই ফরোয়ার্ডের মাধ্যমে ইন্টারেক্টিভ বার্তাঃ দ্বারাvar cmd = GetCommand()মিডিয়ার খবর।

২। সিগন্যাল প্রেরণ এবং গ্রহণের প্রক্রিয়া উভয়ই অবাধ, প্ল্যাটফর্মটি অন্তর্নিহিত মাল্টি-থ্রেড রিসোর্স পুনরুদ্ধারের প্রক্রিয়াটি অপ্টিমাইজ করেছে।Threadঅথবাexchange.Goসমান্তরাল ফাংশনগুলি, যাতে সমান্তরাল কাজগুলি (যেমন যোগদান ফাংশন, অপেক্ষা ফাংশন ইত্যাদি) সম্পূর্ণ হওয়ার জন্য অপেক্ষা না করে, সিস্টেমের নীচে স্বয়ংক্রিয়ভাবে রিসোর্স পুনরুদ্ধার (যেমন সর্বশেষতম সংস্করণ হোস্টের প্রয়োজন) ।

    // 摘录代码片段，发送信号
    tester.run = function() {
        var robotId = tester.currentRobotId

        for (var i = 0; i < 10; i++) {
            var msgByAPI = {"ts": new Date().getTime(), "id": tester.idByAPI, "way": "ByAPI"}            
            tester.arrSendMsgByAPI.push(msgByAPI)
            tester.idByAPI++
            threading.Thread(sendMsgByAPI, msgByAPI, robotId, accessKey, secretKey)   // 并发调用，非阻塞

            var msgByHttp = {"ts": new Date().getTime(), "id": tester.idByHttp, "way": "ByHttp"}
            tester.arrSendMsgByHttp.push(msgByHttp)
            tester.idByHttp++
            threading.Thread(sendMsgByHttp, msgByHttp, httpUrl)                       // 并发调用，非阻塞
        }
    }

    // 摘录代码片段，接收信号
    var cmd = GetCommand()                              // 监听来自扩展API的消息，非阻塞
    var msg = threading.mainThread().peekMessage(-1)    // 监听来自自建Http服务的消息，使用了参数-1，非阻塞

এখন আমরা এই পরীক্ষার প্রক্রিয়াটি দেখব, যেখানে তথ্য সরাসরি কোডটিতে মন্তব্য করা হয়ঃ

function main() {
    __Serve("http://0.0.0.0:8088", serverFunc)      // 在当前策略实例中，创建一个并发的http服务

    var t = createMsgTester(accessKey, secretKey, httpUrl)   // 创建一个用于测试管理的对象
    while (true) {                                           // 策略主循环开始
        Log("测试开始...", "#FF0000")
        t.run()                                              // 每次循环开始，调用测试管理对象的run函数，使用两种方式（1、通过扩展API发送信号，2、直接向当前策略创建的Http服务发送信号），每种方式并发发送10个请求

        var beginTS = new Date().getTime()
        while (new Date().getTime() - beginTS < 60 * 1000) {   // 循环检测来自扩展API的交互消息，循环检测来自自建Http服务的消息
            var cmd = GetCommand()
            if (cmd) {
                try {
                    var obj = JSON.parse(cmd)
                    obj["ts"] = new Date().getTime()        // 检测到交互消息，记录消息，更新时间为收到时间
                    t.getEcho(obj)                          // 记录到对应数组
                } catch (e) {
                    Log(e)
                }
            }
            
            var msg = threading.mainThread().peekMessage(-1)
            if (msg) {
                try {
                    var obj = JSON.parse(msg)
                    obj["ts"] = new Date().getTime()        // 检测到自建的Http服务收到的消息，更新时间为收到时间
                    t.getEcho(obj)                          // ...
                } catch (e) {
                    Log(e)
                }
            }
        }
        Log("等待结束...", "#FF0000")
                
        var tbls = t.deal()                                  // 根据记录的消息，配对，检查是否有未配对的消息，如果有说明有信号丢失
        LogStatus(_D(), "\n`" + JSON.stringify(tbls) + "`")
        Sleep(20000)
    }
}

পরীক্ষার ফলাফল

এইচটিটিপি পদ্ধতির ব্যবহারের সময়টি এপিআই পদ্ধতির তুলনায় কিছুটা কম সময় নেয়।

কৌশল অন্তর্নির্মিত এইচটিটিপি পরিষেবা সংকেত গ্রহণ করে, এই পরীক্ষার পদ্ধতিটি খুব কঠোর নয়, অনুরোধটি বাহ্যিক থেকে আসা উচিত; সহজভাবে বোঝার জন্য, এই বিষয়টি উপেক্ষা করা যেতে পারে। দুটি পদ্ধতির সংকেত গ্রহণের জন্য, কৌশল অন্তর্নির্মিত এইচটিটিপি পরিষেবাটি একটি লিংক হ্রাস করেছে, এটি প্রতিক্রিয়া গতির চেয়ে কিছুটা দ্রুত হওয়া উচিত। সংকেত স্থিতিশীলতার জন্য, সংকেতটি হারাতে বা মিস করা যায় না। পরীক্ষার ফলাফলগুলি দেখতে পাওয়া যায় যে, এফএমজেড প্ল্যাটফর্মের এক্সটেনশন এপিআইটিও স্থিতিশীল, পরীক্ষায় কোনও সংকেত হারাতে দেখা যায়নি, তবে নেটওয়ার্ক ইত্যাদির মতো বিভিন্ন দিকগুলিকে বাদ দেওয়া হয়নি।

এই নিবন্ধে, এইচটিটিপি পরিষেবাগুলির মধ্যে থাকা কোডটি যাচাই করা হয়নি এবং কেবলমাত্র বার্তাগুলির ডেটা গ্রহণ করা হয়েছে। পরবর্তী নিবন্ধে, আমরা একসাথে একটি ব্যবহারযোগ্য বিল্ট-ইন এইচটিটিপি পরিষেবা তৈরি করেছি যা বাইরের ট্রেডিং ভিউ সংকেতগুলি গ্রহণের জন্য একটি টেমপ্লেট তৈরি করে।