1. 项目概述JavaSSMFlask混合架构教学平台开发实录这个项目是我去年为本地一所职业院校开发的课程辅助教学系统采用JavaSSM作为后端核心Flask处理轻量级服务前后端分离架构。平台上线后日均访问量稳定在2000成功承载了12门专业课的在线教学任务。不同于常见的单一技术栈方案这种混合架构既发挥了Java企业级开发的稳定性优势又利用了Python在数据处理方面的灵活性。关键数据系统峰值QPS达到380课程资源库累计存储2.3TB教学资料支持5种主流文档格式在线预览2. 技术选型与架构设计2.1 为什么选择SSMFlask混合架构SSMSpringSpringMVCMyBatis作为主框架处理核心业务逻辑Spring 5.2.6IoC容器管理Bean生命周期SpringMVCRESTful接口设计Content Negotiation处理多种数据格式MyBatis 3.5.6二级缓存自定义TypeHandler优化数据库操作Flask 1.1.2负责专项服务文件内容提取PDF/Word/PPT文本抽取简单数据分析学习行为统计定时任务调度课件自动归档// SSM中集成Flask服务的典型调用示例 RestController RequestMapping(/api/document) public class DocController { Autowired private RestTemplate restTemplate; GetMapping(/preview/{fileId}) public ResponseEntitybyte[] previewDocument(PathVariable String fileId) { // 调用Flask文档预处理服务 String flaskUrl http://flask-service:5000/preview?id fileId; return restTemplate.exchange(flaskUrl, HttpMethod.GET, null, byte[].class); } }2.2 数据库设计要点MySQL 8.0主从架构设计主库写操作核心业务表course_info课程基础信息chapter_structure章节树形结构从库读密集型操作resource_download资源下载记录qa_interaction问答数据-- 课程章节表的递归CTE查询设计 CREATE TABLE course_chapter ( chapter_id BIGINT PRIMARY KEY, course_id BIGINT NOT NULL, parent_id BIGINT DEFAULT NULL, chapter_name VARCHAR(100) NOT NULL, sort_order INT DEFAULT 0, FOREIGN KEY (parent_id) REFERENCES course_chapter (chapter_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;3. 核心功能实现细节3.1 多格式课件在线预览方案文件处理流程用户上传文件到MinIO对象存储Flask服务监听存储桶事件根据文件类型调用不同处理器PDFPyPDF2提取文本pdf.js前端渲染Officepython-pptx/docx库转换HTML视频FFmpeg生成HLS分片# Flask中的文件处理器示例 app.route(/convert, methods[POST]) def convert_file(): file request.files[file] file_type file.filename.split(.)[-1].lower() if file_type pdf: with tempfile.NamedTemporaryFile() as tmp: file.save(tmp.name) text extract_pdf_text(tmp.name) return jsonify({text: text}) elif file_type in [docx, doc]: return convert_word_to_html(file) else: abort(415, descriptionUnsupported media type)3.2 实时问答系统实现技术组合WebSocket协议维持长连接Redis Pub/Sub处理消息广播MySQL存储问答持久化数据// SSM中的WebSocket配置 Configuration EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer { Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(qaSocketHandler(), /qa) .setAllowedOrigins(*) .addInterceptors(new HttpSessionHandshakeInterceptor()); } Bean public QASocketHandler qaSocketHandler() { return new QASocketHandler(); } }4. 性能优化实战记录4.1 高并发下载解决方案遇到的问题热门课件下载导致服务器带宽打满数据库连接池耗尽最终方案七牛云CDN静态资源加速下载请求限流Guava RateLimiter异步记录下载日志// 下载限流实现 RestController RequestMapping(/download) public class DownloadController { private final RateLimiter rateLimiter RateLimiter.create(100.0); // 每秒100个令牌 GetMapping(/resource/{id}) public ResponseEntityResource downloadResource(PathVariable String id) { if (!rateLimiter.tryAcquire()) { throw new RateLimitExceededException(); } // ...实际下载逻辑 } }4.2 缓存策略设计多级缓存架构本地Caffeine缓存高频访问数据课程基本信息用户权限数据Redis集群缓存分布式共享数据热门课件列表实时排行榜数据MySQL查询缓存复杂查询结果缓存更新策略课程信息TTL 30分钟 修改时主动失效排行榜数据定时任务每5分钟更新5. 部署与监控方案5.1 容器化部署架构Docker Compose编排方案version: 3.8 services: mysql-master: image: mysql:8.0 environment: MYSQL_ROOT_PASSWORD: ${DB_ROOT_PASS} ports: - 3306:3306 volumes: - mysql-data:/var/lib/mysql flask-service: build: ./flask ports: - 5000:5000 depends_on: - redis java-app: build: ./java ports: - 8080:8080 depends_on: - mysql-master - redis volumes: mysql-data:5.2 监控指标配置Prometheus监控重点JVM指标GC次数、堆内存MySQL连接池使用率Flask服务响应时间接口成功率5xx错误率Grafana看板包含实时在线人数资源下载速度趋势API响应时间百分位图异常请求TOP10统计6. 典型问题排查手册6.1 跨域会话丢失问题现象Flask服务获取不到Java端设置的Cookie解决方案明确设置Cookie域和路径Cookie cookie new Cookie(sessionid, token); cookie.setDomain(.yourdomain.com); cookie.setPath(/); cookie.setHttpOnly(true); response.addCookie(cookie);配置CORS过滤器Bean public CorsFilter corsFilter() { UrlBasedCorsConfigurationSource source new UrlBasedCorsConfigurationSource(); CorsConfiguration config new CorsConfiguration(); config.setAllowCredentials(true); config.addAllowedOrigin(https://frontend.yourdomain.com); config.addAllowedHeader(*); config.addAllowedMethod(*); source.registerCorsConfiguration(/**, config); return new CorsFilter(source); }6.2 MyBatis批量插入优化原始方案问题万级数据插入耗时超过10分钟优化后方案使用BatchExecutor改写Mapper配置insert idbatchInsert parameterTypejava.util.List INSERT INTO download_log (user_id, resource_id, create_time) VALUES foreach collectionlist itemitem separator, (#{item.userId}, #{item.resourceId}, #{item.createTime}) /foreach /insert添加rewriteBatchedStatementstrue参数优化效果10万条数据插入从6分钟降至8秒7. 安全防护实践7.1 课件下载权限控制实现方案动态链接签名HMAC-SHA256时效性控制5分钟有效期下载次数限制单个链接最大3次public String generateDownloadUrl(Long resourceId) { long timestamp System.currentTimeMillis(); String raw resourceId | timestamp | SECRET_SALT; String sign HmacUtils.hmacSha256Hex(API_SECRET, raw); return String.format(/download?res%dt%ds%s, resourceId, timestamp, sign); }7.2 XSS防护策略多层次防护前端DOMPurify过滤HTML后端Jackson自定义转义Bean public Jackson2ObjectMapperBuilder objectMapperBuilder() { return new Jackson2ObjectMapperBuilder() .defaultHtmlEscaping(true) .serializers(new StringUnicodeSerializer()); }数据库存储前内容清洗8. 项目演进方向当前正在实施的改进引入Elasticsearch实现全文检索基于OpenCV开发课件图片OCR功能使用Kubernetes实现自动扩缩容技术债务清单需要重构的模块积分系统耦合度过高待优化的查询学习轨迹分析SQL计划替换的组件从MinIO迁移到阿里云OSS Java+SSM与Flask混合架构教学平台开发实践
1. 项目概述JavaSSMFlask混合架构教学平台开发实录这个项目是我去年为本地一所职业院校开发的课程辅助教学系统采用JavaSSM作为后端核心Flask处理轻量级服务前后端分离架构。平台上线后日均访问量稳定在2000成功承载了12门专业课的在线教学任务。不同于常见的单一技术栈方案这种混合架构既发挥了Java企业级开发的稳定性优势又利用了Python在数据处理方面的灵活性。关键数据系统峰值QPS达到380课程资源库累计存储2.3TB教学资料支持5种主流文档格式在线预览2. 技术选型与架构设计2.1 为什么选择SSMFlask混合架构SSMSpringSpringMVCMyBatis作为主框架处理核心业务逻辑Spring 5.2.6IoC容器管理Bean生命周期SpringMVCRESTful接口设计Content Negotiation处理多种数据格式MyBatis 3.5.6二级缓存自定义TypeHandler优化数据库操作Flask 1.1.2负责专项服务文件内容提取PDF/Word/PPT文本抽取简单数据分析学习行为统计定时任务调度课件自动归档// SSM中集成Flask服务的典型调用示例 RestController RequestMapping(/api/document) public class DocController { Autowired private RestTemplate restTemplate; GetMapping(/preview/{fileId}) public ResponseEntitybyte[] previewDocument(PathVariable String fileId) { // 调用Flask文档预处理服务 String flaskUrl http://flask-service:5000/preview?id fileId; return restTemplate.exchange(flaskUrl, HttpMethod.GET, null, byte[].class); } }2.2 数据库设计要点MySQL 8.0主从架构设计主库写操作核心业务表course_info课程基础信息chapter_structure章节树形结构从库读密集型操作resource_download资源下载记录qa_interaction问答数据-- 课程章节表的递归CTE查询设计 CREATE TABLE course_chapter ( chapter_id BIGINT PRIMARY KEY, course_id BIGINT NOT NULL, parent_id BIGINT DEFAULT NULL, chapter_name VARCHAR(100) NOT NULL, sort_order INT DEFAULT 0, FOREIGN KEY (parent_id) REFERENCES course_chapter (chapter_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;3. 核心功能实现细节3.1 多格式课件在线预览方案文件处理流程用户上传文件到MinIO对象存储Flask服务监听存储桶事件根据文件类型调用不同处理器PDFPyPDF2提取文本pdf.js前端渲染Officepython-pptx/docx库转换HTML视频FFmpeg生成HLS分片# Flask中的文件处理器示例 app.route(/convert, methods[POST]) def convert_file(): file request.files[file] file_type file.filename.split(.)[-1].lower() if file_type pdf: with tempfile.NamedTemporaryFile() as tmp: file.save(tmp.name) text extract_pdf_text(tmp.name) return jsonify({text: text}) elif file_type in [docx, doc]: return convert_word_to_html(file) else: abort(415, descriptionUnsupported media type)3.2 实时问答系统实现技术组合WebSocket协议维持长连接Redis Pub/Sub处理消息广播MySQL存储问答持久化数据// SSM中的WebSocket配置 Configuration EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer { Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(qaSocketHandler(), /qa) .setAllowedOrigins(*) .addInterceptors(new HttpSessionHandshakeInterceptor()); } Bean public QASocketHandler qaSocketHandler() { return new QASocketHandler(); } }4. 性能优化实战记录4.1 高并发下载解决方案遇到的问题热门课件下载导致服务器带宽打满数据库连接池耗尽最终方案七牛云CDN静态资源加速下载请求限流Guava RateLimiter异步记录下载日志// 下载限流实现 RestController RequestMapping(/download) public class DownloadController { private final RateLimiter rateLimiter RateLimiter.create(100.0); // 每秒100个令牌 GetMapping(/resource/{id}) public ResponseEntityResource downloadResource(PathVariable String id) { if (!rateLimiter.tryAcquire()) { throw new RateLimitExceededException(); } // ...实际下载逻辑 } }4.2 缓存策略设计多级缓存架构本地Caffeine缓存高频访问数据课程基本信息用户权限数据Redis集群缓存分布式共享数据热门课件列表实时排行榜数据MySQL查询缓存复杂查询结果缓存更新策略课程信息TTL 30分钟 修改时主动失效排行榜数据定时任务每5分钟更新5. 部署与监控方案5.1 容器化部署架构Docker Compose编排方案version: 3.8 services: mysql-master: image: mysql:8.0 environment: MYSQL_ROOT_PASSWORD: ${DB_ROOT_PASS} ports: - 3306:3306 volumes: - mysql-data:/var/lib/mysql flask-service: build: ./flask ports: - 5000:5000 depends_on: - redis java-app: build: ./java ports: - 8080:8080 depends_on: - mysql-master - redis volumes: mysql-data:5.2 监控指标配置Prometheus监控重点JVM指标GC次数、堆内存MySQL连接池使用率Flask服务响应时间接口成功率5xx错误率Grafana看板包含实时在线人数资源下载速度趋势API响应时间百分位图异常请求TOP10统计6. 典型问题排查手册6.1 跨域会话丢失问题现象Flask服务获取不到Java端设置的Cookie解决方案明确设置Cookie域和路径Cookie cookie new Cookie(sessionid, token); cookie.setDomain(.yourdomain.com); cookie.setPath(/); cookie.setHttpOnly(true); response.addCookie(cookie);配置CORS过滤器Bean public CorsFilter corsFilter() { UrlBasedCorsConfigurationSource source new UrlBasedCorsConfigurationSource(); CorsConfiguration config new CorsConfiguration(); config.setAllowCredentials(true); config.addAllowedOrigin(https://frontend.yourdomain.com); config.addAllowedHeader(*); config.addAllowedMethod(*); source.registerCorsConfiguration(/**, config); return new CorsFilter(source); }6.2 MyBatis批量插入优化原始方案问题万级数据插入耗时超过10分钟优化后方案使用BatchExecutor改写Mapper配置insert idbatchInsert parameterTypejava.util.List INSERT INTO download_log (user_id, resource_id, create_time) VALUES foreach collectionlist itemitem separator, (#{item.userId}, #{item.resourceId}, #{item.createTime}) /foreach /insert添加rewriteBatchedStatementstrue参数优化效果10万条数据插入从6分钟降至8秒7. 安全防护实践7.1 课件下载权限控制实现方案动态链接签名HMAC-SHA256时效性控制5分钟有效期下载次数限制单个链接最大3次public String generateDownloadUrl(Long resourceId) { long timestamp System.currentTimeMillis(); String raw resourceId | timestamp | SECRET_SALT; String sign HmacUtils.hmacSha256Hex(API_SECRET, raw); return String.format(/download?res%dt%ds%s, resourceId, timestamp, sign); }7.2 XSS防护策略多层次防护前端DOMPurify过滤HTML后端Jackson自定义转义Bean public Jackson2ObjectMapperBuilder objectMapperBuilder() { return new Jackson2ObjectMapperBuilder() .defaultHtmlEscaping(true) .serializers(new StringUnicodeSerializer()); }数据库存储前内容清洗8. 项目演进方向当前正在实施的改进引入Elasticsearch实现全文检索基于OpenCV开发课件图片OCR功能使用Kubernetes实现自动扩缩容技术债务清单需要重构的模块积分系统耦合度过高待优化的查询学习轨迹分析SQL计划替换的组件从MinIO迁移到阿里云OSS