物联网平台第三方应用集成适用于阿里云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(需要公网/内网穿透/专线)
热门跟贴