智能客服在封闭场景下的乱答问题分析与实战解决方案
2026/3/19 11:40:47
作为浙江IT行业软件公司项目负责人,我们面临的大文件传输需求具有很高的技术挑战性。以下是我针对该需求的专业解决方案分析。
[客户端] --> [负载均衡] --> [Web服务器] --> [应用服务器] --> [数据库] ↑ ↓ [文件存储] (阿里云OSS/本地存储)// Vue2示例 - 大文件上传组件import{encryptFile,generateFileKey}from'@/utils/crypto';import{uploadFile}from'@/api/file';exportdefault{data(){return{files:[],uploader:null};},methods:{handleFileChange(e){constfileList=Array.from(e.target.files);this.files=fileList.map(file=>({file,name:file.name,size:file.size,progress:0,fileKey:generateFileKey(file),chunks:Math.ceil(file.size/(5*1024*1024))// 5MB分片}));},asyncstartUpload(){for(constfileInfoofthis.files){awaitthis.uploadFileByChunk(fileInfo);}},asyncuploadFileByChunk(fileInfo){const{file,chunks}=fileInfo;constchunkSize=5*1024*1024;// 5MB每片for(leti=0;i<chunks;i++){conststart=i*chunkSize;constend=Math.min(file.size,start+chunkSize);constchunk=file.slice(start,end);// 加密分片constencryptedChunk=awaitencryptFile(chunk,'SM4');constformData=newFormData();formData.append('file',encryptedChunk);formData.append('chunkIndex',i);formData.append('chunks',chunks);formData.append('fileKey',fileInfo.fileKey);formData.append('fileName',file.name);formData.append('filePath',file.webkitRelativePath||'');try{awaituploadFile(formData,progress=>{fileInfo.progress=Math.floor((i*100+progress*(100/chunks))/chunks);});}catch(error){console.error('上传失败:',error);break;}}}}};// Spring Boot控制器示例 - 文件分片上传@RestController@RequestMapping("/api/file")publicclassFileUploadController{@AutowiredprivateFileServicefileService;@PostMapping("/upload")publicResponseEntityuploadFile(@RequestParam("file")MultipartFilefile,@RequestParam("chunkIndex")intchunkIndex,@RequestParam("chunks")intchunks,@RequestParam("fileKey")StringfileKey,@RequestParam(value="filePath",required=false)StringfilePath,HttpSessionsession){try{// 解密文件分片byte[]decryptedData=CryptoUtil.decrypt(file.getBytes(),"SM4");// 处理文件上传FileUploadResultresult=fileService.handleFileUpload(fileKey,file.getOriginalFilename(),filePath,decryptedData,chunkIndex,chunks,session.getId());returnResponseEntity.ok(result);}catch(Exceptione){returnResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(newErrorResponse("文件上传失败: "+e.getMessage()));}}@GetMapping("/resumeInfo")publicResponseEntitygetResumeInfo(@RequestParam("fileKey")StringfileKey,HttpSessionsession){try{ResumeInfoinfo=fileService.getResumeInfo(fileKey,session.getId());returnResponseEntity.ok(info);}catch(Exceptione){returnResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(newErrorResponse("获取续传信息失败: "+e.getMessage()));}}}// 断点续传服务实现@ServicepublicclassFileServiceImplimplementsFileService{@AutowiredprivateFileUploadRepositoryuploadRepository;@AutowiredprivateStorageServicestorageService;@OverridepublicFileUploadResulthandleFileUpload(StringfileKey,StringfileName,StringfilePath,byte[]data,intchunkIndex,inttotalChunks,StringsessionId){// 检查是否已有上传记录FileUploadRecordrecord=uploadRepository.findByFileKey(fileKey);if(record==null){record=newFileUploadRecord();record.setFileKey(fileKey);record.setFileName(fileName);record.setFilePath(filePath);record.setTotalChunks(totalChunks);record.setSessionId(sessionId);record.setUploadedChunks(newArrayList<>());uploadRepository.save(record);}// 存储分片StringchunkKey=fileKey+"_"+chunkIndex;storageService.storeChunk(chunkKey,data);// 更新上传记录if(!record.getUploadedChunks().contains(chunkIndex)){record.getUploadedChunks().add(chunkIndex);uploadRepository.save(record);}// 检查是否所有分片已上传完成if(record.getUploadedChunks().size()==totalChunks){mergeFileChunks(record);returnnewFileUploadResult(true,100,"文件上传完成");}intprogress=(int)((record.getUploadedChunks().size()*100.0)/totalChunks);returnnewFileUploadResult(false,progress,"分片上传成功");}privatevoidmergeFileChunks(FileUploadRecordrecord){// 合并所有分片为完整文件Listchunks=newArrayList<>();for(inti=0;i<record.getTotalChunks();i++){StringchunkKey=record.getFileKey()+"_"+i;byte[]chunkData=storageService.getChunk(chunkKey);chunks.add(chunkData);}// 合并并存储最终文件byte[]fileData=mergeChunks(chunks);storageService.storeFinalFile(record.getFileKey(),fileData);// 清理临时分片for(inti=0;i<record.getTotalChunks();i++){StringchunkKey=record.getFileKey()+"_"+i;storageService.deleteChunk(chunkKey);}// 更新记录为已完成record.setCompleted(true);uploadRepository.save(record);}}// 文件夹结构处理publicclassFileStructureService{publicvoidsaveFolderStructure(StringbasePath,ListfileItems){Map>directoryMap=newHashMap<>();// 按目录分组for(FileItemitem:fileItems){StringdirPath=extractDirectoryPath(item.getFilePath());directoryMap.computeIfAbsent(dirPath,k->newArrayList<>()).add(item);}// 保存目录结构到数据库for(Map.Entry>entry:directoryMap.entrySet()){saveDirectoryRecord(basePath,entry.getKey(),entry.getValue());}}privateStringextractDirectoryPath(StringfilePath){intlastSlash=filePath.lastIndexOf('/');returnlastSlash>0?filePath.substring(0,lastSlash):"";}privatevoidsaveDirectoryRecord(StringbasePath,StringdirPath,Listfiles){DirectoryRecordrecord=newDirectoryRecord();record.setBasePath(basePath);record.setPath(dirPath);record.setFileCount(files.size());// 计算目录大小longsize=files.stream().mapToLong(FileItem::getSize).sum();record.setTotalSize(size);// 保存到数据库directoryRepository.save(record);}}// 文件夹下载服务@ServicepublicclassFolderDownloadService{@AutowiredprivateDirectoryRepositorydirectoryRepository;@AutowiredprivateFileRecordRepositoryfileRecordRepository;@AutowiredprivateStorageServicestorageService;publicStreamingResponseBodydownloadFolder(StringfolderId,HttpServletResponseresponse){// 获取文件夹信息DirectoryRecordfolder=directoryRepository.findById(folderId).orElseThrow(()->newResourceNotFoundException("文件夹不存在"));// 设置响应头response.setContentType("application/octet-stream");response.setHeader("Content-Disposition","attachment; filename=\""+folder.getName()+"\"");// 创建ZIP输出流(不实际打包,流式传输)returnoutputStream->{Listfiles=fileRecordRepository.findByDirectoryId(folderId);for(FileRecordfile:files){// 设置当前文件头response.setHeader("X-File-Name",file.getName());response.setHeader("X-File-Path",file.getPath());response.setHeader("X-File-Size",String.valueOf(file.getSize()));// 流式传输文件内容try(InputStreaminputStream=storageService.getFileStream(file.getStorageKey())){byte[]buffer=newbyte[1024*1024];// 1MB bufferintbytesRead;while((bytesRead=inputStream.read(buffer))!=-1){outputStream.write(buffer,0,bytesRead);outputStream.flush();}}// 文件分隔标记outputStream.write("---FILE_SEPARATOR---".getBytes());outputStream.flush();}};}}// IE8兼容的上传方案functionsetupIe8Uploader(){if(navigator.userAgent.indexOf('MSIE 8.0')>-1){// IE8使用ActiveX或Flash方案varuploader=newActiveXObject("YourUploader.ActiveX");uploader.onprogress=function(file,loaded,total){updateProgress(file,(loaded/total)*100);};uploader.oncomplete=function(file){console.log('上传完成:',file);};// 注册事件处理document.getElementById('ie8UploadBtn').onclick=function(){varfileInput=document.getElementById('ie8FileInput');uploader.upload(fileInput.value);};}}// React适配器组件importReactfrom'react';import{useFileUpload}from'./useFileUpload';exportconstFileUploaderReact=({onUploadComplete})=>{const{files,handleFileChange,startUpload,progress}=useFileUpload();return(上传文件{files.map((file,index)=>({file.name}))});};// Vue3 Composition APIimport{ref}from'vue';import{uploadFile}from'@/api/file';exportfunctionuseFileUpload(){constfiles=ref([]);consthandleFileChange=(event)=>{files.value=Array.from(event.target.files).map(file=>({file,name:file.name,progress:0}));};conststartUpload=async()=>{for(constfileInfooffiles.value){awaituploadFile(fileInfo.file,(progress)=>{fileInfo.progress=progress;});}};return{files,handleFileChange,startUpload};}// 加密解密服务@ServicepublicclassCryptoService{privatestaticfinalStringAES_ALGORITHM="AES/CBC/PKCS5Padding";privatestaticfinalStringSM4_ALGORITHM="SM4/CBC/PKCS7Padding";publicbyte[]encrypt(byte[]data,Stringalgorithm,Stringkey){try{Ciphercipher=Cipher.getInstance(algorithm);SecretKeySpecsecretKey=newSecretKeySpec(key.getBytes(),algorithm.startsWith("AES")?"AES":"SM4");// 使用固定IV保证可恢复性(实际项目应安全存储IV)byte[]iv=newbyte[16];Arrays.fill(iv,(byte)0x01);IvParameterSpecivSpec=newIvParameterSpec(iv);cipher.init(Cipher.ENCRYPT_MODE,secretKey,ivSpec);returncipher.doFinal(data);}catch(Exceptione){thrownewCryptoException("加密失败",e);}}publicbyte[]decrypt(byte[]encryptedData,Stringalgorithm,Stringkey){try{Ciphercipher=Cipher.getInstance(algorithm);SecretKeySpecsecretKey=newSecretKeySpec(key.getBytes(),algorithm.startsWith("AES")?"AES":"SM4");byte[]iv=newbyte[16];Arrays.fill(iv,(byte)0x01);IvParameterSpecivSpec=newIvParameterSpec(iv);cipher.init(Cipher.DECRYPT_MODE,secretKey,ivSpec);returncipher.doFinal(encryptedData);}catch(Exceptione){thrownewCryptoException("解密失败",e);}}publicStringgenerateFileKey(Filefile){// 生成唯一文件标识(结合文件属性和时间戳)StringrawKey=file.getName()+file.length()+System.currentTimeMillis();returnDigestUtils.md5DigestAsHex(rawKey.getBytes());}}[客户端] → [CDN/负载均衡] → [Web服务器集群] ↓ [应用服务器集群] → [Redis集群(会话/缓存)] ↓ [数据库集群(主从)] [文件存储集群] (OSS/本地存储)# application-prd.ymlstorage:type:oss# 可选 local, oss, s3oss:endpoint:https://your-oss-endpoint.aliyuncs.comaccessKeyId:your-access-keyaccessKeySecret:your-secret-keybucketName:your-bucket-namelocal:rootPath:/data/file-storageserver:maxFileSize:100GBmaxRequestSize:101GBchunkSize:5MBsecurity:crypto:defaultAlgorithm:SM4aesKey:your-aes-keysm4Key:your-sm4-key导入到Eclipse:点击查看教程
导入到IDEA:点击查看教程
springboot统一配置:点击查看教程
NOSQL示例不需要任何配置,可以直接访问测试
选择对应的数据表脚本,这里以SQL为例
up6/upload/年/月/日/guid/filename
支持离线保存文件进度,在关闭浏览器,刷新浏览器后进行不丢失,仍然能够继续上传
支持上传文件夹并保留层级结构,同样支持进度信息离线保存,刷新页面,关闭页面,重启系统不丢失上传进度。
支持文件批量下载
文件下载支持离线保存进度信息,刷新页面,关闭页面,重启系统均不会丢失进度信息。
支持下载文件夹,并保留层级结构,不打包,不占用服务器资源。
点击下载完整示例