陸曉鈞　上海貝爾股份有限公司

產(chǎn)品與技術(shù)方案

泛在網(wǎng)網(wǎng)關(guān)中間件架構(gòu)設(shè)計

陸曉鈞上海貝爾股份有限公司

對泛在網(wǎng)網(wǎng)關(guān)中間件架構(gòu)進(jìn)行了設(shè)計，針對無線物聯(lián)網(wǎng)終端的需求，分析了物聯(lián)網(wǎng)網(wǎng)關(guān)的基本產(chǎn)品需求，提出了泛在網(wǎng)網(wǎng)關(guān)的設(shè)計思路，闡述了層次結(jié)構(gòu)、信息交互流程。針對網(wǎng)關(guān)中間件的架構(gòu)設(shè)計和相關(guān)的數(shù)據(jù)上報、心跳上報等功能重點剖析了設(shè)計原理和可實現(xiàn)的架構(gòu)原理。

物聯(lián)網(wǎng)；泛在網(wǎng)；網(wǎng)關(guān)中間件

1　泛在網(wǎng)網(wǎng)關(guān)概述

泛在網(wǎng)是具有全面感知、可靠傳輸、智能處理特征的連接物理世界的網(wǎng)絡(luò)。泛在網(wǎng)用途廣泛，遍及智能交通、環(huán)境保護(hù)、政府工作、公共安全、平安家居、智能消防、工業(yè)監(jiān)測、老人護(hù)理、個人健康、花卉栽培、水系監(jiān)測、食品溯源、敵情偵查和情報搜集等多個領(lǐng)域。泛在網(wǎng)的接入方式是多種多樣的，如廣域的PSTN、短距離的Z-Wave等，泛在網(wǎng)網(wǎng)關(guān)設(shè)備是將多種接入手段整合起來，統(tǒng)一互聯(lián)到接入網(wǎng)絡(luò)的關(guān)鍵設(shè)備。它可滿足局部區(qū)域短距離通信的接入需求，實現(xiàn)與公共網(wǎng)絡(luò)的連接，同時完成轉(zhuǎn)發(fā)、控制、信令交換和編解碼等功能，而終端管理、安全認(rèn)證等功能保證了泛在網(wǎng)業(yè)務(wù)的質(zhì)量和安全。

泛在網(wǎng)網(wǎng)關(guān)在未來的泛在網(wǎng)時代將會扮演著非常重要的角色，可以實現(xiàn)感知延伸網(wǎng)絡(luò)與接入網(wǎng)絡(luò)之間的協(xié)議轉(zhuǎn)換，既可以實現(xiàn)廣域互聯(lián)，也可以實現(xiàn)局域互聯(lián)，將廣泛應(yīng)用于智能家居、智能社區(qū)、數(shù)字醫(yī)院、智能交通等各行各業(yè)。泛在網(wǎng)組網(wǎng)采用分層的通信系統(tǒng)架構(gòu)，包括感知延伸系統(tǒng)、傳輸系統(tǒng)、業(yè)務(wù)運營管理系統(tǒng)和各種應(yīng)用，在不同的層次上支持不同的通信協(xié)議，如圖1所示。感知延伸系統(tǒng)包括感知和控制技術(shù)，由感知延伸層設(shè)備以及網(wǎng)關(guān)組成，支持包括Lonworks、UPnP、Zig Bee等通信協(xié)議在內(nèi)的多種感知延伸網(wǎng)絡(luò)。感知設(shè)備可以通過多種接入技術(shù)連接到核心網(wǎng)，實現(xiàn)數(shù)據(jù)的遠(yuǎn)程傳輸。

泛在網(wǎng)網(wǎng)關(guān)具備如下幾個功能。

圖1　泛在網(wǎng)網(wǎng)關(guān)邏輯架構(gòu)

（1）廣泛的接入能力。目前，用于近程通信的技術(shù)標(biāo)準(zhǔn)很多，僅常見的WSN技術(shù)就包括Lonworks、ZigBee、6LowPAN、RUBEE等。各類技術(shù)主要針對某一應(yīng)用展開，缺乏兼容性和體系規(guī)劃，如Lonworks主要應(yīng)用于樓宇自動化，RUBEE適用于惡意環(huán)境。如何實現(xiàn)協(xié)議的兼容性、接口和體系規(guī)劃，目前在國內(nèi)外已經(jīng)有多個組織在開展泛在網(wǎng)網(wǎng)關(guān)的標(biāo)準(zhǔn)化工作，如3GPP、傳感器工作組，以實現(xiàn)各種通信技術(shù)標(biāo)準(zhǔn)的互聯(lián)互通。

