物聯網平臺第三方應用集成適用于阿里云IoT、OneNET、ThingsBoard、JetLinks、EMQX等平臺，核心思路大同小異，分為對接模式、接口能力、認證鑒權、數據流向、開發步驟、風險與最佳實踐。

一、兩種主流集成模式

1. API 服務調用(最常用，北向接口)

第三方應用(ERP、MES、SCADA、運維平臺、小程序、APP)通過平臺開放RESTful API讀寫物聯網平臺資源。

可操作內容：

- 查詢設備列表、設備狀態、在線離線、屬性(溫濕度、電流)

- 下發指令、設置設備參數、遠程控制開關

- 查詢歷史遙測數據、告警記錄、事件日志

- 管理產品、設備分組、權限

適用場景：業務系統需要主動查詢/控制設備，低頻到中頻交互。

2. 消息訂閱推送(數據實時流轉，事件驅動)

物聯網平臺把設備上報數據、上下線事件、告警，主動推送給第三方應用。

實現方式：

- MQTT訂閱(平臺作為Broker，第三方客戶端訂閱平臺Topic)

- WebHook(HTTP回調，平臺POST消息到你的服務地址)

- 消息隊列轉發：Kafka/RabbitMQ/RocketMQ，平臺把數據投遞到MQ，第三方消費

> 推薦實時場景用消息推送，避免輪詢API造成平臺壓力和延遲。

二、平臺側開放能力(幾乎所有IoT平臺都提供)

1. 設備屬性(遙測)：設備上報測點數據(讀)

2. 設備服務(指令)：平臺下發控制指令(寫)

3. 事件/告警：設備主動上報故障、閾值告警

4. 時序歷史數據API：按時間范圍拉取歷史曲線

5. OTA升級API：第三方觸發升級、查詢升級進度

6. 設備管理API：創建設備、刪除、批量導入

三、認證與鑒權(安全核心)

常見鑒權方式

1. AccessKey / AppKey + AppSecret：請求API時，簽名算法生成token，放在Header。阿里云、OneNET常用。

2. JWT Token：平臺簽發短期token，每次請求攜帶，過期刷新(ThingsBoard、JetLinks)。

3. MQTT賬號密碼 / MQTT證書：訂閱消息時使用。

4. API白名單：限制第三方應用服務器IP。

> 權限最小化原則：給第三方應用只分配需要的權限，不要管理員全權限。

四、數據流向示例

場景A：第三方平臺讀取設備數據

設備 → IoT平臺(存儲時序數據)

→ 方案1：第三方應用輪詢API拉取屬性

→ 方案2：IoT平臺通過Webhook/MQTT實時推送設備上報數據給第三方服務

場景B：第三方平臺遠程控制設備

第三方應用 → 調用IoT平臺開放API下發指令 → IoT平臺轉發MQTT指令 → 設備接收執行 → 設備返回結果上報平臺 → 平臺回傳給第三方

五、完整開發步驟

1. 在IoT平臺創建應用/授權

在平臺控制臺新建第三方應用，獲取AppKey、密鑰，分配產品/設備權限。

2. 定義數據模型(物模型)對齊

雙方確認測點名稱、單位、數據類型(int/float/bool)、指令參數。物模型不一致是集成最常見坑。

3. 確定通信方案

- 實時數據流：WebHook / MQTT訂閱

- 業務查詢、下發控制：REST API

4. 開發對接代碼

- API：封裝簽名、http請求、異常重試、限流

- WebHook：開發接收接口，做好驗簽，防止偽造請求

5. 測試

- 連通性測試：設備上報，第三方能否收到

- 下行控制測試：第三方下發指令，設備是否響應

- 異常測試：斷網、重連、超時、大量并發數據

6. 上線部署

第三方服務配置公網，配置IP白名單;上線前壓測，設置限流。

7. 運維監控

監控API調用量、消息丟包、回調失敗次數、告警。

六、關鍵技術要點

1. 消息格式：大多為JSON，平臺統一規范。

2. 冪等性：第三方接收Webhook消息要做冪等，防止平臺重復推送導致重復業務邏輯。

3. 限流：IoT平臺一般有API QPS限制，第三方不能高頻輪詢。

4. 時序數據：不要用API高頻拉全量歷史;大量歷史數據優先導出接口或者平臺側對接數據庫。

5. 斷點續傳：Webhook服務宕機，平臺會重試;MQTT使用cleanSession、QoS保證消息不丟。

七、可選高級集成方案(適合大規模項目)

1. 平臺數據轉發到數據庫：IoT平臺直接把設備數據寫入InfluxDB/TDengine，第三方應用讀數據庫，不調用IoT API。

2. 規則引擎：IoT平臺內置規則引擎做過濾、轉換，再轉發給第三方(過濾無效數據，減少第三方壓力)。

> 優勢：在平臺側清洗數據，第三方不用處理臟數據。

八、不同平臺差異簡要對比

- 阿里云IoT：API+Webhook+規則引擎轉發，AccessKey簽名;消息推送用AMQP/HTTP推送。

- 移動OneNET：API+MQTT訂閱，AppKey鑒權。

- ThingsBoard(開源私有化)：REST API、Webhook、MQTT，JWT;自帶規則鏈。

- JetLinks：REST、MQTT，支持自定義消息轉發。

- EMQX：側重MQTT消息轉發，北向API弱，適合純消息流轉。

九、常見坑

1. 忘記驗簽，Webhook接口暴露，被惡意請求攻擊

2. 物模型字段大小寫、單位、數據類型兩邊不一致，解析報錯

3. 輪詢頻率太高，觸發平臺限流

4. 不做冪等，重復消息造成業務重復計算

5. 第三方服務器內網，IoT平臺無法回調Webhook(需要公網/內網穿透/專線)