[發(fā)明專利]一種物聯(lián)網(wǎng)數(shù)據(jù)的中轉(zhuǎn)處理方法

有效

• 申請?zhí)枺?/td>: 201510475375.8
• 申請日: 2015-08-05
• 公開（公告）號: CN105187490B
• 公開（公告）日: 2019-01-04
• 發(fā)明（設(shè)計）人: 姜立偉;余陽;梁文智;曾昭健
• 申請（專利權(quán)）人: 廣東長天思源環(huán)保科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆;胡彬

本發(fā)明涉及物聯(lián)網(wǎng)數(shù)據(jù)傳輸處理領(lǐng)域，具體公開了一種物聯(lián)網(wǎng)數(shù)據(jù)的中轉(zhuǎn)處理方法，主要包括以下步驟：數(shù)據(jù)接收步驟，配置有獨立的接收線程把接收到的數(shù)據(jù)存儲于臨時表中；數(shù)據(jù)分類步驟，把所述臨時表中的數(shù)據(jù)按照預(yù)設(shè)的分類分成多類；數(shù)據(jù)解析步驟，對所述的多類數(shù)據(jù)配置有獨立的多條解析線程且按照預(yù)設(shè)的解析算法進(jìn)行數(shù)據(jù)解析；數(shù)據(jù)上報步驟，把經(jīng)過解析的數(shù)據(jù)上報至平臺；通過這樣的設(shè)計，使得在數(shù)據(jù)解析階段有多條數(shù)據(jù)并列地同步運行，有效地加快數(shù)據(jù)的中轉(zhuǎn)速度。

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

本發(fā)明涉及物聯(lián)網(wǎng)數(shù)據(jù)傳輸領(lǐng)域，具體而言，涉及一種物聯(lián)網(wǎng)數(shù)據(jù)的中轉(zhuǎn)處理方法。

背景技術(shù)

目前環(huán)境問題越來越嚴(yán)峻，需要對各個污染排放企業(yè)進(jìn)行排放源的監(jiān)控如監(jiān)控其煙氣、廢水等各種的含量是否超標(biāo)，就需要建立一個較大的監(jiān)控系統(tǒng)進(jìn)行實時監(jiān)控。該監(jiān)控系統(tǒng)的工作流程大致分為：

1)數(shù)據(jù)采集階段。各檢測探頭收集的數(shù)據(jù)→采集器→經(jīng)過采集器的分析→存放到采集器本身的數(shù)據(jù)庫；

2)一般數(shù)據(jù)傳輸階段。通過數(shù)據(jù)上報系統(tǒng)把采集到的各終端數(shù)據(jù)進(jìn)行上報→中轉(zhuǎn)服務(wù)器→上報至管理平臺。

目前的數(shù)據(jù)上報至中轉(zhuǎn)服務(wù)器，在中轉(zhuǎn)服務(wù)器內(nèi)都是一邊接收各終端上報的數(shù)據(jù)的同時，一邊進(jìn)行解析，再將解析好的數(shù)據(jù)上報至管理平臺。但是，目前數(shù)據(jù)解析之前，沒有按照數(shù)據(jù)類型進(jìn)行分類，采用單一的線程及單一的數(shù)據(jù)解析的算法，算法復(fù)雜而且數(shù)據(jù)效率低，出現(xiàn)以下問題：

1)接收下游站點數(shù)據(jù)過大的時候，解析數(shù)據(jù)不能跟上接收數(shù)據(jù)的速度，中轉(zhuǎn)服務(wù)器就會出現(xiàn)解析數(shù)據(jù)超時，甚至堵塞的問題。

2)數(shù)據(jù)的解析、報送線程還會與數(shù)據(jù)的接收線程發(fā)生資源搶奪，危及數(shù)據(jù)接收、解析、上報的穩(wěn)定性。

3)如果數(shù)據(jù)解析出現(xiàn)錯誤，因為中轉(zhuǎn)服務(wù)器的數(shù)據(jù)量非常多而且沒有分類，數(shù)據(jù)查詢及排查異常將會很麻煩。

4)由于解析算法單一，每當(dāng)報送的數(shù)據(jù)類型出現(xiàn)增加、改變、刪減等情況的時候，數(shù)據(jù)解析算法需要更新，否則數(shù)據(jù)解析出錯，影響中轉(zhuǎn)服務(wù)器甚至整個監(jiān)控系統(tǒng)正常運行。

據(jù)此，本發(fā)明提出了一種物聯(lián)網(wǎng)數(shù)據(jù)的中轉(zhuǎn)處理方法，通過將數(shù)據(jù)按照預(yù)設(shè)的分類分成多類，針對多類數(shù)據(jù)設(shè)計多種對應(yīng)的數(shù)據(jù)解析算法，并配置多條獨立并行的解析線程，有效地解決了這些問題。

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

本發(fā)明旨在至少解決現(xiàn)有技術(shù)中存在的技術(shù)問題之一。

為此，本發(fā)明的一個目的在于，提供一種物聯(lián)網(wǎng)數(shù)據(jù)的中轉(zhuǎn)處理方法，通過本發(fā)明提供的方法，可以有效地提高中轉(zhuǎn)服務(wù)器的處理速度，使得中轉(zhuǎn)服務(wù)器在數(shù)據(jù)的接收與數(shù)據(jù)的解析上更加地協(xié)調(diào)。

為實現(xiàn)上述目的，本發(fā)明提供了一種物聯(lián)網(wǎng)數(shù)據(jù)的中轉(zhuǎn)處理方法，其特征在于，包括：數(shù)據(jù)接收步驟，配置有獨立的接收線程把接收到的數(shù)據(jù)存儲于臨時表中；數(shù)據(jù)分類步驟，把所述臨時表中的數(shù)據(jù)按照預(yù)設(shè)的分類分成N類；數(shù)據(jù)解析步驟，對所述N類數(shù)據(jù)配置獨立的P條解析線程且按照預(yù)設(shè)的解析算法進(jìn)行數(shù)據(jù)解析；數(shù)據(jù)上報步驟，把經(jīng)過解析的數(shù)據(jù)上報至平臺；其中，所述P大于或等于所述N，所述N為大于1的整數(shù)。

根據(jù)本發(fā)明提供的數(shù)據(jù)中轉(zhuǎn)處理方法，先把數(shù)據(jù)存儲進(jìn)臨時表，再對臨時表的數(shù)據(jù)進(jìn)行分成N類，再分配不少于N類數(shù)據(jù)的P條獨立線程，并對每一類數(shù)據(jù)按照預(yù)設(shè)的解析算法進(jìn)行數(shù)據(jù)解析。由于在數(shù)據(jù)解析步驟中，分配的線程數(shù)量大于或等于分類的數(shù)據(jù)類型數(shù)量，這樣就保證了至少每一類數(shù)據(jù)具有一條獨立的解析線程運行，且按照預(yù)設(shè)的解析算法獨立并行地解析，這樣就大大地加快了解析步驟的速度，使得解析線程與接收線程更加協(xié)調(diào)，減少了接收步驟接收的數(shù)據(jù)過快但解析步驟速度跟不上而發(fā)生堵塞的情況。

另外，根據(jù)本發(fā)明提供的數(shù)據(jù)中轉(zhuǎn)處理方法還具有如下附加技術(shù)特征：

根據(jù)本發(fā)明的一個實施例，所述解析算法預(yù)設(shè)有N種，與預(yù)設(shè)的所述N類數(shù)據(jù)一一對應(yīng)。