（2）協(xié)議轉(zhuǎn)換能力。從不同的感知網(wǎng)絡(luò)到接入網(wǎng)絡(luò)的協(xié)議轉(zhuǎn)換，將下層的標(biāo)準(zhǔn)格式的數(shù)據(jù)統(tǒng)一封裝，保證不同的感知網(wǎng)絡(luò)的協(xié)議能夠變成統(tǒng)一的數(shù)據(jù)和信令；將上層下發(fā)的數(shù)據(jù)包解析成感知層協(xié)議可以識別的信令和控制指令。

（3）可管理能力。強大的管理能力，對于任何大型網(wǎng)絡(luò)都是必不可少的。首先要對網(wǎng)關(guān)進(jìn)行管理，如注冊管理、權(quán)限管理、狀態(tài)監(jiān)管等。網(wǎng)關(guān)實現(xiàn)子網(wǎng)內(nèi)節(jié)點的管理，如獲取節(jié)點的標(biāo)識、狀態(tài)、屬性、能量等以及遠(yuǎn)程喚醒、控制、診斷、升級和維護(hù)等。由于子網(wǎng)的技術(shù)標(biāo)準(zhǔn)不同，協(xié)議的復(fù)雜性不同，所以網(wǎng)關(guān)具有的管理能力不同。

2　泛在網(wǎng)網(wǎng)關(guān)設(shè)計思路

泛在網(wǎng)網(wǎng)關(guān)可以實現(xiàn)感知網(wǎng)絡(luò)和基礎(chǔ)網(wǎng)絡(luò)以及不同類型的感知網(wǎng)絡(luò)之間的協(xié)議轉(zhuǎn)換，既可以實現(xiàn)廣域互聯(lián)，也可以實現(xiàn)局域互聯(lián)。本泛在網(wǎng)網(wǎng)關(guān)設(shè)計面向感知網(wǎng)絡(luò)的異構(gòu)數(shù)據(jù)感知環(huán)境，為有效屏蔽底層通信差異化進(jìn)行有效網(wǎng)絡(luò)融合和數(shù)據(jù)通信，采用模塊化設(shè)計、統(tǒng)一數(shù)據(jù)表示、統(tǒng)一地址轉(zhuǎn)換等實現(xiàn)。下面從泛在網(wǎng)網(wǎng)關(guān)的層次結(jié)構(gòu)、信息交互流程兩方面來進(jìn)行闡述。

（1）層次結(jié)構(gòu)

泛在網(wǎng)網(wǎng)關(guān)支持感知延伸設(shè)備之間的多種通信協(xié)議和數(shù)據(jù)類型，實現(xiàn)多種感知延伸設(shè)備之間數(shù)據(jù)通信格式的轉(zhuǎn)換，對上傳的數(shù)據(jù)格式進(jìn)行統(tǒng)一，同時對下達(dá)到感知延伸網(wǎng)絡(luò)的采集或控制命令進(jìn)行映射，產(chǎn)生符合具體設(shè)備通信協(xié)議的消息。泛在網(wǎng)網(wǎng)關(guān)對感知延伸設(shè)備進(jìn)行統(tǒng)一控制與管理，向上層屏蔽底層感知延伸網(wǎng)絡(luò)的異構(gòu)性，共分為4層，分別為業(yè)務(wù)服務(wù)層、標(biāo)準(zhǔn)消息構(gòu)成層、協(xié)議適配和感知延伸層。

●業(yè)務(wù)服務(wù)層。業(yè)務(wù)服務(wù)層由消息接收模塊和消息發(fā)送模塊組成。消息接收模塊負(fù)責(zé)接收來自泛在網(wǎng)業(yè)務(wù)運營管理系統(tǒng)的標(biāo)準(zhǔn)消息，將消息傳遞給標(biāo)準(zhǔn)消息構(gòu)成層。消息發(fā)送模塊負(fù)責(zé)向業(yè)務(wù)運營管理系統(tǒng)可靠地傳送感知延伸網(wǎng)絡(luò)所采集的數(shù)據(jù)信息。該層接收與發(fā)送的消息必須符合標(biāo)準(zhǔn)的消息格式。

