簡(jiǎn)介一套面向物聯(lián)網(wǎng)開發(fā)者的WEB設(shè)備管理與云監(jiān)控源碼項(xiàng)目適用于智能家居、工業(yè)自動(dòng)化等場(chǎng)景解決設(shè)備遠(yuǎn)程接入、狀態(tài)監(jiān)測(cè)、數(shù)據(jù)管理與可視化的實(shí)際問(wèn)題。壓縮包共1915個(gè)文件約27.24MB以PHP后端邏輯、HTML/JS前端頁(yè)面、CSS樣式、PNG圖片素材為主同時(shí)包含MySQL數(shù)據(jù)庫(kù)腳本、配置文件及說(shuō)明文檔便于本地搭建和二次開發(fā)。已有836人學(xué)習(xí)瀏覽。源碼涵蓋設(shè)備注冊(cè)、數(shù)據(jù)上報(bào)、API接口、規(guī)則引擎、可視化界面等完整模塊并提供MQTT通信示例與C語(yǔ)言組件開發(fā)者可據(jù)此掌握從設(shè)備接入到前端展示的完整鏈路還可結(jié)合Excel數(shù)據(jù)表格和Markdown筆記理解項(xiàng)目結(jié)構(gòu)適合希望系統(tǒng)學(xué)習(xí)IoT開發(fā)和云監(jiān)控實(shí)踐的初中級(jí)工程師。1. 項(xiàng)目背景與整體設(shè)計(jì)思路1.1 為什么需要一套物聯(lián)網(wǎng)云監(jiān)控平臺(tái)我做過(guò)不少設(shè)備管理類項(xiàng)目但真正把設(shè)備接入、實(shí)時(shí)監(jiān)控、遠(yuǎn)程運(yùn)維、告警通知串成一條完整閉環(huán)的還是這套物聯(lián)網(wǎng)云監(jiān)控WEB設(shè)備管理系統(tǒng)。以前很多工廠或集成商的設(shè)備管理方式說(shuō)句不好聽的靠的就是一張Excel表和老師傅的經(jīng)驗(yàn)。設(shè)備掛沒(méi)掛、數(shù)據(jù)對(duì)不對(duì)、耗了多少電全憑人工去現(xiàn)場(chǎng)看效率低不說(shuō)出了問(wèn)題往往已經(jīng)是幾個(gè)小時(shí)之后了。這套項(xiàng)目的核心價(jià)值就是給傳統(tǒng)設(shè)備裝上物聯(lián)網(wǎng)這雙眼睛。通過(guò)傳感器和智能網(wǎng)關(guān)把設(shè)備狀態(tài)、環(huán)境參數(shù)、能耗數(shù)據(jù)實(shí)時(shí)采集上來(lái)再在WEB端用圖表、儀表盤、地圖等形式直觀展示。運(yùn)維人員不用再頻繁跑現(xiàn)場(chǎng)坐在電腦前甚至用手機(jī)瀏覽器就能看到設(shè)備的實(shí)時(shí)狀態(tài)。平臺(tái)內(nèi)置的告警規(guī)則還能在設(shè)備異常時(shí)第一時(shí)間推送通知把故障響應(yīng)時(shí)間從小時(shí)級(jí)壓縮到分鐘級(jí)這背后省下的人力成本和產(chǎn)能損失做過(guò)工業(yè)項(xiàng)目的人心里都有數(shù)。1.2 技術(shù)選型背后的真實(shí)考量做物聯(lián)網(wǎng)平臺(tái)技術(shù)棧的選擇直接決定后續(xù)的開發(fā)效率和運(yùn)維成本。這套源碼的技術(shù)路線比較主流后端采用Java Spring Boot框架前端使用Vue.js Element UI數(shù)據(jù)庫(kù)選用MySQL存儲(chǔ)業(yè)務(wù)數(shù)據(jù)消息通信層用的是EMQX或Mosquitto這類MQTT Broker。為什么這么選Spring Boot的生態(tài)成熟集成MyBatis、Redis、定時(shí)任務(wù)都非常順手Vue.js配合Element UI做后臺(tái)管理界面效率極高畢竟設(shè)備管理頁(yè)面的形態(tài)大家都熟悉——表格、表單、彈窗、樹形結(jié)構(gòu)這套組合閉著眼睛都能寫MQTT協(xié)議則是物聯(lián)網(wǎng)場(chǎng)景的事實(shí)標(biāo)準(zhǔn)帶寬占用低、QoS機(jī)制可靠非常適合大量設(shè)備的長(zhǎng)連接場(chǎng)景。不少同學(xué)會(huì)糾結(jié)要不要上微服務(wù)或者直接用Netty自己寫通信層。我的建議是如果不是千萬(wàn)級(jí)設(shè)備接入體量單體應(yīng)用加MQTT Broker的方案完全夠用開發(fā)成本低、排查問(wèn)題方便后期真到了瓶頸階段再按模塊拆分也不遲。做物聯(lián)網(wǎng)平臺(tái)跑通業(yè)務(wù)閉環(huán)永遠(yuǎn)是第一優(yōu)先級(jí)過(guò)度設(shè)計(jì)是新手最容易犯的毛病。2. 系統(tǒng)架構(gòu)與核心模塊拆解2.1 三層架構(gòu)設(shè)備端、平臺(tái)端、WEB端整個(gè)平臺(tái)在大體上分為三層設(shè)備接入層、平臺(tái)服務(wù)層、WEB展示層。設(shè)備接入層負(fù)責(zé)各類傳感器、控制器、智能網(wǎng)關(guān)的數(shù)據(jù)采集和指令下發(fā)通過(guò)MQTT協(xié)議與平臺(tái)保持長(zhǎng)連接平臺(tái)服務(wù)層是核心大腦負(fù)責(zé)設(shè)備認(rèn)證、數(shù)據(jù)解析、存儲(chǔ)、規(guī)則引擎、告警計(jì)算等WEB展示層面向運(yùn)維人員和管理員提供設(shè)備管理、實(shí)時(shí)監(jiān)控、數(shù)據(jù)報(bào)表、系統(tǒng)配置等界面。這三層之間通過(guò)HTTP和MQTT兩類協(xié)議交互。HTTP用于前后端業(yè)務(wù)接口比如登錄、設(shè)備增刪改查、歷史數(shù)據(jù)查詢MQTT用于實(shí)時(shí)數(shù)據(jù)上行和指令下行。為什么要用兩種協(xié)議因?yàn)闃I(yè)務(wù)操作和實(shí)時(shí)通信的訴求不一樣HTTP請(qǐng)求響應(yīng)模式適合低頻、可控的操作而設(shè)備數(shù)據(jù)是持續(xù)產(chǎn)生、需要主動(dòng)推送的輪詢HTTP不僅浪費(fèi)帶寬延遲也不可控。這種混合架構(gòu)是當(dāng)前物聯(lián)網(wǎng)平臺(tái)的主流做法既保證交互體驗(yàn)又兼顧實(shí)時(shí)性能。2.2 數(shù)據(jù)存儲(chǔ)時(shí)序數(shù)據(jù)與業(yè)務(wù)數(shù)據(jù)分離設(shè)備產(chǎn)生的數(shù)據(jù)有一個(gè)顯著特點(diǎn)寫入頻繁、更新極少、帶有時(shí)間戳。如果和業(yè)務(wù)數(shù)據(jù)混在一起存隨著時(shí)間推移表會(huì)變得非常大查詢效率也越來(lái)越差。這套項(xiàng)目里的做法是將兩類數(shù)據(jù)分開存儲(chǔ)設(shè)備基本信息、用戶信息、組織架構(gòu)、告警規(guī)則等存在MySQL業(yè)務(wù)庫(kù)溫濕度、電壓、電流這類遙測(cè)數(shù)據(jù)按天或按月分表也可以選擇存入InfluxDB、TDengine等時(shí)序數(shù)據(jù)庫(kù)。這里有個(gè)設(shè)計(jì)細(xì)節(jié)值得拓展一下很多設(shè)備數(shù)據(jù)本身對(duì)實(shí)時(shí)性要求高但對(duì)歷史精度要求沒(méi)那么苛刻所以在存儲(chǔ)策略上可以做降采樣。比如原始數(shù)據(jù)每5秒一條存3個(gè)月后可以聚合為每分鐘一條存1年后再降為每10分鐘一條。這樣既保證近期數(shù)據(jù)的高精度又能控制長(zhǎng)期存儲(chǔ)的成本。代碼里通常用一個(gè)定時(shí)任務(wù)來(lái)完成數(shù)據(jù)清理和聚合調(diào)用時(shí)序庫(kù)的連續(xù)查詢功能就能實(shí)現(xiàn)。這套方案對(duì)于預(yù)算有限的團(tuán)隊(duì)特別實(shí)用因?yàn)榉?wù)器磁盤沒(méi)那么容易被打滿。2.3 平臺(tái)的核心能力邊界這套源碼作為中小型物聯(lián)網(wǎng)平臺(tái)覆蓋的能力包括設(shè)備管理、實(shí)時(shí)監(jiān)控、遠(yuǎn)程控制、告警中心、數(shù)據(jù)統(tǒng)計(jì)、用戶權(quán)限、操作日志等。設(shè)備管理支持批量導(dǎo)入導(dǎo)出方便初始化或者遷移遠(yuǎn)程控制支持下發(fā)指令并反饋執(zhí)行結(jié)果告警中心支持按設(shè)備分組、按規(guī)則模板批量配置閾值告警數(shù)據(jù)統(tǒng)計(jì)提供曲線圖和報(bào)表導(dǎo)出用于分析運(yùn)行趨勢(shì)。在實(shí)際落地中平臺(tái)還有幾個(gè)隱藏價(jià)值點(diǎn)容易被忽略一是操作日志完備誰(shuí)在什么時(shí)間操作了哪臺(tái)設(shè)備全程留痕這在工廠審計(jì)中很關(guān)鍵二是開放API接口方便與第三方系統(tǒng)如ERP、MES對(duì)接三是數(shù)據(jù)看板支持大屏展示會(huì)議室墻上的大屏接上這個(gè)頁(yè)面整個(gè)產(chǎn)線狀態(tài)一目了然很適合做成果匯報(bào)。這套源碼的邊界和應(yīng)用場(chǎng)景基本覆蓋了中小型項(xiàng)目的絕大多數(shù)需求。3. 設(shè)備接入與上下行數(shù)據(jù)鏈路3.1 MQTT接入流程與設(shè)備認(rèn)證設(shè)備接入的第一步是認(rèn)證。每個(gè)設(shè)備在平臺(tái)注冊(cè)后會(huì)生成唯一的設(shè)備標(biāo)識(shí)如產(chǎn)品Key和設(shè)備序列號(hào)設(shè)備端連接MQTT Broker時(shí)使用設(shè)備證書或Token進(jìn)行認(rèn)證。最常用的做法是采用一機(jī)一密的機(jī)制平臺(tái)為每一臺(tái)設(shè)備生成專屬的ClientId和密碼設(shè)備連接時(shí)攜帶這些信息Broker通過(guò)認(rèn)證插件校驗(yàn)合法性非法設(shè)備直接拒絕連接。從實(shí)操層面看設(shè)備接入流程可以拆成四步第一步在WEB端添加產(chǎn)品定義產(chǎn)品的數(shù)據(jù)模型包括屬性、事件、服務(wù)三類能力第二步為具體設(shè)備實(shí)例填寫序列號(hào)等信息獲取連接憑證第三步設(shè)備端使用MQTT客戶端庫(kù)如Eclipse Paho、MQTT.fx連接Broker訂閱指令主題第四步設(shè)備上報(bào)數(shù)據(jù)后平臺(tái)驗(yàn)證數(shù)據(jù)格式、寫入數(shù)據(jù)庫(kù)并更新設(shè)備在線狀態(tài)。這套流程走順了后面接新設(shè)備就是純粹的配置工作不用改代碼。3.2 數(shù)據(jù)上行從JSON到結(jié)構(gòu)化存儲(chǔ)設(shè)備上報(bào)的數(shù)據(jù)格式通常有兩種一種是非標(biāo)的JSON字符串另一種是物模型定義的標(biāo)準(zhǔn)數(shù)據(jù)格式。推薦使用物模型的方式因?yàn)檫@樣平臺(tái)可以通過(guò)JSON Schema校驗(yàn)數(shù)據(jù)合法性新設(shè)備接入也不用為每種設(shè)備寫一套解析代碼。例如一個(gè)溫濕度傳感器上報(bào)的JSON內(nèi)容大致為{temperature:25.6,humidity:60.3,deviceId:SN001}平臺(tái)收到后先做格式校驗(yàn)再映射到內(nèi)部數(shù)據(jù)結(jié)構(gòu)最終寫入MySQL或時(shí)序數(shù)據(jù)庫(kù)。這個(gè)過(guò)程有幾個(gè)坑需要特別注意第一字段名的統(tǒng)一設(shè)備端上報(bào)temperature數(shù)據(jù)庫(kù)字段也叫temperature代碼里不會(huì)出歧義第二數(shù)據(jù)截?cái)鄦?wèn)題浮點(diǎn)數(shù)精度在傳輸過(guò)程中可能丟失建議后端用BigDecimal或Decimal類型存儲(chǔ)避免后續(xù)統(tǒng)計(jì)對(duì)不上第三時(shí)間戳規(guī)范化設(shè)備上報(bào)的時(shí)間可能是本地時(shí)間也可能是UTC時(shí)間必須統(tǒng)一轉(zhuǎn)換為服務(wù)器時(shí)區(qū)的DateTime否則報(bào)表的時(shí)間線會(huì)亂套。這些細(xì)節(jié)看似零碎但直接影響數(shù)據(jù)質(zhì)量而數(shù)據(jù)質(zhì)量就是物聯(lián)網(wǎng)平臺(tái)的命根子。3.3 指令下發(fā)同步確認(rèn)還是異步通知遠(yuǎn)程控制是物聯(lián)網(wǎng)平臺(tái)的一個(gè)重要面。指令下發(fā)的流程是WEB端點(diǎn)擊控制按鈕后端服務(wù)收到請(qǐng)求后將控制指令發(fā)布到該設(shè)備對(duì)應(yīng)的MQTT主題設(shè)備端訂閱該主題并執(zhí)行動(dòng)作執(zhí)行完畢后將結(jié)果上報(bào)。這里需要區(qū)分平臺(tái)命令送達(dá)和設(shè)備執(zhí)行成功兩個(gè)概念前者只表示消息到達(dá)Broker后者需要設(shè)備端回復(fù)確認(rèn)指令。在項(xiàng)目實(shí)踐中我習(xí)慣把所有下發(fā)的指令記錄到指令表并維護(hù)一個(gè)狀態(tài)字段取值是待下發(fā)、已送達(dá)、執(zhí)行中、成功、失敗、超時(shí)。后端下發(fā)消息后通過(guò)定時(shí)任務(wù)輪詢指令狀態(tài)如果超過(guò)設(shè)定閾值仍未收到設(shè)備回復(fù)就自動(dòng)標(biāo)記超時(shí)。這種機(jī)制能讓W(xué)EB端界面向用戶展示準(zhǔn)確的指令執(zhí)行狀態(tài)而不是發(fā)出去就黑盒狀態(tài)排查離線場(chǎng)景下的假死指令非常好用。3.4 設(shè)備在線狀態(tài)與心跳機(jī)制設(shè)備在線狀態(tài)判斷是物聯(lián)網(wǎng)平臺(tái)基礎(chǔ)卻容易出問(wèn)題的一環(huán)。純TCP長(zhǎng)連接可以直接通過(guò)斷開事件判定掉線但MQTT的心跳包機(jī)制需要單獨(dú)處理。設(shè)備端按設(shè)定間隔發(fā)送心跳例如每60秒一次Broker如果在1.5倍的心跳時(shí)間內(nèi)沒(méi)有收到任何報(bào)文就判定連接斷開。平臺(tái)側(cè)通過(guò)訂閱在線狀態(tài)主題或查詢Broker的客戶端列表來(lái)感知這些變化。這里要說(shuō)明一個(gè)實(shí)際經(jīng)驗(yàn)單純依賴Broker連接狀態(tài)還是不夠的因?yàn)橛行┰O(shè)備斷電前來(lái)不及發(fā)送遺囑消息主機(jī)已經(jīng)掉了Broker雖然能感知但展示層如果做了本地緩存狀態(tài)就會(huì)不一致。我建議平臺(tái)在設(shè)備狀態(tài)判斷時(shí)采用雙保險(xiǎn)Broker連接狀態(tài)為主要依據(jù)服務(wù)端再做一層最后活躍時(shí)間校驗(yàn)超過(guò)設(shè)定時(shí)間強(qiáng)制標(biāo)記為離線。這樣即使在Broker異常或數(shù)據(jù)推送延遲的場(chǎng)景下界面展示的在線狀態(tài)也不會(huì)失真太久。4. 云監(jiān)控核心功能實(shí)現(xiàn)4.1 實(shí)時(shí)數(shù)據(jù)大屏與監(jiān)控看板實(shí)時(shí)監(jiān)控功能是這套平臺(tái)的門面。它包含設(shè)備狀態(tài)總覽、實(shí)時(shí)數(shù)據(jù)儀表盤、地圖分布展示、告警滾動(dòng)播報(bào)等模塊。WEB端通過(guò)WebSocket與后端保持長(zhǎng)連接當(dāng)設(shè)備上報(bào)數(shù)據(jù)后后端服務(wù)將最新的點(diǎn)播數(shù)據(jù)推送到前端前端自動(dòng)更新表格或圖表達(dá)到秒級(jí)看到現(xiàn)場(chǎng)變化的效果。大屏看板的實(shí)現(xiàn)需要從設(shè)計(jì)上區(qū)分實(shí)時(shí)數(shù)據(jù)和歷史數(shù)據(jù)兩種數(shù)據(jù)流。實(shí)時(shí)數(shù)據(jù)走WebSocket即時(shí)推送直接用當(dāng)前最新值刷新看板上的儀表盤指針和數(shù)字實(shí)時(shí)變化歷史趨勢(shì)曲線則通過(guò)HTTP調(diào)用查詢接口獲取按時(shí)間范圍返回聚合后的數(shù)據(jù)點(diǎn)。尤其需要注意的是數(shù)據(jù)頻率的適配如果設(shè)備每5秒上報(bào)一次數(shù)據(jù)而看板只需要30秒級(jí)別的刷新那就不應(yīng)該讓W(xué)ebSocket每條都推送再重繪圖表中間加一層數(shù)據(jù)緩沖和節(jié)流可以大幅降低前端開銷。這套系統(tǒng)在監(jiān)控大屏場(chǎng)景下的加載速度和流暢度都比我之前用輪詢方案做的第一版不知道強(qiáng)了多少。4.2 告警規(guī)則引擎與通知渠道告警是物聯(lián)網(wǎng)監(jiān)控的核心痛點(diǎn)需求。沒(méi)有告警光屏上看到數(shù)據(jù)異常等人工反應(yīng)過(guò)來(lái)?yè)p失已經(jīng)造大了。平臺(tái)內(nèi)置了一套規(guī)則引擎支持為每個(gè)物理量配置多個(gè)告警規(guī)則比如溫度高于80度觸發(fā)緊急告警持續(xù)5分鐘仍然高于75度觸發(fā)高溫預(yù)警。規(guī)則引擎的核心就是對(duì)流式數(shù)據(jù)進(jìn)行持續(xù)計(jì)算每條新數(shù)據(jù)進(jìn)來(lái)都要做閾值判斷同時(shí)還要處理持續(xù)時(shí)長(zhǎng)、恢復(fù)判斷、告警去重等問(wèn)題。告警消息的觸達(dá)方式也是物聯(lián)網(wǎng)平臺(tái)比較看重的一塊。除了在WEB端彈出通知和告警列表之外往往還要支持郵件、短信、企業(yè)微信/釘釘機(jī)器人等渠道。在項(xiàng)目里我實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的策略模式定義一個(gè)告警通知接口不同渠道各自實(shí)現(xiàn)一個(gè)發(fā)送方法告警觸發(fā)時(shí)按照規(guī)則配置的路由策略決定發(fā)哪個(gè)渠道。短信適合值班人員接收的緊急告警郵件適合常規(guī)日?qǐng)?bào)企業(yè)微信群機(jī)器人適合運(yùn)維協(xié)同?；ㄥX買短信的人都知道渠道收斂很重要不然一分鐘能給你發(fā)一兩百條告警短信誤報(bào)和重復(fù)告警能煩死人。4.3 歷史數(shù)據(jù)查詢與報(bào)表統(tǒng)計(jì)歷史數(shù)據(jù)是設(shè)備優(yōu)化和故障分析的原始依據(jù)。平臺(tái)提供兩種查詢方式原始數(shù)據(jù)明細(xì)查詢和聚合統(tǒng)計(jì)。明細(xì)查詢用于定位某個(gè)時(shí)間點(diǎn)的具體數(shù)據(jù)聚合統(tǒng)計(jì)用于分析趨勢(shì)、均值、峰值等。比如查詢某臺(tái)設(shè)備一周內(nèi)的溫度最大值、平均值用于判斷設(shè)備運(yùn)行環(huán)境是否穩(wěn)定。報(bào)表模塊可以導(dǎo)出Excel或生成PDF方便運(yùn)維會(huì)議匯報(bào)。在實(shí)現(xiàn)上有幾個(gè)效率點(diǎn)值得注意。第一查詢條件必須帶時(shí)間范圍索引否則后期數(shù)據(jù)量大了會(huì)慢到?jīng)]法用第二聚合統(tǒng)計(jì)盡量在數(shù)據(jù)庫(kù)層面完成SQL里用GROUP BY配合時(shí)間窗口函數(shù)不要把所有數(shù)據(jù)撈到Java內(nèi)存里再聚合第三緩存熱數(shù)據(jù)最近一小時(shí)的實(shí)時(shí)數(shù)據(jù)可以放在Redis里查詢時(shí)優(yōu)先走緩存緩存未命中再落庫(kù)。這些優(yōu)化做完大數(shù)據(jù)量下的報(bào)表打開速度能快一個(gè)數(shù)量級(jí)用戶體感完全不同。4.4 視頻監(jiān)控與告警聯(lián)動(dòng)很多物聯(lián)網(wǎng)平臺(tái)還有接入攝像頭視頻流的場(chǎng)景。源碼里通過(guò)GB28181協(xié)議或RTSP拉流方式接入網(wǎng)絡(luò)攝像頭WEB端通過(guò)Flv.js或WebRTC播放實(shí)時(shí)視頻流。更實(shí)用的是告警聯(lián)動(dòng)功能當(dāng)某個(gè)報(bào)警觸發(fā)后系統(tǒng)自動(dòng)調(diào)取關(guān)聯(lián)攝像頭的錄像或截圖保存到告警記錄中方便事后回溯現(xiàn)場(chǎng)。這在養(yǎng)殖場(chǎng)、倉(cāng)庫(kù)、配電房等場(chǎng)景中極其有用光看數(shù)據(jù)很難判斷現(xiàn)場(chǎng)是什么狀況但視頻畫面一看就明白了。不過(guò)說(shuō)實(shí)話視頻監(jiān)控模塊在中小型項(xiàng)目里不宜做太深涉及視頻轉(zhuǎn)碼、存儲(chǔ)、回放的話工程量會(huì)成倍上漲。建議初期只用云臺(tái)控制、實(shí)時(shí)預(yù)覽、截圖三種基礎(chǔ)能力后續(xù)再按需擴(kuò)展錄像回放、智能識(shí)別人員闖入、煙火檢測(cè)等功能。畢竟項(xiàng)目核心是云監(jiān)控的云端管理能力視頻是輔助增強(qiáng)不是主菜。5. WEB端設(shè)備管理與權(quán)限設(shè)計(jì)5.1 設(shè)備全生命周期管理WEB端的設(shè)備管理模塊要做到從設(shè)備注冊(cè)到注銷的全生命周期管理。設(shè)備狀態(tài)分為未激活、在線、離線、禁用、注銷五種。設(shè)備新增后處于未激活狀態(tài)第一次成功上報(bào)數(shù)據(jù)后自動(dòng)激活并上線管理員可以手動(dòng)禁用某臺(tái)設(shè)備禁用后平臺(tái)忽略該設(shè)備的采集數(shù)據(jù)和指令請(qǐng)求注銷則是徹底移除設(shè)備并保留歷史記錄供追溯。設(shè)備詳情頁(yè)我建議至少包含四個(gè)區(qū)塊基本信息產(chǎn)品名稱、序列號(hào)、安裝位置、經(jīng)緯度等、運(yùn)行狀態(tài)當(dāng)前在線狀態(tài)、最后在線時(shí)間、連接IP、實(shí)時(shí)數(shù)據(jù)當(dāng)前最新的各屬性值、歷史操作指令下發(fā)記錄、告警記錄。很多運(yùn)維問(wèn)題都是從這臺(tái)設(shè)備最后在線是什么時(shí)候這種基礎(chǔ)查詢開始的信息越全排查越省力。設(shè)備導(dǎo)入導(dǎo)出功能也建議在初期就做。工廠一次性接入幾百臺(tái)設(shè)備如果手工逐個(gè)添加半天時(shí)間就耗在這了。Excel模板批量導(dǎo)入 二維碼批量生成是部署階段最高效的手段。設(shè)備安裝時(shí)現(xiàn)場(chǎng)人員掃碼就能在手機(jī)上看到設(shè)備信息并綁定工單安裝效率明顯提升。5.2 組織架構(gòu)與多租戶權(quán)限模型企業(yè)使用物聯(lián)網(wǎng)平臺(tái)時(shí)往往涉及總部和多個(gè)分部或車間的組織結(jié)構(gòu)。WEB端需要支持按組織架構(gòu)管理設(shè)備也就是設(shè)備的歸屬不只是一個(gè)部門而是層層嵌套的樹形結(jié)構(gòu)?？偛抗芾韱T能看到所有設(shè)備數(shù)據(jù)車間管理員只能看到自己車間內(nèi)的設(shè)備。這種基于RBAC模型的權(quán)限管理比較簡(jiǎn)單用戶、角色、權(quán)限點(diǎn)、數(shù)據(jù)范圍四個(gè)維度就夠了。數(shù)據(jù)權(quán)限的控制是很多項(xiàng)目容易做糙的地方。簡(jiǎn)單粗暴的做法是查詢時(shí)只做名稱過(guò)濾但真正的數(shù)據(jù)權(quán)限需要在SQL層面按組織ID進(jìn)行攔截?？蚣苌峡梢酝ㄟ^(guò)MyBatis的攔截器自動(dòng)拼接數(shù)據(jù)權(quán)限條件凡是查詢?cè)O(shè)備、數(shù)據(jù)、告警等核心表的地方都自動(dòng)帶上當(dāng)前用戶的可視范圍條件。這樣即使開發(fā)人員中途忘了寫權(quán)限判斷也不會(huì)出現(xiàn)越權(quán)訪問(wèn)的低級(jí)漏洞。5.3 前端交互與性能體驗(yàn)WEB管理端畢竟是給管理員天天用的交互體驗(yàn)直接決定平臺(tái)被接受的程度。項(xiàng)目使用Vue.js Element UI表格支持分頁(yè)、排序、列顯隱、批量選擇操作頁(yè)面操作步驟盡量控制在2跳以內(nèi)。設(shè)備列表和實(shí)時(shí)監(jiān)控頁(yè)在數(shù)據(jù)量大時(shí)要有分頁(yè)和懶加載機(jī)制否則每3秒鐘WebSocket推一次數(shù)據(jù)前端頁(yè)面卡成幻燈片那就沒(méi)法用了。我實(shí)際測(cè)試下來(lái)前端在這幾個(gè)點(diǎn)上下對(duì)功夫體驗(yàn)提升最明顯一是表格的虛擬滾動(dòng)渲染幾千行不卡二是圖表的動(dòng)畫開關(guān)實(shí)時(shí)數(shù)據(jù)刷新時(shí)關(guān)閉動(dòng)畫流暢很多三是全局異常提示和加載狀態(tài)的一致性避免用戶重復(fù)點(diǎn)擊提交。整體的前端架構(gòu)建議采用Vuex存儲(chǔ)用戶信息、權(quán)限點(diǎn)、設(shè)備樹緩存避免每次切換頁(yè)面都要重新拉取設(shè)備列表。6. 部署上線與常見問(wèn)題排查6.1 Docker Compose一鍵編排部署部署這套平臺(tái)推薦使用Docker Compose。數(shù)據(jù)庫(kù)、Redis、MQTT Broker、后端服務(wù)、前端Nginx五個(gè)容器通過(guò)一個(gè)compose文件編排起來(lái)非常省心。特別是現(xiàn)場(chǎng)實(shí)施的時(shí)候目標(biāo)機(jī)器上環(huán)境可能千奇百怪Docker可以把服務(wù)和依賴打包在一起部署一臺(tái)新服務(wù)器大概就是十分鐘的事情。部署時(shí)要注意幾個(gè)配置項(xiàng)MySQL的volume掛載路徑要持久化不然容器重建數(shù)據(jù)就丟了EMQX要開放18083端口用于Dashboard管理1883端口用于設(shè)備連接Nginx配置HTTP長(zhǎng)連接和WebSocket升級(jí)頭否則前端實(shí)時(shí)推送連不上。生產(chǎn)環(huán)境務(wù)必開啟防火墻只放行必要端口設(shè)備接入端口、Web端口、SSH端口三個(gè)就好其他端口全關(guān)。6.2 后端服務(wù)層面常見問(wèn)題與優(yōu)化在實(shí)際運(yùn)行中后端服務(wù)最常碰到的問(wèn)題基本集中在三塊數(shù)據(jù)庫(kù)連接池耗盡、Netty線程阻塞、內(nèi)存溢出。連接池耗盡多半是因?yàn)槁齋QL太多排查可以打開MySQL的慢查詢?nèi)罩景褕?zhí)行時(shí)間超過(guò)1秒的SQL抓出來(lái)做索引優(yōu)化線程阻塞常見于設(shè)備大量涌入時(shí)的任務(wù)隊(duì)列擠壓建議拆分線程池設(shè)備消息處理和數(shù)據(jù)落庫(kù)分開內(nèi)存溢出則需要調(diào)整JVM參數(shù)同時(shí)關(guān)注是否有集合類沒(méi)有清理導(dǎo)致對(duì)象無(wú)法回收。還有一個(gè)容易忽略的服務(wù)端優(yōu)化點(diǎn)是消息并發(fā)處理。全量設(shè)備長(zhǎng)時(shí)間在線、數(shù)據(jù)流量大時(shí)單機(jī)處理能力會(huì)到瓶頸。如果單機(jī)資源還不夠必然要上集群。這一步建議后置先把單機(jī)壓到極致再做集群擴(kuò)展避免在項(xiàng)目初期就背上一堆分布式復(fù)雜度。6.3 設(shè)備端接入的典型異常排查這里整理了一張?jiān)O(shè)備接入時(shí)的排查速查表我在多個(gè)現(xiàn)場(chǎng)項(xiàng)目實(shí)施中用過(guò)可以減少大量溝通成本現(xiàn)象可能原因快速排查思路設(shè)備連不上MQTT認(rèn)證失敗核對(duì)ClientId和密碼檢查是否一機(jī)一密機(jī)制設(shè)備連上了但數(shù)據(jù)沒(méi)入庫(kù)主題訂閱錯(cuò)誤檢查設(shè)備發(fā)布主題與平臺(tái)訂閱主題是否匹配數(shù)據(jù)入庫(kù)但沒(méi)有顯示物模型字段映射錯(cuò)誤檢查數(shù)據(jù)庫(kù)字段名與上報(bào)JSON字段名是否一致設(shè)備狀態(tài)一直離線心跳間隔配置過(guò)大查看平臺(tái)日志中的最后活躍時(shí)間調(diào)整心跳策略指令下發(fā)設(shè)備無(wú)響應(yīng)設(shè)備處于透?jìng)髂Ｊ酱_認(rèn)設(shè)備是否訂閱了指令主題查看指令狀態(tài)機(jī)每次在現(xiàn)場(chǎng)排查問(wèn)題我第一步永遠(yuǎn)是看設(shè)備端日志和平臺(tái)端日志的時(shí)間戳對(duì)齊沒(méi)有。設(shè)備上報(bào)時(shí)間、平臺(tái)接收時(shí)間、入庫(kù)時(shí)間三個(gè)時(shí)間一對(duì)比鏈路瓶頸在哪個(gè)環(huán)節(jié)基本就清楚了。6.4 實(shí)戰(zhàn)心得從源碼部署到二次開發(fā)拿到這套源碼之后我建議先不急著改代碼按以下步驟走一遍第一步部署起基礎(chǔ)環(huán)境跑通設(shè)備模擬器上報(bào)數(shù)據(jù) - WEB端看到實(shí)時(shí)數(shù)據(jù) - 修改設(shè)備閾值觸發(fā)告警這條主鏈路第二步仔細(xì)閱讀數(shù)據(jù)庫(kù)設(shè)計(jì)文檔和核心代碼重點(diǎn)理解數(shù)據(jù)表之間的關(guān)系第三步針對(duì)自己的業(yè)務(wù)場(chǎng)景做二次開發(fā)優(yōu)先從增加一種產(chǎn)品類型這種小需求入手逐步熟悉代碼風(fēng)格第四步再進(jìn)行頁(yè)面定制化改造。二次開發(fā)時(shí)注意保持原有分層結(jié)構(gòu)不要在Controller里寫復(fù)雜業(yè)務(wù)邏輯所有數(shù)據(jù)處理都放到Service層。自定義告警規(guī)則時(shí)盡量復(fù)用原來(lái)的規(guī)則引擎接口而不是在原有代碼里加特定判斷邏輯。這樣后續(xù)升級(jí)官方源碼時(shí)改動(dòng)沖突會(huì)小很多。還有一點(diǎn)就是在改數(shù)據(jù)庫(kù)表字段時(shí)及時(shí)同步更新前后端的數(shù)據(jù)模型代碼報(bào)錯(cuò)說(shuō)找不到字段的問(wèn)題在二次開發(fā)階段我?guī)缀趺看味紩?huì)遇到。7. 寫在最后一次完整的物聯(lián)網(wǎng)閉環(huán)實(shí)踐做這套物聯(lián)網(wǎng)云監(jiān)控平臺(tái)帶給我最大的體會(huì)是物聯(lián)網(wǎng)系統(tǒng)真正的復(fù)雜度不在通信協(xié)議也不在某個(gè)炫酷的前端圖表而是把設(shè)備接入、數(shù)據(jù)流轉(zhuǎn)、告警處理、業(yè)務(wù)展示這條鏈路完整地串起來(lái)每一環(huán)都可靠運(yùn)轉(zhuǎn)。設(shè)備端斷線重連、平臺(tái)側(cè)數(shù)據(jù)清洗、WEB端信息展示任何一個(gè)環(huán)節(jié)出紕漏整套系統(tǒng)的可信度就會(huì)打折扣。在實(shí)際落地過(guò)程中我還有一個(gè)很深的經(jīng)驗(yàn)項(xiàng)目驗(yàn)收階段展示給客戶看的永遠(yuǎn)不是代碼寫得多漂亮而是業(yè)務(wù)的完整閉環(huán)。從設(shè)備添加開始到數(shù)據(jù)上傳到異常告警到遠(yuǎn)程控制再到報(bào)表導(dǎo)出每一步都能走得通、看得見、解釋得清這個(gè)項(xiàng)目就成功了九成。這套源碼的價(jià)值正在于它把上述細(xì)節(jié)都做了相對(duì)規(guī)范的實(shí)現(xiàn)給二次開發(fā)提供了一套可以起步的骨架。最后再分享一下個(gè)人部署體驗(yàn)如果條件允許建議在同一臺(tái)性能還行的服務(wù)器上完整部署一遍用MQTT.fx模擬10臺(tái)設(shè)備做壓力測(cè)試觀察CPU和內(nèi)存指標(biāo)調(diào)整數(shù)據(jù)庫(kù)連接數(shù)和JVM參數(shù)。這個(gè)過(guò)程走完你對(duì)這套系統(tǒng)的理解深度比單純看源碼要扎實(shí)得多。做物聯(lián)網(wǎng)這行動(dòng)手永遠(yuǎn)是學(xué)習(xí)效率最高的方式。本文還有配套的精品資源點(diǎn)擊獲取