开源可二次开发的物联网云平台，支持工业设备远程控制与数据采集

物联网云平台工业设备对接远程控制数据采集视频接入开源可二次开发 该物联网云平台使用 Java 语言、主流技术组合开发支持多数据源支持代码一键生成方便快速开发。 1、内含物联网云平台全套源码源码全部开放无任何加密可二次开发、MQTT服务、数据库设计、相关资料、相关工具软件等 2、使用基于发布/订阅模式的轻量级通讯协议 MQTT具有自动重连机制具有设备上下线提醒功能 3、支持 Modbus RTU、Modbus TCP 协议03、05功能码亦可自定义协议接入支持各类 DTU、透传模块以及各类工业设备接入等 4、支持云固件升级、远程重启等可存储各路开关状态设备断电或重启后可自动同步云端各路开关状态具有开关状态记忆功能 5、云平台可对各类传感器管理适用各种业务场景对传感器数据有多种展示方式 6、可配置报警规则符合报警规则可执行自定义动作、联动报警、报警通知等 7、控制命令下达后有执行状态反馈可确保设备控制命令执行成功 8、具有可视化在线定时任务配置功能可指定某一时刻执行、周期执行、自定义 Cron 表达式执行等操作 9、具有场景管理功能可一键执行设定的动作 10、具有视频管理功能支持萤石云协议的摄像头均可接入云平台可在云平台直接预览视频画面 11、可记录设备、用户所有操作记录设备、用户上下线记录等并具有多种类型的数据统计展示 12、云平台可对所有用户管理每个用户可配置不同角色、不同权限具有权限分配功能支持对人员进行菜单、按钮及数据权限控制亦可自定义数据权限 13、前端采用完全响应式布局支持电脑、平板、手机等所有主流设备 14、Maven 多项目依赖模块及插件分项目尽量松耦合方便模块升级、增减模块 等等……内容较多在此无法一一列举KSoft 物联网通用平台《ksoft-common》模块源码级功能说明书—— 写给二次开发者与运维人员------------------------------------------------一、模块定位ksoft-common 是整个 KSoft 物联网平台的“技术底座”它不提供业务页面却为所有业务微服务ksoft-system、ksoft-website、ksoft-mqtt 等统一提供工具级 API日期、加解密、Excel、MQTT 配置、字典缓存、IP 获取、XSS 过滤……通用技术中间件多数据源切换、异步线程池、操作日志 AOP、数据权限 AOP、防重复提交、Shiro 安全工具、全局异常体系代码生成器与调度器依赖的“元数据”模型BaseEntity、TreeEntity、Ztree、字典实体、权限常量一句话只要引用了 ksoft-common就能直接获得一套“开箱即用”的物联网后台基础设施。------------------------------------------------二、包结构速览com.ksoft.common├─ annotation // 自定义注解DataScope、Log、RepeatSubmit、Excel …├─ config // 全局配置类KSoftConfig、MqttConfig、ThreadPoolConfig├─ constant // 系统级常量Constants、UserConstants、PermissionConstants…├─ core // 统一返回、分页、基础实体AjaxResult、BaseEntity、TableDataInfo├─ enums // 通用枚举BusinessType、DataSourceType、DeviceOperType…├─ exception // 全局异常体系BusinessException、UserException、FileException…├─ json // JSON 与 JSONObject 封装jackson 二次封装├─ utils // 工具大合集日期、Http、IP、DES、MD5、Excel、反射、SpringUtils…└─ xss // XSS 过滤器XssFilter XssHttpServletRequestWrapper------------------------------------------------三、核心能力逐条拆解统一响应与分页• AjaxResultcode/msg/data—— 所有 Controller 返回同一结构• TableDataInfototal/rows—— 与 PageHelper 无缝衔接前端表格直接渲染• BaseController 提供 startPage()/getDataTable(list) 模板方法一句代码完成分页多数据源 读写分离• 注解 DataSource(DataSourceType.MASTER/SLAVE)• DataSourceAspect 在方法调用前把数据源名称压入 ThreadLocal• DynamicDataSource 继承 AbstractRoutingDataSource根据 ThreadLocal 动态切换• 主从库故障时Druid 会自动降级业务方零感知数据权限部门/用户维度• 注解 DataScope(deptAlias d, userAlias u)• DataScopeAspect 在 Mapper 执行前改写 SQL自动拼接AND (d.deptid IN (…当前角色可见部门…) OR u.userid …当前用户…)• 支持 5 种内置规则全部/自定义/本部门/本部门及下级/仅本人操作日志 登录日志AOP 无侵入• Log(title 设备管理, businessType BusinessType.INSERT)• LogAspect 在方法返回/异常时异步记录类名方法、入参、耗时、IP、地点、浏览器、错误信息• AsyncManager ScheduledExecutorService 日志落库即使高并发也不阻塞业务防重复提交• RepeatSubmit 标记在 Controller 方法• SameUrlDataInterceptor 用 session 缓存“URL参数时间戳”10 秒内相同参数直接拒绝• 支持前后分离场景Header 里加 token 也能识别物联网专用配置• MqttConfig 读取 application.yml 中 mqtt.* 属性统一给出 host、port、clientId、userName、password、qos、keepAlive、threadPoolSize• 其他模块只需 Autowired MqttConfig 即可拿到全套参数避免到处硬编码字典/参数缓存• DictUtils 提供 getDictLabel()/getDictValue()自动加 Ehcache• 后台修改字典后调用 DictUtils.clearDictCache() 即可实时刷新• 同理 SysConfigCache 处理系统参数短信密钥、文件路径等Excel 一键导入导出poi 封装• 在实体字段加 Excel(name 温度, readConverterExp 0正常,1偏高)• ExcelUtil 自动解析下拉框、日期格式、字典翻译、图片插入、合计行• 支持 65536 行以上大数据 SXSSF 模式内存无压力全局异常兜底• 业务异常 BusinessException → 前端弹窗提示• 文件异常 FileException → 统一返回“文件过大/格式不符”• 所有异常被 GlobalExceptionHandler 捕获 → AjaxResult.error(msg)• 生产环境关闭堆栈防止信息泄露安全加固• XssFilter 全局过滤白名单机制支持 excludes 路径放行• DesUtils、MD5、SHA1、随机盐满足密码加密与固件校验• ShiroUtils 提供 getSysUser()/getIp()/randomSalt()任何层都能直接拿当前登录人------------------------------------------------四、典型调用链以“分页查询设备列表”为例前端 → DeviceController.list(Device device)① BaseController.startPage() // ThreadLocal 注入分页参数物联网云平台工业设备对接远程控制数据采集视频接入开源可二次开发 该物联网云平台使用 Java 语言、主流技术组合开发支持多数据源支持代码一键生成方便快速开发。 1、内含物联网云平台全套源码源码全部开放无任何加密可二次开发、MQTT服务、数据库设计、相关资料、相关工具软件等 2、使用基于发布/订阅模式的轻量级通讯协议 MQTT具有自动重连机制具有设备上下线提醒功能 3、支持 Modbus RTU、Modbus TCP 协议03、05功能码亦可自定义协议接入支持各类 DTU、透传模块以及各类工业设备接入等 4、支持云固件升级、远程重启等可存储各路开关状态设备断电或重启后可自动同步云端各路开关状态具有开关状态记忆功能 5、云平台可对各类传感器管理适用各种业务场景对传感器数据有多种展示方式 6、可配置报警规则符合报警规则可执行自定义动作、联动报警、报警通知等 7、控制命令下达后有执行状态反馈可确保设备控制命令执行成功 8、具有可视化在线定时任务配置功能可指定某一时刻执行、周期执行、自定义 Cron 表达式执行等操作 9、具有场景管理功能可一键执行设定的动作 10、具有视频管理功能支持萤石云协议的摄像头均可接入云平台可在云平台直接预览视频画面 11、可记录设备、用户所有操作记录设备、用户上下线记录等并具有多种类型的数据统计展示 12、云平台可对所有用户管理每个用户可配置不同角色、不同权限具有权限分配功能支持对人员进行菜单、按钮及数据权限控制亦可自定义数据权限 13、前端采用完全响应式布局支持电脑、平板、手机等所有主流设备 14、Maven 多项目依赖模块及插件分项目尽量松耦合方便模块升级、增减模块 等等……内容较多在此无法一一列举② DeviceService.selectDeviceList(device)DataScope(deptAliasd) // DataScopeAspect 改写 SQLMyBatis Mapper → 多数据源切换若方法标 DataSource(SLAVE)③ PageHelper 拦截器 → SELECT … LIMIT ?④ 结果封装 TableDataInfo → AjaxResult → 前端表格渲染⑤ LogAspect 记录操作日志异步线程池⑥ 异常 → GlobalExceptionHandler → AjaxResult.error(msg)------------------------------------------------五、二次开发必看指南新增工具方法直接新建 XxxUtils 放在 common.utils 包静态方法private 构造补充单元测试即可。新增通用枚举实现 IEnumgetValue/getDescription即可被 ExcelUtil、DictUtils 自动识别。新增数据源步骤① application-druid.yml 加 spring.datasource.druid.xxx步骤② DataSourceType 枚举新增 XXX步骤③ DruidConfig.java 新增 xxxDataSource() Bean步骤④ 在 Service/Mapper 方法加 DataSource(xxx)自定义异常继承 BaseException 并写对应枚举GlobalExceptionHandler 中追加一个 ExceptionHandler统一返回格式保持 AjaxResult。关闭/降级功能• xss.enabledfalse → 关闭 XSS 过滤• user.password.maxRetryCount0 → 关闭密码重试限制• mqtt.enabledfalse → 关闭 MQTT 自动配置------------------------------------------------六、性能与运维指标维度数据单实例 4C8G备注最大在线设备50 万MQTT 集群LB并发 HTTP3 k QPSPageHelper读写分离日志异步延迟50 msScheduledThreadPool堆内存占用启动 350 MB开启 30 个线程池FullGC 频率1 次/天G1 6G Heap------------------------------------------------七、常见坑与排查分页失效现象PageHelper 返回全部数据原因startPage() 与 Mapper 调用之间插了别的 SQL如 selectDictLabel解决把非分页 SQL 提到 startPage() 之前数据源切换不生效现象DataSource(SLAVE) 仍走主库原因方法被同类内部调用AOP 未生效解决拆到另一个 Service或启用 AopContext.currentProxy()MQTT 断线重连风暴现象EMQX 看到海量重连原因clientId 重复serverId001解决clientId serverId IpUtils.getHostIp() _ PIDExcel 导出 OOM现象SXSSF 仍内存溢出原因row.createCell() 之后未 flush()或图片一次性读入解决图片采用 InputStream 延迟读取每 5000 行 flush------------------------------------------------八、版本演进路线v2.2当前└─ 多数据源、MQTT、防重、XSS、代码生成v2.4规划中└─ 集成 Redis 缓存、Spring Validation 分组、Flowable 工作流、EMQX 规则引擎桥接v3.0远期└─ 全面云原生Spring Cloud Alibaba K8s Istio Prometheus SkyWalking------------------------------------------------九、结语ksoft-common 通过“注解驱动 AOP 织入 工具下沉”的策略把 80% 的物联网后台通用问题一次性解决。作为二次开发者只需关注① 业务实体 ② 业务 Mapper ③ 业务 Controller——其余基础设施ksoft-common 已全部备好。熟读本文即可在 30 分钟内跑通新模块1 小时内发布到测试环境次日即可交付客户。祝开发愉快