一、业务概述
本系统面向商用智能饮水设备运营场景,搭建一套软硬一体物联网管控平台,解决多台饮水终端分散管理、现场运维成本高、设备状态无法实时掌握、远程调控难等痛点。平台采用 TCP+HTTP 双通道通信,对接线下 4G 饮水设备,实现设备联网接入、运行数据采集、远程出水 / 加热控制、离线指令缓存补发、运行数据留存对账全流程业务能力,运营人员可通过 Web 后台统一管理所有终端,无需现场上门操作,大幅降低设备运维、巡检人力成本,适配小区、工厂、校园等多点位饮水设备规模化运营管理需求。
二、核心业务功能
设备联网接入管理
设备通过 4G 网络主动建立 TCP 长连接接入平台,设备上线完成注册登记;依靠 20 秒心跳机制实时判定在线状态,闲置超时自动断连并支持断线重连,平台统一维护全量设备台账,实时展示每台设备在线 / 离线状态、GPS 位置信息。
远程设备操控
后台通过 HTTP 接口下发控制指令,支持远程控制设备出水,自定义出水量、出水温度;远程启动加热,设定加热时长。设备在线时指令实时下发执行;设备离线则将指令存入 Redis 队列,待设备重新上线自动补发,同时完整记录每一条控制指令日志。
设备运行数据实时采集
持续接收设备上报运行状态、温度、水量、定位等数据,实时缓存至 Redis 快速查看,关键运行记录同步持久化至 MySQL 长期留存,支持后续数据查询、运营统计。
自动化定时运维任务
系统内置定时运维逻辑,每 22 分钟自动执行短时加热,避免水路停滞变质;定时批量巡检全部设备在线状态;定期轮询离线指令队列,保障积压指令有序下发。
高稳定并发运维保障
采用数据库连接池支撑大批量设备并发接入;Redis 缓存分担查询压力,搭配 MySQL 实现数据双重备份;数据库、通信链路故障支持自动重连恢复,保障 7×24 小时不间断稳定运行。
后台 Web 管理能力
提供标准化 HTTP 接口,管理端可查询全局系统配置、查看全部设备清单、一键下发各类控制指令,操作简单直观,适配运营人员日常日常对账、巡检、设备调控工作。
三、业务价值
远程管控替代上门运维,减少线下巡检人力与出行成本;
双通道通信兼顾设备实时控制与后台便捷管理,适配 4G 户外设备弱网环境;
全量设备数据自动留存,便于运营数据复盘、故障追溯;
模块化架构可拓展,后续可新增计费、故障告警、多类型智能设备接入等业务能力。
一、整体实现思路
项目基于 Node.js 采用模块化分层开发,区分硬件通信层、指令业务层、后台接口层、数据存储层,通过 TCP、HTTP 双通道分离设备通信与后台管理操作,搭配 Redis、MySQL 实现高速缓存与数据持久化,依托 PM2 做进程守护,部署在 Linux 服务器实现 7×24 小时稳定运行,整套架构专门适配 4G 智能饮水设备弱网、多设备并发接入场景。
二、分层模块实现细节
TCP 通信服务模块(硬件对接核心)
搭建 12300 端口长连接服务,自定义二进制通信协议,规范注册、心跳、状态上报、GPS 定位、指令响应数据包结构。设备上电主动发起连接完成注册,每 20 秒上传心跳维持在线;设置 10 分钟无数据超时断连,内置断线自动重连逻辑适配 4G 波动网络。
封装出水、加热两类控制指令报文,统一帧头、设备 ID、参数、校验码格式,收到设备回执后同步更新设备运行状态。
HTTP 接口服务模块(管理端交互)
开启 3000 端口 Web 服务,提供标准化 REST 接口,支持系统配置查询、设备列表读取、远程控制指令提交。所有请求前置参数校验,拦截非法操作;指令下发时先读取 Redis 判断设备在线状态,区分实时下发、离线缓存两种处理逻辑。
命令调度管理模块
统一接管全平台指令分发、队列管理。在线设备直接转发 TCP 指令;离线指令存入 Redis 消息队列,定时轮询队列,设备恢复连接后自动补发。所有下发指令、设备回执完整写入数据库留痕,支持后续追溯。
数据存储模块
使用 MySQL 连接池管理持久化数据,存储设备档案、操作日志、历史运行记录;Redis 承担高速缓存,实时存放设备在线状态、待执行指令队列,实现读写分离提升并发性能。系统采用双数据源保障,Redis 缓存故障可降级读取 MySQL,链路断开自动重试连接。
定时任务模块
独立封装定时调度逻辑:每 22 分钟自动下发短时加热指令;定时批量巡检所有设备在线状态;周期性扫描 Redis 离线指令队列,保障积压指令有序执行,实现设备无人值守自动运维。
三、全流程业务实现流程
运营人员在管理后台通过 HTTP 接口提交出水 / 加热控制指令 → 系统校验设备在线状态 → 在线设备经由 TCP 通道实时下发二进制指令;离线设备将指令存入 Redis 队列 → 设备重新联网后自动拉取队列指令执行 → 设备上报执行结果回执 → Redis 实时更新设备最新状态,操作记录同步持久化至 MySQL。
四、高可用与兼容实现方案
并发处理:数据库连接池、Redis 缓存分担海量设备并发读写压力,支持大量终端同时在线;
故障自愈:TCP 连接、数据库、Redis 连接均配置自动重连,出现断连、超时自动恢复服务;
弱网适配:定制 20 秒心跳保活、合理超时机制,降低 4G 设备频繁掉线概率;