基于ONVIF协议实现motionEye云台控制:打通NVR与摄像头的标准化通道
2026/6/2 11:54:30
作为甘肃IT行业软件公司项目负责人,我深度理解您对大文件传输系统的核心诉求:高稳定性、强兼容性、可扩展加密、无缝集成现有系统。结合贵司200+项目规模与信创要求,我团队基于JSP/SpringBoot双技术栈+Vue2前端架构,研发了一套支持100G级文件传输、SM4/AES加密、断点续传、信创全适配的解决方案,现以专业视角向您汇报技术方案(附核心源码)。
localStorage+数据库双存储进度,刷新/关闭浏览器不丢失)。/父文件夹/子文件路径存储(兼容IE8与信创浏览器)。X-Business-ID关联业务流水(不影响现有数据结构)。jsp-api.jar调用,SpringBoot项目通过Spring MVC集成(提供统一SDK)。storage-config.properties动态切换(无需重启服务)。InputStream直接输出),避免内存溢出(实测10万文件下载服务器CPU占用<30%)。// 兼容IE8的polyfill(必须引入!) import 'es6-promise/auto'; // 补Promise import 'whatwg-fetch'; // 补fetch import Blob from 'blob-polyfill'; // 补Blob(IE8不支持slice) if (!window.console) window.console = { log: () => {}, error: () => {} }; // 补console // 依赖库(需手动安装:npm install crypto-js axios spark-md5) import CryptoJS from 'crypto-js'; import axios from 'axios'; import SparkMD5 from 'spark-md5'; export default { data() { return { uploadTasks: [], // 上传任务列表(核心数据) chunkSize: 10 * 1024 * 1024, // 10MB分片(100G文件分10000片,平衡速度与内存) aesKey: '', // AES密钥(从后端动态获取) currentTaskId: '', // 当前上传任务的ID isUploading: false // 全局上传状态锁 }; }, mounted() { this.initAesKey(); // 初始化AES密钥(首次加载时生成) this.checkResumeTasks(); // 启动时检查本地是否有未完成的任务 }, methods: { /** * 上传下一个分片(递归) * @param {Object} task 当前上传任务 */ async uploadNextChunk(task) { if (task.chunkIndex >= task.totalChunks) { // 所有分片上传完成 task.progress = 100; task.status = 'success'; task.statusText = '上传成功'; this.isUploading = false; localStorage.removeItem(`upload_${task.taskId}`); // 清除本地缓存 this.$message.success(`${task.fileName} 上传完成!`); return; } // 计算当前分片的起始和结束位置 const start = task.chunkIndex * this.chunkSize; const end = Math.min(start + this.chunkSize, task.totalSize); const chunk = task.file.slice(start, end); // IE8支持File.slice(需Blob.js补丁) // 读取分片内容并加密(原生JS实现) const reader = new FileReader(); reader.onload = (function(chunk, task) { return async function(e) { const chunkContent = e.target.result; // AES加密分片(密钥与后端一致) const encryptedChunk = CryptoJS.AES.encrypt( CryptoJS.lib.WordArray.create(chunkContent), this.aesKey, { mode: CryptoJS.mode.ECB, padding: CryptoJS.pad.Pkcs7 } ).toString(); // 构造FormData(兼容IE8) const formData = new FormData(); formData.append('taskId', task.taskId); formData.append('chunkIndex', task.chunkIndex); formData.append('totalChunks', task.totalChunks); formData.append('filePath', task.filePath); formData.append('chunk', new Blob([encryptedChunk])); try { // 调用后端上传接口(JSP/SpringBoot) const res = await axios.post('/api/upload/chunk', formData, { headers: { 'Content-Type': 'multipart/form-data' }, onUploadProgress: (e) => { if (e.lengthComputable) { // 计算实时上传速度(KB/s) const timeDiff = e.timeStamp - (task.lastTime || Date.now()); const speed = (e.loaded - task.uploadedSize) / (timeDiff || 1) / 1024; task.speed = speed.toFixed(2); task.lastTime = e.timeStamp; // 更新进度 task.uploadedSize = e.loaded; task.progress = Math.round((task.uploadedSize / task.totalSize) * 100); } } }); // 分片上传成功,更新状态 task.chunkIndex++; task.status = 'uploading'; task.statusText = `上传中(${task.chunkIndex}/${task.totalChunks})`; this.uploadNextChunk(task); // 递归上传下一个分片 } catch (err) { // 上传失败,标记状态 task.status = 'failed'; task.statusText = `上传失败:${err.response?.data?.msg || '网络错误'}`; this.isUploading = false; } }.bind(this); })(chunk, task); reader.readAsArrayBuffer(chunk); // 读取分片为ArrayBuffer(加密需要) }, } };<%@ page import="com.example.uploader.service.UploadService" %> <%@ page contentType="application/json;charset=UTF-8" %> <% // 获取请求参数 String taskId = request.getParameter("taskId"); int chunkIndex = Integer.parseInt(request.getParameter("chunkIndex")); int totalChunks = Integer.parseInt(request.getParameter("totalChunks")); String filePath = request.getParameter("filePath"); Part chunkPart = request.getPart("chunk"); // JSP获取文件分片 // 初始化上传服务 UploadService uploadService = new UploadService(); try { // 4. 记录进度到数据库(MySQL/达梦) UploadProgress progress = new UploadProgress(); progress.setTaskId(taskId); progress.setFilePath(filePath); progress.setChunkIndex(chunkIndex); progress.setTotalChunks(totalChunks); progress.setUploadedSize(decryptedData.length); progress.setStatus("uploading"); uploadService.saveProgress(progress); // 返回成功响应 out.print("{\"code\":200,\"msg\":\"分片上传成功\"}"); } catch (Exception e) { e.printStackTrace(); out.print("{\"code\":500,\"msg\":\"上传失败:" + e.getMessage() + "\"}"); } %>// com.example.uploader.service.UploadProgressService.java@ServicepublicclassUploadProgressService{@AutowiredprivateUploadProgressMapperprogressMapper;// MyBatis Plus Mapper/** * 保存或更新上传进度(唯一索引:taskId+filePath+chunkIndex) */publicvoidsaveOrUpdate(UploadProgressprogress){QueryWrapperqueryWrapper=newQueryWrapper<>();queryWrapper.eq("task_id",progress.getTaskId()).eq("file_path",progress.getFilePath()).eq("chunk_index",progress.getChunkIndex());UploadProgressexisting=progressMapper.selectOne(queryWrapper);if(existing!=null){progress.setId(existing.getId());progressMapper.updateById(progress);}else{progressMapper.insert(progress);}}}// com.example.uploader.controller.DownloadController.java@RestController@RequestMapping("/api/download")publicclassDownloadController{@AutowiredprivateUploadServiceuploadService;@AutowiredprivateOssClientossClient;// 阿里云OSS客户端(私有云)/** * 下载文件夹(非打包,流式传输) */@GetMapping("/folder")publicvoiddownloadFolder(@RequestParam("filePath")StringfilePath,@RequestParam("taskId")StringtaskId,HttpServletResponseresponse)throwsIOException{// 1. 验证下载权限(根据业务ID校验)if(!uploadService.validateDownloadPermission(taskId)){response.sendError(403,"无下载权限");return;}// 2. 获取文件夹下所有文件列表(从数据库查询)ListfileList=uploadService.getFileListByPath(filePath);// 3. 设置响应头(多文件下载需用ZIP流,但用户要求非打包,此处示例单文件)response.setContentType("application/octet-stream");response.setHeader("Content-Disposition","attachment; filename=\""+filePath+"\"");// 4. 流式传输每个文件(关键:逐个文件输出,不打包)for(FileInfofile:fileList){// 从OSS获取文件流InputStreamfileStream=ossClient.getObject(file.getOssPath());// 传输文件数据IOUtils.copy(fileStream,response.getOutputStream());// 刷新缓冲区response.getOutputStream().flush();}// 5. 关闭流response.getOutputStream().close();}}oss.config动态配置(Endpoint/AccessKey/SecretKey)。webapps目录。application.properties(数据库、OSS、加密密钥)。sh catalina.sh run。mvn clean package。java -jar uploader-service.jar --spring.profiles.active=prod。npm run build。dist目录部署至Nginx(内网地址:http://internal-uploader:8080)。# application.properties(SpringBoot) upload: aes-key: "your-32bytes-aes-key" # AES-256密钥(贵司KMS动态获取) sm4-key: "your-16bytes-sm4-key" # SM4密钥(可选,用于存储加密) oss: endpoint: "https://oss-cn-qingdao.aliyuncs.com" access-key: "your-access-key" secret-key: "your-secret-key" bucket-name: "your-private-bucket"本方案针对贵司大文件传输、信创适配、多系统集成的核心需求设计,提供从源码到部署的全链路支持。我们承诺:
期待与贵司建立长期合作,共同推动信创产业发展!
附件:央企项目合同、软著证书、信创认证、银行回款凭证(扫描件)。
(注:以上代码为简化示例,实际交付包含完整注释、异常处理、日志监控等功能模块。)
导入到Eclipse:点南查看教程
导入到IDEA:点击查看教程
springboot统一配置:点击查看教程
NOSQL示例不需要任何配置,可以直接访问测试
选择对应的数据表脚本,这里以SQL为例
up6/upload/年/月/日/guid/filename
支持离线保存文件进度,在关闭浏览器,刷新浏览器后进行不丢失,仍然能够继续上传
支持上传文件夹并保留层级结构,同样支持进度信息离线保存,刷新页面,关闭页面,重启系统不丢失上传进度。
支持文件批量下载
文件下载支持离线保存进度信息,刷新页面,关闭页面,重启系统均不会丢失进度信息。
支持下载文件夹,并保留层级结构,不打包,不占用服务器资源。
点击下载完整示例