●標(biāo)準(zhǔn)消息構(gòu)成層。標(biāo)準(zhǔn)消息構(gòu)成層由消息解析模塊和消息轉(zhuǎn)換模塊組成。消息解析模塊解析來自業(yè)務(wù)服務(wù)層的標(biāo)準(zhǔn)消息，調(diào)用消息轉(zhuǎn)換模塊將標(biāo)準(zhǔn)消息轉(zhuǎn)換為底層感知延伸設(shè)備能夠理解的依賴于具體設(shè)備通信協(xié)議的數(shù)據(jù)格式。當(dāng)感知延伸層上傳數(shù)據(jù)時，該層的消息解析模塊則解析依賴于具體設(shè)備通信協(xié)議的消息，調(diào)用消息轉(zhuǎn)換模塊將其轉(zhuǎn)換為業(yè)務(wù)服務(wù)層能夠接收的標(biāo)準(zhǔn)格式的消息。消息構(gòu)成層是泛在網(wǎng)網(wǎng)關(guān)的核心，完成對標(biāo)準(zhǔn)消息以及依賴于特定感知延伸網(wǎng)絡(luò)的消息的解析，并實現(xiàn)兩者之間的相互轉(zhuǎn)換，達(dá)到統(tǒng)一控制和管理底層感知延伸網(wǎng)絡(luò)，向上屏蔽底層網(wǎng)絡(luò)通信協(xié)議異構(gòu)性的目的。

●協(xié)議適配層。協(xié)議適配層保證不同的感知延伸層協(xié)議能夠通過此層變成格式統(tǒng)一的數(shù)據(jù)和控制信令。

●感知延伸層。此層面向底層感知延伸設(shè)備，包含消息發(fā)送與消息接收兩個子模塊。消息發(fā)送模塊負(fù)責(zé)將經(jīng)過消息構(gòu)成層轉(zhuǎn)換后的可被特定感知延伸設(shè)備理解的消息發(fā)送給底層設(shè)備。消息接收模塊則接收來自底層設(shè)備的消息，發(fā)送至標(biāo)準(zhǔn)消息構(gòu)成層進(jìn)行解析。感知延伸網(wǎng)絡(luò)由感知設(shè)備組成，包括射RFID、GPS、視頻監(jiān)控系統(tǒng)、各類型傳感器等。感知延伸設(shè)備之間支持多種通信協(xié)議，可以組成Lonworks和Zigbee以及其他多種感知延伸網(wǎng)絡(luò)。

（2）信息交互流程

信息交互流程分為以下幾個階段，如圖2所示。

●最終用戶產(chǎn)生符合標(biāo)準(zhǔn)數(shù)據(jù)格式的消息，并將其發(fā)送至網(wǎng)關(guān)業(yè)務(wù)服務(wù)層的消息接收模塊。

●業(yè)務(wù)服務(wù)層消息接收模塊將標(biāo)準(zhǔn)消息發(fā)送至標(biāo)準(zhǔn)消息構(gòu)成層的消息解析模塊。

●消息解析模塊調(diào)用相應(yīng)的消息轉(zhuǎn)換功能，將標(biāo)準(zhǔn)信息轉(zhuǎn)換為依賴于具體設(shè)備通信協(xié)議的消息。

●消息解析模塊將轉(zhuǎn)換為依賴于具體設(shè)備通信協(xié)議的消息傳送至感知延伸服務(wù)層的消息發(fā)送模塊。

●感知延伸服務(wù)層的消息發(fā)送模塊選擇合適的傳輸方式，將依賴設(shè)備通信協(xié)議的特定消息發(fā)送至具體的底層設(shè)備。

圖2　泛在網(wǎng)信息交互流程

●底層設(shè)備根據(jù)特定消息執(zhí)行信息采集操作，并將結(jié)果返回給網(wǎng)關(guān)感知延伸服務(wù)層的消息接收模塊。

●網(wǎng)關(guān)的感知延伸服務(wù)層的消息接收模塊將依賴設(shè)備通信協(xié)議的特定消息傳送至標(biāo)準(zhǔn)消息構(gòu)成層的消息解析模塊。

●消息解析模塊調(diào)用信息轉(zhuǎn)換模塊，將依賴于設(shè)備通信協(xié)議的特定消息轉(zhuǎn)換為標(biāo)準(zhǔn)消息。從圖2可以看出，泛在網(wǎng)網(wǎng)關(guān)解決了泛在網(wǎng)網(wǎng)絡(luò)內(nèi)不同設(shè)備無法統(tǒng)一控制和管理的問題，達(dá)到屏蔽底層通信差異的目的，并使得最終用戶無需知道底層設(shè)備的具體通信細(xì)節(jié)，實現(xiàn)對不同感知延伸層設(shè)備的統(tǒng)一訪問。

