1. 项目概述基于若依框架的物联网平台开发实践第一次接触若依RuoYi框架是在2018年一个智慧农业项目中当时需要快速搭建一个具备设备管理能力的后台系统。这个基于Spring Boot的快速开发框架以其完善的基础功能和模块化设计让我在两周内就完成了传统开发需要一个月的工作量。如今将若依框架与物联网技术结合可以构建出功能强大且易于维护的物联网管理平台。物联网平台的核心使命是解决设备连接、数据采集和业务处理的闭环问题。传统开发方式往往需要从零开始构建用户管理、权限控制等基础模块而若依框架已经提供了这些开箱即用的功能。根据我的实测数据使用若依作为基础可以节省约60%的基础功能开发时间让团队更专注于物联网特有的业务逻辑实现。这个平台特别适合以下场景中小型物联网项目需要快速落地验证传统企业数字化改造中的设备联网需求教学演示或技术预研阶段的原型搭建已有若依系统需要扩展物联网能力2. 技术架构设计2.1 基础框架选型分析若依框架目前有单体架构和微服务架构两个版本。对于大多数物联网场景我推荐使用单体架构版本基于Spring Boot除非遇到以下情况才考虑微服务版本设备连接数超过5万需要跨地域部署团队具备成熟的微服务运维能力技术栈组合建议前端Vue2/Vue3根据团队技术储备选择后端Spring Boot 2.7 MyBatis-Plus数据库MySQL 8.0或PostgreSQL消息中间件EMQX 4.4社区版已足够缓存Redis 6.x注意若依默认集成的是Redis单节点在生产环境中建议至少配置哨兵模式。我在某智慧园区项目中就曾因单节点宕机导致设备状态丢失。2.2 物联网核心模块设计物联网平台需要扩展的核心模块包括设备管理模块设备档案型号、SN、位置等在线状态监控固件版本管理数据采集模块遥测数据接收MQTT/HTTP数据解析引擎存储策略配置规则引擎模块阈值告警规则联动控制策略场景化规则模板可视化模块设备面板定制数据趋势分析地理信息展示在我的某工厂设备监控项目中通过若依代码生成器快速构建了设备管理模块的基础CRUD功能节省了约40个工时。3. 关键实现细节3.1 MQTT集成方案EMQX与若依的集成是物联网平台的核心。推荐以下配置方式// application.yml 配置示例 emqx: broker: tcp://127.0.0.1:1883 username: ruoyi_iot password: 加密后的密码 client-id: ruoyi-server-${random.uuid} topics: - device//status - device//telemetry消息处理建议采用Spring Event机制Service public class MqttMessageListener { EventListener public void handleMqttMessage(MqttMessageEvent event) { String topic event.getTopic(); String payload event.getPayload(); // 业务处理交给异步线程池 ThreadPoolTaskExecutor executor SpringUtils.getBean(threadPoolTaskExecutor); executor.execute(() - processMessage(topic, payload)); } private void processMessage(String topic, String payload) { // 实际业务逻辑 } }3.2 设备鉴权实现物联网设备连接需要严格的安全控制。推荐采用三重鉴权机制设备级认证每个设备分配唯一的clientId和凭证Topic权限控制限制设备只能发布/订阅指定主题数据签名验证重要指令需携带签名若依的权限体系可以扩展用于设备管理-- 设备权限表设计示例 CREATE TABLE iot_device_permission ( device_id varchar(64) NOT NULL COMMENT 设备ID, publish_topics varchar(1024) DEFAULT NULL COMMENT 可发布主题, subscribe_topics varchar(1024) DEFAULT NULL COMMENT 可订阅主题, create_time datetime DEFAULT NULL COMMENT 创建时间, PRIMARY KEY (device_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;3.3 数据存储优化物联网数据具有高并发写入的特点需要特殊处理冷热数据分离热数据最近7天MySQL温数据1年内TimescaleDB冷数据1年以上对象存储分表策略// 按月分表示例 public class DeviceDataShardingStrategy implements TableShardingStrategy { Override public String determineTableName(String logicTable, Object params) { LocalDateTime now LocalDateTime.now(); return logicTable _ now.getYear() _ now.getMonthValue(); } }缓存策略设备最新状态Redis String设置TTL历史数据查询Redis ZSET按时间排序4. 典型问题解决方案4.1 设备连接不稳定现象设备频繁掉线重连间隔不规则排查步骤检查EMQX的listeners.tcp.default配置# EMQX控制台命令 emqx_ctl listeners show调整KeepAlive参数建议60-300秒检查网络延迟和丢包率解决方案# 修改EMQX配置 echo listeners.tcp.default.keepalive 300 /etc/emqx/emqx.conf systemctl restart emqx4.2 消息堆积问题现象消费者处理速度跟不上消息生产速度优化方案增加消费者线程池Configuration public class ThreadPoolConfig { Bean(iotMessageExecutor) public Executor iotMessageExecutor() { ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor(); executor.setCorePoolSize(Runtime.getRuntime().availableProcessors() * 2); executor.setMaxPoolSize(50); executor.setQueueCapacity(1000); executor.setThreadNamePrefix(iot-message-); return executor; } }启用消息批量处理KafkaListener(topics device.telemetry, containerFactory batchFactory) public void handleBatchMessages(ListConsumerRecord?, ? records) { // 批量处理逻辑 }4.3 权限同步延迟现象设备权限变更后未及时生效解决方案实现EMQX的HTTP认证钩子RestController RequestMapping(/auth) public class EmqxAuthController { PostMapping(/device) public ResponseEntity? authenticateDevice(RequestBody AuthRequest request) { // 实时查询数据库验证 boolean valid deviceService.validateDevice(request.getClientid(), request.getUsername(), request.getPassword()); return valid ? ResponseEntity.ok().build() : ResponseEntity.status(401).build(); } }配置EMQX使用外部认证# etc/plugins/emqx_auth_http.conf auth.http.auth_req http://127.0.0.1:8080/auth/device auth.http.super_req http://127.0.0.1:8080/auth/superuser5. 性能优化实践5.1 数据库连接池调优若依默认使用HikariCP连接池物联网场景建议调整# application.yml spring: datasource: hikari: maximum-pool-size: 20 minimum-idle: 5 connection-timeout: 30000 idle-timeout: 600000 max-lifetime: 1800000实测数据在500并发设备场景下上述配置比默认设置减少约30%的连接等待时间5.2 EMQX集群配置当设备数超过单节点承载能力时需要搭建EMQX集群准备3台服务器推荐配置4C8G设置节点名称# 每台机器修改/etc/emqx/emqx.conf node.name emqx192.168.1.1配置集群发现策略cluster.discovery static cluster.static.seeds emqx192.168.1.1,emqx192.168.1.2,emqx192.168.1.35.3 前端性能优化设备列表页面对性能要求较高推荐采用以下方案虚拟滚动技术template el-table :datatableData stylewidth: 100% heightcalc(100vh - 180px) row-keyid :row-height54 :totaltotal scrollhandleScroll !-- 列定义 -- /el-table /templateWebSocket实时更新created() { this.socket new WebSocket(ws://your-domain.com/ws/device); this.socket.onmessage (event) { const data JSON.parse(event.data); this.updateDeviceStatus(data); }; }6. 安全加固措施6.1 通信安全MQTT over TLS# EMQX配置 listeners.ssl.default { bind 0.0.0.0:8883 max_connections 102400 ssl_options { keyfile /etc/emqx/certs/key.pem certfile /etc/emqx/certs/cert.pem cacertfile /etc/emqx/certs/cacert.pem } }API接口签名public class ApiSignInterceptor implements HandlerInterceptor { Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) { String sign request.getHeader(X-Sign); String timestamp request.getHeader(X-Timestamp); // 验证时间戳防止重放攻击 if (System.currentTimeMillis() - Long.parseLong(timestamp) 300000) { throw new RuntimeException(请求已过期); } // 验证签名 String expectedSign generateSign(request, timestamp); if (!expectedSign.equals(sign)) { throw new RuntimeException(签名验证失败); } return true; } }6.2 数据安全敏感数据加密public class DataEncryptor { private static final String AES_KEY your-256-bit-key; public static String encrypt(String data) { // AES加密实现 } public static String decrypt(String encrypted) { // AES解密实现 } }数据库字段加密TableName(iot_device) public class Device { TableField(typeHandler EncryptTypeHandler.class) private String secretKey; // getters setters }7. 部署与运维7.1 容器化部署推荐使用Docker Compose部署整套系统version: 3 services: emqx: image: emqx:4.4 ports: - 1883:1883 - 8883:8883 - 8083:8083 - 8084:8084 volumes: - ./emqx_data:/opt/emqx/data mysql: image: mysql:8.0 environment: MYSQL_ROOT_PASSWORD: yourpassword volumes: - ./mysql_data:/var/lib/mysql redis: image: redis:6 command: redis-server --requirepass yourpassword volumes: - ./redis_data:/data ruoyi: build: . ports: - 8080:8080 depends_on: - mysql - redis - emqx7.2 监控方案Prometheus Grafana监控EMQX指标采集# etc/plugins/emqx_prometheus.conf prometheus.interval 15 prometheus.push_gateway_server http://prometheus:9091若依应用监控!-- pom.xml -- dependency groupIdio.micrometer/groupId artifactIdmicrometer-registry-prometheus/artifactId /dependency日志收集!-- logback-spring.xml -- appender nameELK classnet.logstash.logback.appender.LogstashTcpSocketAppender destinationlogstash:5044/destination encoder classnet.logstash.logback.encoder.LogstashEncoder/ /appender8. 扩展与二次开发8.1 多租户支持物联网SaaS平台需要多租户隔离数据库层面ALTER TABLE iot_device ADD tenant_id VARCHAR(32) NOT NULL; CREATE INDEX idx_tenant ON iot_device(tenant_id);MyBatis拦截器Intercepts(Signature(type Executor.class, methodquery, args{MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class})) public class TenantInterceptor implements Interceptor { Override public Object intercept(Invocation invocation) throws Throwable { // 自动添加tenant_id条件 Object parameter invocation.getArgs()[1]; if (parameter instanceof Map) { ((Map) parameter).put(tenantId, getCurrentTenant()); } return invocation.proceed(); } }8.2 边缘计算集成通过与边缘网关配合实现边缘计算边缘规则引擎# 边缘网关规则脚本示例 def on_message(msg): if msg.topic.startswith(sensor/temperature): temp float(msg.payload) if temp 30: publish(actuator/fan, ON)云端同步机制public class EdgeSyncService { Scheduled(fixedRate 300000) public void syncEdgeRules() { ListRule cloudRules ruleService.listActiveRules(); edgeDevices.forEach(device - { sendRulesToEdge(device.getId(), cloudRules); }); } }在最近的一个智慧路灯项目中我们采用这种架构将云端计算负载降低了约40%同时显著提升了控制响应速度。