[發(fā)明專利]一種基于配置的傳感器數(shù)據(jù)解析處理方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202010597853.3
• 申請(qǐng)日: 2020-06-28
• 公開(kāi)（公告）號(hào): CN111736894A
• 公開(kāi)（公告）日: 2020-10-02
• 發(fā)明（設(shè)計(jì)）人: 王嘉琦;張子晨;曹鑫亮;王英利;張馳;車(chē)明亮;楊帆;張繼一
• 申請(qǐng)（專利權(quán)）人: 南通大學(xué)
• 主分類號(hào): G06F8/71
• 分類號(hào): G06F8/71;G06F8/41;G06F9/54
• 代理公司: 南京瑞弘專利商標(biāo)事務(wù)所(普通合伙) 32249
• 代理人: 許潔

本發(fā)明公開(kāi)了一種基于配置的傳感器數(shù)據(jù)解析處理方法，初始化系統(tǒng)環(huán)境，加載相應(yīng)的軟件環(huán)境；并將文件中的配置讀取出來(lái)；初始化主線程組與從線程組；構(gòu)建數(shù)據(jù)接收進(jìn)程引導(dǎo)器，并進(jìn)行相關(guān)設(shè)置；構(gòu)建攔截器，并將其掛載到數(shù)據(jù)接收進(jìn)程引導(dǎo)器；構(gòu)建主攔截器，用于接收傳感器數(shù)據(jù)進(jìn)行解析，并對(duì)該數(shù)據(jù)做回應(yīng)處理，并將其掛載到數(shù)據(jù)接收進(jìn)程引導(dǎo)器；利用所構(gòu)建的數(shù)據(jù)接收進(jìn)程引導(dǎo)器來(lái)綁定進(jìn)程端口，并監(jiān)聽(tīng)相應(yīng)的端口發(fā)送的傳感器數(shù)據(jù)。本發(fā)明可以實(shí)現(xiàn)通過(guò)編寫(xiě)配置，即可實(shí)現(xiàn)變更傳感器數(shù)據(jù)解析處理程序的功能。而配置的編寫(xiě)，可以交給運(yùn)維人員來(lái)編寫(xiě)，并不需要程序員的介入。因此，相比于現(xiàn)有技術(shù)，本發(fā)明具有一定的實(shí)用性和易用性。

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

本發(fā)明涉及一種數(shù)據(jù)解析處理方法，具體涉及是一種大規(guī)模傳感器數(shù)據(jù)的解析處理方法。

背景技術(shù)

在當(dāng)前，物聯(lián)網(wǎng)技術(shù)已經(jīng)廣泛的應(yīng)用到環(huán)保、消防、交通、測(cè)繪等多個(gè)領(lǐng)域。在這些應(yīng)用中，傳感器數(shù)據(jù)扮演了一個(gè)至關(guān)重要的角色。傳感器數(shù)據(jù)一般通過(guò)無(wú)線網(wǎng)絡(luò)發(fā)送至主機(jī)的TCP端口，以協(xié)議規(guī)范傳感器和主機(jī)之間的信息傳輸，并在主機(jī)端根據(jù)協(xié)議解析處理傳感器數(shù)據(jù)。

當(dāng)傳感器數(shù)據(jù)的內(nèi)容發(fā)生變化時(shí)，主機(jī)端的傳感器數(shù)據(jù)解析處理程序要做相應(yīng)的變化，這種變化通常是以重新編寫(xiě)代碼的方式進(jìn)行的。考慮到傳感器數(shù)據(jù)內(nèi)容頻繁發(fā)生變化的應(yīng)用場(chǎng)景，相對(duì)應(yīng)的變更程序要付出代價(jià)。因此，需要一種方法，可以實(shí)現(xiàn)對(duì)頻繁變化的傳感器數(shù)據(jù)，無(wú)需變更程序即可進(jìn)行解析處理。

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

發(fā)明目的：為了解決現(xiàn)有技術(shù)的不足，本發(fā)明提供了一種基于配置的傳感器數(shù)據(jù)解析處理方法，本發(fā)明解決的技術(shù)問(wèn)題即針對(duì)大規(guī)模傳感器數(shù)據(jù)的解析處理方法，當(dāng)傳感器數(shù)據(jù)解析處理功能需求發(fā)生變更時(shí)，通過(guò)變更配置，即可實(shí)現(xiàn)相應(yīng)解析處理功能的改變。

技術(shù)方案：一種基于配置的傳感器數(shù)據(jù)解析處理方法，包括如下步驟：

步驟一：初始化系統(tǒng)環(huán)境，加載相應(yīng)的軟件環(huán)境；并將文件中的配置讀取出來(lái)；

步驟二：初始化類型為NioEventLoopGroup的主線程組與從線程組bossLoopGroup和workLoopGroup；

步驟三：構(gòu)建類型為ServerBootstrap的數(shù)據(jù)接收進(jìn)程引導(dǎo)器，并進(jìn)行相關(guān)設(shè)置；

步驟四：構(gòu)建攔截器，用于將多條傳感器數(shù)據(jù)一一分割開(kāi)來(lái)，避免網(wǎng)絡(luò)數(shù)據(jù)包半包粘包，并將其掛載到數(shù)據(jù)接收進(jìn)程引導(dǎo)器；

步驟五：構(gòu)建主攔截器，用于接收傳感器數(shù)據(jù)進(jìn)行解析，并對(duì)該數(shù)據(jù)做回應(yīng)處理，并將其掛載到數(shù)據(jù)接收進(jìn)程引導(dǎo)器；

步驟六：利用步驟三中所構(gòu)建的數(shù)據(jù)接收進(jìn)程引導(dǎo)器來(lái)綁定進(jìn)程端口，并監(jiān)聽(tīng)相應(yīng)的端口發(fā)送的傳感器數(shù)據(jù)。

進(jìn)一步的，所述步驟三中相關(guān)設(shè)置具體包括：

a)將主、從線程組bossLoopGroup和workLoopGroup與數(shù)據(jù)接收器進(jìn)程引導(dǎo)器Server-Bootstrap進(jìn)行關(guān)聯(lián)；

b)設(shè)置主、從線程組的通道類型為NioServerSocketChannel。

進(jìn)一步的，所述步驟五中主攔截器的具體實(shí)現(xiàn)步驟為：

a)根據(jù)消息配置對(duì)數(shù)據(jù)的各個(gè)部分進(jìn)行解析；

b)展示數(shù)據(jù)，若數(shù)據(jù)為關(guān)鍵數(shù)據(jù)，將數(shù)據(jù)存入緩存隊(duì)列中；

c)根據(jù)消息配置構(gòu)建回應(yīng)數(shù)據(jù)并對(duì)其進(jìn)行發(fā)送。

進(jìn)一步的，關(guān)于主攔截器的實(shí)現(xiàn)，所述步驟a的具體實(shí)現(xiàn)步驟為：解析傳感器數(shù)據(jù)的消息ID，并根據(jù)消息ID查找對(duì)應(yīng)的消息配置(一條消息配置中包含若干屬性配置)；開(kāi)始一個(gè)循環(huán)，循環(huán)次數(shù)為屬性配置的個(gè)數(shù)，按序根據(jù)屬性配置讀取消息中的屬性信息并將屬性信息存儲(chǔ)。