物聯(lián)網(wǎng)平臺(tái)規(guī)則引擎與微信結(jié)合的應(yīng)用

劉善鋒

（南京中興軟件有限責(zé)任公司，南京 210012）

隨著物聯(lián)網(wǎng)的發(fā)展，為了集中管理眾多的物聯(lián)網(wǎng)設(shè)備，一般都是通過物聯(lián)網(wǎng)平臺(tái)IoT（Internet of things）集中進(jìn)行接入和管理，設(shè)備上報(bào)的數(shù)據(jù)需要根據(jù)用戶定制的數(shù)據(jù)規(guī)則上報(bào)到指定的用戶，這樣既可以減輕物聯(lián)網(wǎng)平臺(tái)的負(fù)荷，也可以讓用戶只關(guān)心與自己相關(guān)的設(shè)備數(shù)據(jù)。本文主要介紹物聯(lián)網(wǎng)平臺(tái)規(guī)則引擎與微信系統(tǒng)關(guān)聯(lián)，將消息及時(shí)發(fā)送給用戶，本系統(tǒng)主要包括設(shè)備數(shù)據(jù)上報(bào)、物聯(lián)網(wǎng)平臺(tái)、微信處理、微信用戶四大模塊，如下圖所示。

1 設(shè)備數(shù)據(jù)上報(bào)

設(shè)備數(shù)據(jù)上報(bào)主要完成物聯(lián)網(wǎng)設(shè)備主動(dòng)向物聯(lián)網(wǎng)平臺(tái)上報(bào)設(shè)備的各種能力數(shù)據(jù)，設(shè)備與物聯(lián)網(wǎng)平臺(tái)通訊協(xié)議支持MQTT（Message Queuing Telemetry Transport）、CoAP（Constrained Application Protocol）、LWM2M（Lightweight Machine to Machine）、HTTP（HyperText Transfer Protocol）、Modbus等。

2 物聯(lián)網(wǎng)平臺(tái)

物聯(lián)網(wǎng)平臺(tái)實(shí)現(xiàn)了物聯(lián)網(wǎng)的設(shè)備管理、連接管理以及應(yīng)用使能管理，適配各種通訊協(xié)議，屏蔽網(wǎng)路技術(shù)差異，使底層網(wǎng)絡(luò)對(duì)上層應(yīng)用透明，為物聯(lián)網(wǎng)行業(yè)提供終端連接、應(yīng)用創(chuàng)新、數(shù)據(jù)共享、運(yùn)營(yíng)支撐、集成服務(wù)等能力。

物聯(lián)網(wǎng)平臺(tái)與規(guī)則引擎相關(guān)的模塊主要包括設(shè)備數(shù)據(jù)處理模塊、規(guī)則配置模塊、規(guī)則引擎模塊、消息處理模塊、告警模塊。

設(shè)備數(shù)據(jù)處理模塊：接收物聯(lián)網(wǎng)設(shè)備上報(bào)101的數(shù)據(jù)，對(duì)數(shù)據(jù)進(jìn)行協(xié)議解析轉(zhuǎn)換處理，將處理后的數(shù)據(jù)上報(bào)給規(guī)則引擎模塊203。

規(guī)則配置模塊：配置設(shè)備能力上報(bào)的數(shù)據(jù)的各種規(guī)則的觸發(fā)條件，以及規(guī)則觸發(fā)后生成的消息傳輸載體，消息傳輸載體包括支持微信號(hào)、郵件、短信、URL等，配置的規(guī)則信息供規(guī)則引擎模塊203引用。

規(guī)則引擎模塊：對(duì)設(shè)備數(shù)據(jù)處理模塊202上報(bào)的消息進(jìn)行分析，分析的規(guī)則來自規(guī)則配置模塊204配置的設(shè)備規(guī)則信息，如果設(shè)備數(shù)據(jù)滿足規(guī)則的觸發(fā)條件，將規(guī)則觸發(fā)的消息發(fā)給消息處理模塊205。

消息處理模塊：將規(guī)則引擎模塊203發(fā)送的消息轉(zhuǎn)換為告警消息，發(fā)送給告警模塊；對(duì)轉(zhuǎn)換后的告警消息進(jìn)行消息傳輸載體的判斷，發(fā)給對(duì)應(yīng)的消息傳輸載體模塊處理，如果消息傳輸載體是微信，則發(fā)送給微信處理系統(tǒng)301進(jìn)行處理；同時(shí)實(shí)現(xiàn)與告警模塊和公眾號(hào)服務(wù)器的信息交互。

告警模塊：接收消息處理模塊205發(fā)送的告警消息，將告警信息在物聯(lián)網(wǎng)平臺(tái)進(jìn)行存儲(chǔ)和展現(xiàn)，同時(shí)實(shí)現(xiàn)對(duì)消息處理模塊205發(fā)送的告警操作信息的處理和響應(yīng)。

3 微信處理

微信處理系統(tǒng)實(shí)現(xiàn)物聯(lián)網(wǎng)平臺(tái)與用戶交互，主要包括公眾號(hào)服務(wù)、微信服務(wù)器、公眾號(hào)客戶端三大模塊。

公眾號(hào)服務(wù)器：有三大功能，一是接收消息處理模塊205發(fā)送的告警消息，通過微信服務(wù)器303推送到對(duì)應(yīng)的微信賬號(hào)的公眾號(hào)客戶端上；二是將微信用戶通過公眾號(hào)客戶端304對(duì)告警消息處理請(qǐng)求轉(zhuǎn)發(fā)給消息處理模塊205；三是接收消息處理模塊205發(fā)送的告警操作的響應(yīng)消息，并將響應(yīng)消息轉(zhuǎn)發(fā)給公眾號(hào)客戶端304。

微信服務(wù)器：實(shí)現(xiàn)公眾號(hào)服務(wù)器302和公眾號(hào)客戶端304之間請(qǐng)求的轉(zhuǎn)發(fā)。

公眾號(hào)客戶端：接收公眾號(hào)服務(wù)器302推送的消息，以及提供對(duì)告警消息的處理操作，包括告警確認(rèn)和清除等操作。

4 微信用戶

微信用戶要接收規(guī)則引擎觸發(fā)的消息，需關(guān)注物聯(lián)網(wǎng)平臺(tái)的微信公眾號(hào)，且微信用戶對(duì)應(yīng)的賬號(hào)在規(guī)則配置模塊204要進(jìn)行配置；微信用戶通過公眾號(hào)客戶端304接收告警信息，用戶對(duì)告警進(jìn)行分析處理完成后，可以通過公眾號(hào)客戶端304發(fā)起對(duì)物聯(lián)網(wǎng)平臺(tái)201的告警進(jìn)行清除和確認(rèn)等操作。

5 結(jié)束語

通過規(guī)則引擎使物聯(lián)網(wǎng)平臺(tái)與微信進(jìn)行了有機(jī)的結(jié)合，使得用戶不僅可以快捷、低成本獲取需要的信息，也可以對(duì)關(guān)鍵信息進(jìn)行確認(rèn)反饋，實(shí)現(xiàn)與物聯(lián)網(wǎng)平臺(tái)的交互；同時(shí)規(guī)則引擎將觸發(fā)的消息轉(zhuǎn)換為告警在物聯(lián)網(wǎng)平臺(tái)存儲(chǔ)和展現(xiàn)，為物聯(lián)網(wǎng)后續(xù)對(duì)設(shè)備的分析提供基礎(chǔ)數(shù)據(jù)，使得物聯(lián)網(wǎng)平臺(tái)具有更高的競(jìng)爭(zhēng)力。