一種物聯網中分布式數據存儲和查詢的方法
2023-05-06 01:43:16
專利名稱：：一種物聯網中分布式數據存儲和查詢的方法
技術領域：
：本發明涉及物聯網中的數據存儲和查詢的方法，具體涉及一種物聯網中分布式數據存儲和查詢的方法及系統。
背景技術：
：物聯網(InternetofThings)的提出發展了原有的傳感網、RFID等技術。原有的傳感器網絡作為物聯網的組成部分被包含進來。物聯網發展的一個重要目標是打破原來傳感器網絡的垂直應用方式，即不同的應用需要建設自己的傳感器網絡設施，應用之間不能共享資源，這種方式造成了極大的網絡資源浪費。人們設想物聯網是一個巨大的信息生產工場，物聯網產生的數據將應用到各行各業。物聯網需要建立共性的管理平臺，使得不同的上層應用能夠共享下層的傳感器網絡及其產生的數據。現存的網絡應用以網際網路應用為主，網際網路是現存的最大的網絡，各種應用在網際網路中展開。要使得傳感器網絡能夠更好的為各種應用服務，就要使傳感器網絡接入網際網路，傳感器網絡的數據能夠為在網際網路上開展的應用所訪問、共享。物聯網要實現對物理世界的信息的收集、存儲和查詢。在現有的傳感器網絡中，傳感器採集到數據後，對數據的存儲主要包括三種方法本地存儲、以數據為中心的存儲和網外存儲。其中，本發明基於網外存儲。現有技術的網外存儲是指傳感器將產生的數據發送到sink節點，該sink節點是一個物聯網接入網關節點,將數據存儲在網絡外部。對於頻繁訪問的數據外部存儲的方式很適用。基於以上分析現有技術對無線傳感器網絡的外部存儲研究，僅僅停留在傳感器將採集到的數據發送給sink節點，也就是網關節點，而有關這些採集的數據如何在現有的外部網絡中進行高效存儲的問題並未涉及。這是在傳感器網絡發展初期，傳感器網絡用於滿足不同的應用它們彼此之間沒有聯網的必要，而在單個傳感器網絡中數據量相對是比較小的，但是進入物聯網階段後，很多的傳感器網絡都需要通過網際網路進行互聯，在這種情況下眾多的傳感器網絡所產生的數據將是海量的。因此目前迫切需要提供一種能在網際網路網絡中存儲傳感器網絡生成的大量數據的問題，其中DHT(distributedhashtable,分布式哈希表)是現有的網際網路上的一種分布式的數據存儲方法，適合海量數據的分布式存儲和查詢，但是如何將其應用於現有的物聯網中進行數據存儲並未見過任何相關記載。同時現有的DHT系統對存儲的數據不做時效性的區分，而物聯網中所產生的數據是應用相關的，不同的數據具有不同的時效性。現有技術有關典型的物聯網網絡分層結構如圖I所示，共分五層，從下往上依次為感知層、接入層、網絡層、支撐層、應用層。感知層有各種底層設備和網絡，包括傳感器網絡、RFID、執行器等。在感知層，傳感器通過傳感網協議組成網絡，收集物理世界的信息。感知層的各種設備和網絡通過多種接入技術接入網際網路，所使用的接入方式包括3G/4G、Mesh網絡、WiFi、有線或者衛星等。網絡層為網際網路，網絡層的功能包括信息的遠距離傳輸，跨區域信息的承載和共享。支撐層又稱中間介，或者業務層，該層主要完成三部分功能對下需要對網絡資源進行認知，對網絡資源進行優化；完成信息的共享存儲、表達與處理，最終達到信息共享的目的；對上提供業務接口與支撐，方便上層業務的開發。應用層上是基於業務支撐層提供的業務能力所開發的各種應用，像智能建築、智能交通、智能家居、環境監測、遠程醫療、農產品溯源等。
發明內容本發明的目的在於，為克服在物聯網包含的感知層產生數據如何在支撐層高效存儲的問題以便物聯網的上層的各種應用需要對傳感器產生的數據能夠方便的共享，同時為克服現有技術的分布式存儲網絡本身在存儲物聯網感知層產生的數據的時存在的技術缺陷問題，本發明提供一種物聯網中分布式數據存儲和查詢的方法及系統。為實現上述發明目的，本發明提供一種物聯網中分布式數據存儲和查詢的方法，該方法用於將物聯網下層若干個底層感知網絡採集的數據在上層的若干區域伺服器之間實現分布式存儲，包含數據存儲的步驟，所述底層網絡採集的數據在底層網絡內部以其內部的協議進行傳輸，傳輸到接入網關，經由接入網關接入部署在網際網路上的區域伺服器，所述採集的數據在區域伺服器組成的網絡中進行存儲；數據查詢和讀取的步驟，上層應用需要底層網絡採集的數據時，通過任意一個區域伺服器查詢數據名所映射的存儲節點的IP，從該IP的節點上獲得所需的傳感器數據；其中，所述區域伺服器採用分布式組網，且所述的區域伺服器將所述採集數據分為實時數據和非實時數據在所述區域伺服器上進行存儲；對每一次存儲按功能將區域伺服器劃分為接入區域伺服器和存儲區域伺服器，所述接入區域伺服器為通過網關接受底層待存儲數據的區域伺服器，所述存儲區域伺服器為確定的存儲節點。上述技術方案中，所述分布式組網採用分布式哈希表進行組網，所述底層網絡為無線傳感器網絡。所述數據存儲步驟為步驟101，底層的感知網絡採集到數據後，傳輸到接入網關，經由網關發往區域伺服器，由區域伺服器中的網關數據接口接收網關發來的傳感器數據；步驟102，所述接入區域伺服器確定存儲區域伺服器，並將待存儲數據發往確定的存儲區域伺服器；步驟103，存儲區域伺服器存儲接入伺服器發來的數據。所述步驟102的確定存儲節點步驟為接入區域伺服器查詢是否有該數據名的映射信息的有效緩存，如果有則將採集的數據發往存儲節點進行存儲；如果沒有該數據名的映射信息的有效緩存則進入下一步驟；所述接入區域伺服器採用其包含的分布式哈希表組網模塊查詢數據名映射到的存儲節點，將採集的數據存儲到查詢得到的存儲節點上。其中，所述數據名可以是傳感器的ID屬性，傳感器檢測的事件名屬性。作為本發明的一個改進，所述步驟102之前還包含接入區域伺服器對待存儲採集數據進行時效性標誌的步驟。所述步驟103的具體步驟為存儲在本節點的數據進行時效性檢查，如果這些採集的數據為非實時數據則直接在該存儲區域伺服器上進行存儲；如果採集數據為實時數據，檢測這些待存儲的實時數據時效性是否過期，如果時效性過期不對這些數據進行存儲；如果沒有過期在該區域伺服器上存儲。基於上述方式，本發明還提供一種物聯網中分布式數據存儲和查詢的系統，該系統基於物聯網，其特徵在於，所述系統還包含若干區域伺服器，該區域伺服器與物聯網上層應用相連同時與物聯網包含的接入網絡相連，用於接收並存儲物聯網底層網絡採集的數據；其中，所述若干區域伺服器採用分布式哈希表組網。上述技術方案所述的系統中所述底層網絡為傳感器網絡；所述區域伺服器進一步包含DHT模塊，用於區域伺服器之間的組網以及從傳感器數據名到存儲傳感器數據的區域伺服器節點的映射；數據時效性區分模塊，用於將底層採集的數據分為實時數據和非實時數據；和資料庫模塊，負責存儲傳感器數據。所述區域伺服器還包含一緩存模塊，用於緩存從DHT模塊上查詢的傳感器數據名到存儲傳感器數據的存儲節點的映射信息；應用接口模塊，用於和上層的應用通信；網關接口模塊，用於與下層的接入網關對接。本發明的優點在於首先，設計了一種物聯網海量數據分布式存儲的系統，解決了物聯網底層數據在網際網路高效存儲的問題，方便不同應有對數據的共享問題；此外還改進了現有的分布式存儲系統不能根據物聯網底層數據的應用的類型對數據的時效性進行區分，針對數據的時效性對現有DHT的存儲方法進行了改進，使得DHT能夠對不同時效性的數據實施不同的存儲策略，針對產生的大量數據有效的節省了存儲空間同時不降低數據查詢讀取的高效性。圖I是本發明的物聯網組網方式示意圖；圖2是本發明的物聯網中分布式數據存儲和查詢的系統的組成框圖；圖3是本發明的物聯網中分布式數據存儲和查詢的系統包含的區域伺服器的組成框圖；圖4_a是本發明的物聯網中分布式數據存儲方法的流程圖；圖4_b是本發明的物聯網中分布式數據查詢方法的流程圖；圖5_a是本發明的物聯網中分布式數據存儲和查詢的當接入區域伺服器包含時效性區分的數據存儲的流程圖；圖5_b是本發明的存儲區域伺服器進行存儲時對時效性處理存儲的步驟；圖6是本發明技術效果的仿真圖。具體實施例方式下面結合附圖和具體實施例對本發明進行詳細的說明。如圖I所示，該圖是本發明中的物聯網對海量數據進行分布式存儲的網絡部署圖，底層網絡的數據通過中間的接入層連接到網際網路，接入方式可以是有線的，也可以是無線方式；上層為區域伺服器(Regionalserver)，它們使用IP協議，部署在網際網路上，負責一定區域的物聯網應用。且上層的區域伺服器對於每一次具體存儲過程按照它們的功能不同可以劃分為接入區域伺服器和存儲區域伺服器(存儲節點)，但是這兩類伺服器的功能是在不同存儲發生時是可以相互轉換的，所以所有區域伺服器的組成均相同。如圖2所示，該圖為物聯網數據採集到存儲的系統組成框圖。基於該系統的數據收集存儲過程為無線傳感器網絡或者執行網絡等物聯網包含的感知網絡的數據在其網絡內部以其內部的協議進行傳輸，傳輸到接入網關(accessGateway,aGW),經由接入網關接入部署在網際網路上的區域伺服器，數據存儲在區域伺服器上(區域伺服器對應的網絡分層是支撐層)，所有的區域伺服器採用分布式組網的方式進行數據存儲，且應根據數據的時效性進行不同的存儲。其中，本發明中的分布式組網選用DHT組網方式。底層的感知網絡均以無線傳感器網絡進行展開說明，而其他的底層感知網絡的數據存儲也在本發明的保護範圍內。如圖3所示，該圖為區域伺服器採用DHT組網的時候的組成框圖。區域伺服器上的數據存儲和查詢系統包括一個DHT模塊(DHTmodule)、一個資料庫模塊(DataBase)、對上層應用的接口模塊、數據時效性的區分模塊、接收網關發來傳感器數據的模塊。其中，DHT模塊負責區域伺服器之間的組網以及從傳感器數據名到存儲傳感器數據的區域伺服器節點的映射，資料庫模塊負責存儲傳感器數據。本發明中採用數據時效性的區分模塊對傳統的DHT存儲方式進行了修改，在以DHT的方式進行數據存儲的時候對數據的時效性進行了區分，分為實時數據和非實時數據，由DHT中的數據區分模塊來完成。在具體實施數據存儲的時候如果數據的時效性是實時性的，則不對數據進行原有的DHT中的備份處理，並且為該類型的數據建立計時器，當時間超過了應用所要求的時效性時刪除該數據。如果數據的時效性是非實時的則對該數據採用傳統的DHT中的備份機制進行備份存儲。各模塊功能解釋應用接口接收應用下發的對數據的時效性的要求，有實時性和非實時性兩種類型。數據時效性分類模塊當區域伺服器作為接入區域伺服器時根據應用下發的對數據的時效性的要求，對和該應用相關的數據進行時效性標記。網關數據接口負責接收由網關發來的傳感器數據。DHT組網模塊實現了傳統的DHT功能，將區域伺服器按照DHT的方式組網。緩存模塊，用於緩存從DHT模塊上查詢的傳感器數據名到存儲傳感器數據的存儲節點的映射信息，這樣使得在緩存信息有效期內再有相同的數據名的數據存儲時，直接可以從緩存中獲得存儲節點的信息，不需要再向DHT模塊進行查詢，減小查詢開銷。數據時效性區分模塊，當區域伺服器作為存儲節點時，它會首先對數據時效性進行判斷，以確定數據是否需要備份。其中數據時效性區分模塊在傳統的DHT存儲機制中加入的識別數據的時效性的模塊，以對不同時效性的數據做不同的存儲處理。數據的時效性由應用的特點來決定，應用對數據時效性的要求從應用接口下發給區域伺服器，數據時效性分類模塊接收應用對某些數據的時效性的要求，將不同的傳感器數據進行不同的時效性標記，分為實時性數據和非實時性數據。如圖4-a所示，該圖為基於以上系統該圖為分布式組網採用DHT組網方式的數據存儲步驟為步驟401，底層的感知網絡採集到數據後，傳輸到接入網關，經由網關發往區域伺服器，由區域伺服器中的網關數據接口接收網關發來的傳感器數據。步驟402，接入區域伺服器向其包含的映射信息緩存模塊查詢是否有該數據名的映射信息的有效緩存，如果有則將採集的數據發往存儲節點進行存儲；如果沒有該數據名的映射信息的有效緩存則進入下一步驟；步驟403，接入區域伺服器採用其包含的分布式哈希表組網模塊查詢數據名映射到的存儲節點，將採集的數據存儲到查詢得到的存儲節點上；同時將查詢數據名映射到的存儲節點在區域伺服器包含的映射信息緩存模塊中進行存儲。如圖4_b，該圖為與以上步驟對應的查詢步驟為(I)上層應用發出數據查詢獲取請求，且區域伺服器上的應用接口收到應用的請求；(2)區域伺服器向其包含的映射信息緩存模塊查詢是否有該數據名的映射信息的有效緩存，如果緩存中存在數據名和存儲節點的映射信息的有效緩存，區域伺服器向對應的存儲節點獲取數據，並由應用接口發送給應用，數據查詢獲取結束；如果緩存中不存在數據名和存儲節點的映射信息的有效緩存，則進入下一步驟；(3)分布式哈希表模塊將查詢數據名所對應的存儲節點的映射信息，區域伺服器向對應的存儲節點獲取數據，並由應用接口發送給應用，同時將查詢得到的數據名所對應的存儲節點的映射信息進行緩存，數據查詢獲取結束。實施例基於以上步驟，如果底層感知網絡為無線傳感器網絡則上述數據存儲步驟描述如下傳感器網絡採集到數據後，在傳感器網絡內部以傳感器網的路由協議傳輸到接入網關，經由網關發往區域伺服器。區域伺服器向DHT模塊查詢傳感器數據名對應的存儲節點的IP，數據名可以是傳感器的ID屬性，可以是傳感器檢測的事件名屬性等等，根據系統的設計確定。查詢傳感器數據名所對應的存儲節點的過程是以傳感器數據名為DHT查詢中的key,由DHT的算法返回該數據名所對應的存儲節點的IP，即DHT中key所對應的value。在DHT返回傳感器數據名對應的存儲該傳感器數據的區域伺服器節點的IP後，傳感器所在的區域伺服器將傳感器採集的數據存入傳感器數據名映射到的IP的節點的資料庫上。頻繁的查詢DHT的操作，一方面會增加DHT模塊的負載，另一方面會帶來延遲。為了避免頻繁的查詢DHT的操作，在區域伺服器上建立區域伺服器當前負責的下層網絡的數據名所映射的IP列表緩存，這樣在緩存有效期內直接從緩存中讀取存儲節點。基於以上步驟，如果底層感知網絡為無線傳感器網絡則上述數據查詢步驟描述如下上層應用需要傳感器數據時，只需要通過任意一個區域伺服器查詢數據名所映射的存儲節點的IP，從該IP的節點上即可獲得傳感器數據。應用所連接的可以是網絡上的任意一臺區域伺服器，不必是當前負責該傳感器的區域伺服器。入口的區域伺服器也可以緩存DHT的查詢結果，從而再有相同的傳感器數據查詢時，可以從緩存中直接返回存儲節點的結果。基於以上存儲方法，為了實現物聯網底層感知網絡的海量數據的有效存儲，為存儲網絡節省更多的存儲空間，本發明還做出以下改進。如圖5-a所示，該圖對分布式存儲方式還進一步考慮了數據時效性問題，即在圖4的步驟401之後步驟402之前還包含步驟501該步驟用於對採集的數據進行時效性分析的步驟，將待存儲的數據分為實時數據和非實時數據，其中存儲節點對這兩種數據採用不同的備份機制進行存儲。改進後的數據存儲的步驟如下步驟401，底層的感知網絡採集到數據後，傳輸到接入網關，經由網關發往區域伺服器，由接入區域伺服器中的網關數據接口接收網關發來的傳感器數據。步驟501，接入區域伺服器中的數據時效性分類模塊根據應用下發的數據的時效性的要求,對數據進行時效性的標記,標記類型包括實時性數據和非實時性數據。步驟402，接入區域伺服器向其包含的映射信息緩存模塊查詢是否有該數據名的映射信息的有效緩存，如果有則將採集的數據發往存儲節點進行存儲；如果沒有該數據名的映射信息的有效緩存則進入下一步驟；步驟403，接入區域伺服器採用其包含的分布式哈希表組網模塊查詢數據名映射到的存儲節點，將採集的數據存儲到查詢得到的存儲節點上；同時將查詢數據名映射到的存儲節點在區域伺服器包含的映射信息緩存模塊中進行存儲。DHT是一種動態的分布式網絡存儲方法，由於DHT中節點的動態性，在數據存儲的過程中要對節點上的數據進行備份，DHT中有不同的備份機制，在傳統的DHT方式的數據存儲中對數據的類型不做區分，也就是說對所有的數據都會備份。本發明將DHT引入到物聯網的海量信息存儲中，並且根據應用對數據的不同要求對傳感器數據做了分類。實時性的數據類型是指只有當前數據是有用的，歷史數據對應用不再有作用，所以對實時性的數據就不再需要DHT對數據的備份機制。當一個存儲節點失效時，根據DHT的機制數據將被存儲到別的存儲節點上，而應用查詢數據名時，根據DHT的機制將會獲得傳感器數據名所對應的的新的存儲節點，獲取當前數據即可。而且在存儲節點上根據數據的生命期，對過期的數據進行刪除，這樣就會節省很大的存儲空間。對非實時數據類型而言，歷史數據對應用是有用的，需要對歷史數據進行備份，這個工作使用傳統的DHT中對數據的備份機制即可。基於上述分析，圖4-a、圖4-b和圖5_a描述的步驟僅僅涉及了接入區域伺服器將採集的數據發往由其確定的存儲節點(即存儲區域伺服器)，而這些數據在存儲區域伺服器上如何針對時效性進行區分備份存儲的具體過程並未描述。如圖5-b所示，該過程描述為首先，存儲區域伺服器接受接入區域伺服器傳送過來的待存儲數據還需進行以下處理然後，存儲區域伺服器包含的數據時效性區分模塊對存儲在本節點的數據進行時效性檢查，如果這些採集的數據為非實時數據則直接在該存儲區域伺服器上進行存儲；如果採集數據為實時數據，則進入下一步驟；最後，檢測這些待存儲的實時數據時效性是否過期，如果時效性過期則將刪除這些數據，即不對這些數據進行存儲；如果沒有過期才在該區域伺服器上存儲。區域伺服器向DHT模塊查詢傳感器數據名對應的存儲節點，將數據存入經由DHT查詢返回的存儲節點。這裡的存儲節點是指以DHT方式組網的區域伺服器。每個存儲節點上的數據時效性區分模塊對進入本節點存儲的數據的時效性進行識別。如果數據的時效性是實時性的，則不對數據進行原有的DHT中的備份處理，並且為該類型的數據建立計時器，當時間超過了應用所要求的時效性時刪除該數據。如果數據的時效性是非實時的則對該數據採用傳統的DHT中的備份機制進行備份存儲。試驗結果對本發明提出的物聯網的數據收集存儲和查詢獲取方案，進行了原型系統的設計和開發。在實際系統中，下層的DHT採用chord算法，資料庫使用mysql，以c++語言完成的分布式數據系統工作良好，存儲負載在各個存儲節點上得到均衡，有節點失效時，可以在I秒鐘以內重新建立新的數據存取結點。圖6是有三臺機器的分布式存儲系統在收集數據12小時後的存儲統計圖，存儲負載在各個存儲點上得到均衡。最後所應說明的是，以上實施例僅用以說明本發明的技術方案而非限制。儘管參照實施例對本發明進行了詳細說明，本領域的普通技術人員應當理解，對本發明的技術方案進行修改或者等同替換，都不脫離本發明技術方案的精神和範圍，其均應涵蓋在本發明的權利要求範圍當中。權利要求1.一種物聯網中分布式數據存儲和查詢的方法，該方法用於將物聯網下層若干個底層感知網絡採集的數據在上層的若干區域伺服器之間實現分布式存儲，包含數據存儲的步驟，所述底層網絡採集的數據在底層網絡內部以其內部的協議進行傳輸，傳輸到接入網關，經由接入網關接入部署在網際網路上的區域伺服器，所述採集的數據在區域伺服器組成的網絡中進行存儲；數據查詢和讀取的步驟，上層應用需要底層網絡採集的數據時，通過任意一個區域伺服器查詢數據名所映射的存儲節點的IP，從該IP的節點上獲得所需的傳感器數據；其中，所述區域伺服器採用分布式組網，且所述的區域伺服器將所述採集數據分為實時數據和非實時數據在所述區域伺服器上進行存儲；對每一次存儲按功能將區域伺服器劃分為接入區域伺服器和存儲區域伺服器，所述接入區域伺服器為通過網關接受底層待存儲數據的區域伺服器，所述存儲區域伺服器為確定的存儲節點。2.根據權利要求I所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述分布式組網採用分布式哈希表進行組網。3.根據權利要求I所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述底層網絡為無線傳感器網絡。4.根據權利要求1、2或3所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述數據存儲步驟具體為步驟101，底層的感知網絡採集到數據後，傳輸到接入網關，經由網關發往區域伺服器，由區域伺服器中的網關數據接口接收網關發來的傳感器數據；步驟102，所述接入區域伺服器確定存儲區域伺服器，並將待存儲數據發往確定的存儲區域伺服器；步驟103，存儲區域伺服器存儲接入伺服器發來的數據。5.根據權利要求4所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述步驟102之前還包含接入區域伺服器對待存儲採集數據進行時效性標誌的步驟，其中的時效性將數據分為實時數據和非實時數據。6.根據權利要求4所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述確定存儲節點步驟為接入區域伺服器查詢是否有該數據名的映射信息的有效緩存，如果有則將採集的數據發往存儲節點進行存儲；如果沒有該數據名的映射信息的有效緩存則進入下一步驟；所述接入區域伺服器採用其包含的分布式哈希表組網模塊查詢數據名映射到的存儲節點，將採集的數據存儲到查詢得到的存儲節點上。7.根據權利要求5所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述數據名可以是傳感器的ID屬性，傳感器檢測的事件名屬性。8.根據權利要求4或5所述的物聯網中分布式數據存儲和查詢的方法，其特徵在於，所述步驟103的具體步驟為存儲在本節點的數據進行時效性檢查，如果這些採集的數據為非實時數據則直接在該存儲區域伺服器上進行存儲；如果採集數據為實時數據，檢測這些待存儲的實時數據時效性是否過期，如果時效性過期不對這些數據進行存儲；如果沒有過期在該區域伺服器上存儲。9.一種物聯網中分布式數據存儲和查詢的系統，該系統基於物聯網，其特徵在於，所述系統還包含若干區域伺服器，該區域伺服器與物聯網上層應用相連同時與物聯網包含的接入網絡相連，用於接收並存儲物聯網底層網絡採集的數據；其中，所述若干區域伺服器採用分布式哈希表組網。10.根據權利要求9所述的物聯網中分布式數據存儲和查詢的系統，其特徵在於，所述底層網絡為傳感器網絡。11.根據權利要求9或10所述的物聯網中分布式數據存儲和查詢的系統，其特徵在於，所述區域伺服器進一步包含DHT模塊，用於區域伺服器之間的組網以及從傳感器數據名到存儲傳感器數據的區域伺服器節點的映射；數據時效性區分模塊，用於將底層採集的數據分為實時數據和非實時數據；和資料庫模塊，負責存儲傳感器數據。12.根據權利要求10所述的物聯網中分布式數據存儲和查詢的系統，其特徵在於，所述區域伺服器還包含一緩存模塊，用於緩存從DHT模塊上查詢的傳感器數據名到存儲傳感器數據的存儲節點的映射信息；應用接口模塊，用於和上層的應用通信；網關接口模塊，用於與下層的接入網關對接。全文摘要本發明提出一種物聯網中分布式數據存儲和查詢的方法，該方法用於將物聯網下層若干個底層感知網絡採集的數據在上層的若干區域伺服器之間實現分布式存儲，包含數據存儲的步驟，所述底層網絡採集的數據在底層網絡內部以其內部的協議進行傳輸，傳輸到接入網關，經由接入網關接入部署在網際網路上的區域伺服器，所述採集的數據在區域伺服器組成的網絡中進行存儲；和數據查詢和讀取的步驟。其中，所述區域伺服器採用分布式組網，且所述的區域伺服器將所述採集數據分為實時數據和非實時數據在所述區域伺服器上進行存儲。本發明首次將分布式存儲網絡應用到物聯網的海量數據的存儲當中，而且為了節省分布式存儲網絡的存儲資源將數據進行了時效性劃分。文檔編號H04L29/08GK102752322SQ201110095990公開日2012年10月24日申請日期2011年4月18日優先權日2011年4月18日發明者劉宇,唐暉,牛溫佳,譚紅豔,趙志軍申請人:中國科學院聲學研究所