3　泛在網(wǎng)關(guān)中間件架構(gòu)設(shè)計

（1）數(shù)據(jù)上報

以下給出網(wǎng)關(guān)中間件數(shù)據(jù)庫主要表設(shè)計：在插件中根據(jù)數(shù)據(jù)上報周期獲取并解析數(shù)據(jù)之后，需要將數(shù)據(jù)上報至平臺，上報數(shù)據(jù)使用平臺定義的REST接口，處理如下的請求和回復(fù)消息。

請求消息：

Parameters

Method PUT

Base URL

API Endpoint/devices/＜device_id＞/datastreams/＜data_stream_id＞/datapoints

Headers

WOT-ApiKey API_KEY_HERE

WOT-Developer DEVELOPER_ID_HERE

Body

“｛

““timestamp””：““2012-03-15T16：13：14””，

““value””：““294.34””

｝”

回復(fù)消息：

Parameters

Status Code 200 OK

其中，根據(jù)serial_no，在device_property表中可以獲取device_id，wot_apikey，developer_id，product_id信息。通過product_id以及獲取數(shù)據(jù)中的tagtext，可以在device_stream表中獲取device_stream_id的信息。

（2）心跳上報

在成功獲取設(shè)備數(shù)據(jù)之后，更新agent_statistics表。以網(wǎng)關(guān)參數(shù)表中的心跳周期參數(shù)heart_beat_cycle為周期，啟動timertask任務(wù)，比對當(dāng)前時間與agent_statistics表的last_update_time字段的差，如果這個時間差在一個心跳周期之內(nèi)，則使用平臺提供的如下接口，上報心跳消息并處理回復(fù)消息：

請求消息

Parameters

Method GET

Base URL

API Endpoint/devices/＜device_id＞/heartbeat

Headers

WOT-ApiKey API_KEY_HERE

WOT-Developer DEVELOPER_ID_HERE

Body

回復(fù)消息

Parameters

Status Code200OK

（3）反控長連接及反控

為了實現(xiàn)設(shè)備反控，網(wǎng)關(guān)中間件模塊與平臺建立了TCP長連接，把所有需要反向控制的設(shè)備都在這個TCP長連接中注冊，當(dāng)平臺收到Restful的設(shè)備控制命令的時候，將通過這個TCP長連接來發(fā)送指令下來。關(guān)聯(lián)的表：wot_gw_db.device_property有一項屬性：register_status，當(dāng)設(shè)備的該屬性被設(shè)定為“Y”的時候，在啟動時向平臺注冊該可反控設(shè)備。

TCP長連接建立后，會初始化一系列的狀態(tài)維護(hù)，包括建立一個處理接受緩沖區(qū)中的數(shù)據(jù)到消息隊列，啟動一個消息分發(fā)線程從消息隊列中獲取并處理消息，還將對長連接進(jìn)行維持。

（4）REST方式的參數(shù)配置

網(wǎng)關(guān)使用了REST的風(fēng)格進(jìn)行接口設(shè)計，除了北向上報數(shù)據(jù)和部分南向數(shù)據(jù)獲取使用REST以外，網(wǎng)關(guān)參數(shù)配置也使用REST風(fēng)格服務(wù)，實現(xiàn)參數(shù)查詢和修改功能，使用JAX-RS實現(xiàn)。JAX-RS是JavaEE6引入的一個新技術(shù)，是一個Java編程語言的應(yīng)用程序接口，支持按照表述性狀態(tài)轉(zhuǎn)移（REST）架構(gòu)風(fēng)格創(chuàng)建Web服務(wù)。JAX-RS使用了JavaSE5引入的Java標(biāo)注來簡化Web服務(wù)的客戶端和服務(wù)端的開發(fā)和部署。這里采用基于JAX-RS實現(xiàn)的框架Jersey來創(chuàng)建的Web Service，可方便地部署到Servlet容器，如Tomcat中。

查詢請求接口設(shè)計如下：

請求消息：

Parameters

Method GET

Base URL

API Endpoint/parameters

Headers

No Headers

Body

This request does not require body data

回復(fù)消息：

Parameters

Status Code 200 OK

Headers

No Headers

Body

