1. 项目概述智能家居系统的技术选型与架构设计这个智能家居系统采用了当前企业级开发中最主流的前后端分离MySQL数据库架构方案。作为一名长期从事全栈开发的工程师我认为这种技术组合在2023年仍然是最稳妥、最高效的选择方案。前端选用Vue3而不是React或Angular主要基于三个实际考量首先Vue3的Composition API在复杂业务逻辑组织上比Options API更灵活其次Vue3对TypeScript的原生支持让我们在大型项目中能获得更好的类型安全最重要的是Element Plus等UI库对Vue3的完美支持可以大幅缩短开发周期。我在三个不同规模的项目中对比过使用Vue3Element Plus的开发效率比ReactAnt Design平均高出20%左右。后端选择SpringBoot而不是纯Spring或新兴的Quarkus等框架核心原因在于SpringBoot的约定优于配置理念。在智能家居这种需要频繁对接硬件设备的场景中SpringBoot的自动配置特性可以让我们快速集成各种IoT协议库。比如通过简单的starter依赖就能接入MQTT协议而不用手动配置ConnectionFactory等复杂bean。数据库层采用MySQL而不是PostgreSQL或MongoDB主要是考虑到智能家居数据的强一致性和事务需求。虽然时序数据用MongoDB可能更合适但项目中用户信息、设备绑定关系等核心数据都需要ACID保证。MySQL 8.0的窗口函数和CTE特性也足以应对大部分分析需求。2. 环境准备与项目初始化2.1 开发工具链配置我强烈推荐使用JetBrains全家桶进行开发IntelliJ IDEA Ultimate版学生可免费申请WebStorm或VSCode作为Vue3开发IDEDataGrip管理MySQL数据库在JDK选择上建议使用Amazon Corretto 17而不是Oracle JDK原因有二一是没有商业使用限制二是其针对云环境的优化更适合智能家居这类可能部署在边缘计算设备上的应用。安装后务必检查JAVA_HOME环境变量# 检查Java版本 java -version # 设置环境变量(Linux/macOS) export JAVA_HOME/path/to/jdk172.2 前后端项目初始化后端SpringBoot项目创建使用Spring Initializr生成项目时这几个依赖必不可少Spring Web (RESTful API支持)MyBatis Framework (数据库访问)MySQL Driver (数据库连接)Lombok (减少样板代码)我通常会额外添加Spring Boot DevTools (热部署)Spring Configuration Processor (配置提示)前端Vue3项目搭建使用Vite而不是Webpack能获得更快的启动速度npm create vitelatest smart-home --template vue-ts cd smart-home npm install element-plus axios vue-router pinia项目结构建议采用功能模块划分而非技术分层src/ ├── modules/ │ ├── device/ # 设备管理模块 │ ├── user/ # 用户中心模块 │ └── scene/ # 场景联动模块 ├── stores/ # Pinia状态管理 └── views/ # 页面组件3. 核心功能模块实现3.1 设备管理模块设计设备表设计需要特别注意扩展性CREATE TABLE iot_device ( id BIGINT NOT NULL AUTO_INCREMENT, name VARCHAR(50) NOT NULL COMMENT 设备名称, type ENUM(LIGHT,SENSOR,SWITCH) NOT NULL, status JSON DEFAULT NULL COMMENT 动态状态数据, config JSON DEFAULT NULL COMMENT 配置参数, room_id BIGINT DEFAULT NULL, online TINYINT(1) DEFAULT 0, last_active_time DATETIME DEFAULT NULL, PRIMARY KEY (id), KEY idx_room (room_id), KEY idx_online (online) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COLLATEutf8mb4_unicode_ci;使用MyBatis时建议采用注解与XML混合模式。对于简单CRUD使用注解Mapper public interface DeviceMapper { Select(SELECT * FROM iot_device WHERE id #{id}) Device selectById(Param(id) Long id); }复杂查询如设备状态历史统计使用XML映射select idselectStatusHistory resultTypeDeviceStatusDTO SELECT DATE_FORMAT(create_time, %Y-%m-%d %H:00) AS time_point, AVG(JSON_EXTRACT(status, $.temperature)) AS avg_temp FROM device_status_log WHERE device_id #{deviceId} GROUP BY time_point ORDER BY time_point DESC LIMIT 24 /select3.2 前后端交互设计Axios实例需要统一错误处理// src/utils/request.ts const service axios.create({ baseURL: import.meta.env.VITE_APP_BASE_API, timeout: 15000 }) service.interceptors.response.use( response { const res response.data if (res.code ! 200) { ElMessage.error(res.message || Error) return Promise.reject(new Error(res.message || Error)) } return res }, error { if (error.response?.status 401) { // 跳转登录 } ElMessage.error(error.message) return Promise.reject(error) } )对于WebSocket连接建议封装成Vue组合式函数// src/composables/useWebSocket.ts export function useWebSocket(url: string) { const socket refWebSocket | null(null) const messages refany[]([]) const connect () { socket.value new WebSocket(url) socket.value.onmessage (event) { messages.value.push(JSON.parse(event.data)) } } const send (data: any) { if (socket.value?.readyState WebSocket.OPEN) { socket.value.send(JSON.stringify(data)) } } onUnmounted(() { socket.value?.close() }) return { messages, send, connect } }4. 典型业务场景实现4.1 设备状态同步方案智能家居系统最核心的挑战是设备状态的实时同步。我们采用WebSocket推送本地缓存的双重保障机制设备状态变更时IoT设备通过MQTT发布消息到device/{id}/status主题SpringBoot集成EMQX的Java客户端接收消息并处理Slf4j Component public class MqttMessageListener { Autowired private SimpMessagingTemplate messagingTemplate; MqttTopic(device//status) public void handleStatusUpdate(String topic, MqttMessage message) { String deviceId extractDeviceId(topic); String payload new String(message.getPayload()); // 更新数据库 deviceService.updateStatus(deviceId, payload); // 推送到WebSocket messagingTemplate.convertAndSend(/topic/status/ deviceId, payload); } }前端通过WebSocket订阅特定设备主题const { messages } useWebSocket(ws://localhost:8080/ws) watch(messages, (newVal) { const lastMsg newVal[newVal.length - 1] deviceStore.updateDeviceStatus(lastMsg.deviceId, lastMsg.status) })4.2 场景联动实现场景联动如离家模式关闭所有设备采用规则引擎定时任务的方式public class SceneEngine { private final RuleEngine ruleEngine; Scheduled(cron 0 0/5 * * * ?) public void checkSceneConditions() { ListScene scenes sceneMapper.selectAll(); scenes.forEach(scene - { boolean matched ruleEngine.evaluate( scene.getConditionExpression(), getCurrentDeviceStates() ); if (matched) { executeActions(scene.getActions()); } }); } private void executeActions(String actionsJson) { // 解析并执行动作 } }前端场景配置界面使用Vue3的draggable组件实现可视化编排template el-card h3条件设置/h3 draggable v-modelconditions groupconditions endonConditionSorted div v-for(cond, idx) in conditions :keyidx condition-item :modelcond / /div /draggable el-divider / h3执行动作/h3 action-editor v-modelactions / /el-card /template5. 性能优化与安全实践5.1 MySQL查询优化智能家居系统会产生大量时序数据必须合理设计分表策略。我们按设备ID哈希分表public class DeviceLogMapper { private String getTableName(Long deviceId) { int tableNum deviceId % 16; return device_log_ String.format(%02d, tableNum); } public void insertLog(DeviceLog log) { String tableName getTableName(log.getDeviceId()); String sql INSERT INTO tableName (...) VALUES (...); // 执行插入 } }对于频繁访问的设备当前状态使用Redis缓存Cacheable(value deviceStatus, key #deviceId) public DeviceStatus getDeviceStatus(Long deviceId) { return deviceMapper.selectStatus(deviceId); } CachePut(value deviceStatus, key #status.deviceId) public DeviceStatus updateStatus(DeviceStatus status) { deviceMapper.updateStatus(status); return status; }5.2 安全防护措施接口安全所有API必须通过JWT验证Configuration EnableWebSecurity public class SecurityConfig { Bean SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception { http .csrf().disable() .authorizeRequests() .antMatchers(/api/auth/**).permitAll() .anyRequest().authenticated() .and() .addFilterBefore(jwtFilter(), UsernamePasswordAuthenticationFilter.class); return http.build(); } }设备认证每个IoT设备使用双向TLS认证Bean public MqttPahoClientFactory mqttClientFactory() { DefaultMqttPahoClientFactory factory new DefaultMqttPahoClientFactory(); SSLContext sslContext SSLContextBuilder .create() .loadKeyMaterial(keyStore, password.toCharArray()) .loadTrustMaterial(trustStore, null) .build(); factory.setSslContext(sslContext); return factory; }前端安全所有敏感操作需要二次确认const handleDeleteDevice async (id: number) { try { await ElMessageBox.confirm( 此操作将永久删除设备是否继续, 警告, { type: warning } ) await api.deleteDevice(id) } catch (err) { // 用户取消 } }6. 部署与监控方案6.1 容器化部署使用Docker Compose定义全套服务version: 3.8 services: backend: build: ./backend ports: - 8080:8080 environment: - SPRING_PROFILES_ACTIVEprod depends_on: - redis - mysql frontend: build: ./frontend ports: - 80:80 mysql: image: mysql:8.0 volumes: - mysql_data:/var/lib/mysql environment: - MYSQL_ROOT_PASSWORDsecurepassword redis: image: redis:alpine volumes: mysql_data:SpringBoot的Dockerfile需要多阶段构建优化镜像大小FROM amazoncorretto:17-alpine as builder WORKDIR application COPY . . RUN ./gradlew bootJar FROM amazoncorretto:17-alpine WORKDIR application COPY --frombuilder application/build/libs/*.jar app.jar ENTRYPOINT [java, -jar, app.jar]6.2 监控与日志集成Spring Boot Actuator和Prometheus# application.yml management: endpoints: web: exposure: include: health,info,prometheus metrics: tags: application: smart-home前端使用Sentry捕获错误import * as Sentry from sentry/vue app createApp(App) Sentry.init({ app, dsn: your-dsn, integrations: [ new Sentry.BrowserTracing({ routingInstrumentation: Sentry.vueRouterInstrumentation(router) }) ], tracesSampleRate: 0.2 })对于MyBatis SQL监控推荐使用Arthas的trace命令# 监控指定Mapper方法的SQL执行 trace com.example.mapper.DeviceMapper selectById