[發(fā)明專(zhuān)利]在線(xiàn)監(jiān)測(cè)設(shè)備通信數(shù)據(jù)包通用接收方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201810014289.0
• 申請(qǐng)日: 2018-01-08
• 公開(kāi)（公告）號(hào): CN108259483A
• 公開(kāi)（公告）日: 2018-07-06
• 發(fā)明（設(shè)計(jì)）人: 呂勇;鄭傳彬;范軍響;陳曉燕
• 申請(qǐng)（專(zhuān)利權(quán)）人: 廣州恩業(yè)電子科技有限公司
• 主分類(lèi)號(hào): H04L29/06
• 分類(lèi)號(hào): H04L29/06
• 代理公司: 暫無(wú)信息
• 代理人: 暫無(wú)信息

本發(fā)明公開(kāi)了在線(xiàn)監(jiān)測(cè)設(shè)備通信數(shù)據(jù)包通用接收方法，包括TCP服務(wù)阻塞等待遠(yuǎn)程設(shè)備連接，開(kāi)啟goroutine機(jī)制，阻塞讀取數(shù)據(jù)包信息，解析數(shù)據(jù)包，進(jìn)行數(shù)據(jù)傳輸協(xié)議校驗(yàn)，解析出數(shù)據(jù)，數(shù)據(jù)庫(kù)查表，保存數(shù)據(jù)；執(zhí)行定時(shí)任務(wù)，銷(xiāo)毀離線(xiàn)客戶(hù)端。

技術(shù)領(lǐng)域

本發(fā)明涉及監(jiān)測(cè)設(shè)備技術(shù)領(lǐng)域，具體為在線(xiàn)監(jiān)測(cè)設(shè)備通信數(shù)據(jù)包通用接收方法。

背景技術(shù)

就環(huán)保在線(xiàn)監(jiān)測(cè)行業(yè)來(lái)說(shuō)，數(shù)據(jù)通信必須要有一個(gè)中心接收服務(wù)程序，這個(gè)中心服務(wù)程序在理論上可以基于任何一門(mén)編程語(yǔ)言開(kāi)發(fā)的，只要按照數(shù)據(jù)傳輸協(xié)議，正常并穩(wěn)定運(yùn)行，可同時(shí)解析多客戶(hù)端的數(shù)據(jù)包即可。

本文涉及到的開(kāi)發(fā)技術(shù)只有GO編程語(yǔ)言技術(shù)，利用GO編程語(yǔ)言的goroutine機(jī)制以及對(duì)計(jì)算機(jī)多核心開(kāi)發(fā)出來(lái)的TCP接收服務(wù)程序，可以輕松解析數(shù)百萬(wàn)設(shè)備同時(shí)在線(xiàn)的數(shù)據(jù)包。

以往技術(shù)局限于條件解析，比如監(jiān)測(cè)的是水?dāng)?shù)據(jù)只能解析出水?dāng)?shù)據(jù)，想在此基礎(chǔ)上再增加一種監(jiān)測(cè)功能卻無(wú)能為力。本TCP接收服務(wù)程序，無(wú)此限制，只依賴(lài)定義了什么樣的傳輸協(xié)議，基于定義好的協(xié)議，可靈活解析任何類(lèi)型的數(shù)據(jù)包。

傳統(tǒng)的解決方法，運(yùn)用原技術(shù)來(lái)解決所存在的缺點(diǎn)有以下幾點(diǎn)：

(1)接受監(jiān)測(cè)類(lèi)型有局限性，比如是水的就只能是水，是氣的只能是氣。

(2)數(shù)據(jù)存儲(chǔ)的結(jié)構(gòu)必須提前創(chuàng)建好，這些結(jié)構(gòu)只能對(duì)應(yīng)一個(gè)監(jiān)測(cè)類(lèi)型，改動(dòng)性不強(qiáng)。

(3)原技術(shù)主要使用的是Java語(yǔ)言開(kāi)發(fā)。需要較大的內(nèi)存空間來(lái)收集數(shù)據(jù)。

(4)Java開(kāi)發(fā)的代碼量相對(duì)來(lái)說(shuō)比較多，數(shù)據(jù)運(yùn)算時(shí)間比較長(zhǎng)。

發(fā)明內(nèi)容

本發(fā)明的目的在于提供在線(xiàn)監(jiān)測(cè)設(shè)備通信數(shù)據(jù)包通用接收方法，解決了背景技術(shù)中所提出的問(wèn)題。

為實(shí)現(xiàn)上述目的，本發(fā)明提供如下技術(shù)方案：在線(xiàn)監(jiān)測(cè)設(shè)備通信數(shù)據(jù)包通用接收方法，包括TCP服務(wù)阻塞等待遠(yuǎn)程設(shè)備連接，開(kāi)啟goroutine機(jī)制，阻塞讀取數(shù)據(jù)包信息，解析數(shù)據(jù)包，進(jìn)行數(shù)據(jù)傳輸協(xié)議校驗(yàn)，解析出數(shù)據(jù)，數(shù)據(jù)庫(kù)查表，保存數(shù)據(jù)；執(zhí)行定時(shí)任務(wù)，銷(xiāo)毀離線(xiàn)客戶(hù)端。具體步驟為：

步驟一：遠(yuǎn)程設(shè)備數(shù)據(jù)傳輸；

步驟二：TCP服務(wù)；

步驟三：goroutine調(diào)度機(jī)制；

步驟四：讀取字符流；

步驟五：取出包頭信息；

步驟六：協(xié)議校驗(yàn)；

步驟七：解析出數(shù)據(jù)；

步驟八：查詢(xún)相對(duì)應(yīng)表；

步驟九：創(chuàng)建表名；

步驟十：保存數(shù)據(jù)庫(kù)；

步驟十一：執(zhí)行任務(wù)；

步驟十二：刪除數(shù)據(jù)庫(kù)記錄；

步驟十三：客戶(hù)端狀態(tài)判斷。

作為本發(fā)明的一種優(yōu)選實(shí)施方式，所述遠(yuǎn)程設(shè)備數(shù)據(jù)傳輸：監(jiān)測(cè)現(xiàn)場(chǎng)設(shè)備所傳來(lái)的數(shù)據(jù)。

作為本發(fā)明的一種優(yōu)選實(shí)施方式，所述TCP服務(wù)：監(jiān)聽(tīng)遠(yuǎn)程設(shè)備是否連接，若連接，則開(kāi)啟一條goroutine，若不連接，則繼續(xù)阻塞等待。

作為本發(fā)明的一種優(yōu)選實(shí)施方式，所述goroutine調(diào)度機(jī)制：若沒(méi)啟用多核心配置參數(shù)，每個(gè)goroutine都在一個(gè)CPU中處理，若啟用了，則每個(gè)goroutine隨機(jī)分配到多個(gè)CPU中處理。

作為本發(fā)明的一種優(yōu)選實(shí)施方式，所述讀取字符流：將連接通道中的字節(jié)流數(shù)據(jù)讀出，如果沒(méi)有就處于等待狀態(tài)。