“｛

｛““parameterID””：““1””，““key””：““heartbeat_cycle””，““value””：““30””，““description””：““heartbeat cycle””｝，

｛““parameterID””：““2””，““key””：““data_update_interval””，““value””：““60””，““description””：““data update interval””｝

｝”

修改請求接口

請求消息：

Parameters

Method POST

Base URL

API Endpoint/parameters/＜parameterID＞

Headers

No Headers

Body

“｛

““key””：““heartbeat_cycle””，

““value””：““60””，

““description””：““heartbeat cycle””

｝”

回復(fù)消息：

Parameters

Status Code 200 OK

Headers

No Headers

Body

This response does not contain body data

4　插件化架構(gòu)

網(wǎng)關(guān)中間件包括一個支持Java Jar包插件的功能，可以提供在不重新編譯網(wǎng)關(guān)程序的情況下，增加額外數(shù)據(jù)解析模塊。

這些模塊以Jar包方式提供（編程時需要遵守一定的規(guī)范，才能被網(wǎng)關(guān)中間件插件框架識別），放置在網(wǎng)關(guān)WebAPP特定目錄之下，啟動這些插件有兩種方式：

第一種：網(wǎng)關(guān)程序啟動時

當(dāng)網(wǎng)關(guān)程序在Web容器內(nèi)初始化時，會在特定目錄（以下稱Plugin目錄）下尋找Jar包。將找到的Jar包依次解析，判斷其是否為插件。如果是，Load插件到內(nèi)存中，并啟動插件的入口方法。

第二種：在頁面上啟動插件

網(wǎng)關(guān)程序的Web頁面提供了一個上傳插件和啟動的交互UI。管理員可以通過這個頁面，把本機的插件Jar包上傳到Plugin目錄下，并且解析和啟動。

5　結(jié)束語

物聯(lián)網(wǎng)技術(shù)已經(jīng)進(jìn)入快速發(fā)展的階段，能夠接入多種類型的無線物聯(lián)網(wǎng)終端將成為其發(fā)展過程中必須解決的問題之一。物聯(lián)網(wǎng)網(wǎng)關(guān)作為接入多終端的重要設(shè)備，其設(shè)計應(yīng)該遵循設(shè)備適配靈活，接入方便等特點。本文所設(shè)計的物聯(lián)網(wǎng)網(wǎng)關(guān)將成為業(yè)界相關(guān)領(lǐng)域發(fā)展的重要先導(dǎo)型研究。

［1］Bonnet P，Gehrke J，Seshadri P.Querying the Physical World ［J］.Personal Communications，IEEE，20007（5）：10-15.

［2］CHOIi-Joung，JU Hong-Taek，CHA Hyun-Jun.An Efficient Embedded Web Server for Web-based Network Element Management［C］.Network Operations and Management Symposium，2000：187-200.

［3］WANG Wei，LI Jun.An XML Firewall on Embedded Network Processor［C］.4th International Conference on Networking and Services，2008：1-6.

［4］QIU Peng，ZHAO Yi，HEO Ung.Gateway Architecture for Zigbee Sensor Network for Remote Control over IP Network［C］.8th Asia-Pacific Symposium on Information and Telecommunication Technologies，2010：1-4.

［5］Singh D，Daeyeoul K.Performance Analysis of Gateway Discovery Techniques：IPv6-Based Wireless Sensor Networks［C］.2nd International Conference on Evolving Internet，2010：142-146.

［6］Hori Y，Onimaru K and Ikenaga T.Design and Implementation of an IPv6 Gateway Allowing Effective Use of Multihome Network［C］.IEEE Pacific Rim Conference on Communications Computers and Signal Processing，2003，2：601-604.

［7］Guinard D，Trifa V，Wilde E.A resource Oriented Architecture for the Web of Things［C］.Internet of Things（IOT），2010.IEEE，2010：1-8.

［8］Guinard D，Trifa V，Mattern F，et al.From the Internet of Things to the Web of Things：Resource-oriented Architecture and Best Practices［M］.Architecting the Internet of Things.Springer Berlin Heidelberg，2011：97-129.

［9］Stirbu V.Towards a Restful Plug and Play Experience in the Web of Things［C］.Semantic Computing，2008 IEEE International Conference on.IEEE，2008：512-517.

［10］Mulligan G.The 6Lo WP AN Architecture［C］.Proceedings of the 4th Workshopon Embedded Networked Sensors.ACM，2007：78-82.