当前位置：首页 > news >正文

HTML5结合Vue3实现超大文件分片上传的加密传输方案？

news 2026/6/28 11:06:59

中石油旗下子公司大文件传输系统技术方案

一、项目背景与需求分析

作为中石油集团旗下专注于能源信息化领域的子公司，我司长期服务于政府及军工单位，在能源管理、安全生产等关键领域积累了丰富的行业经验。本次政府招投标项目提出的大文件传输需求具有以下特殊性：

功能需求：
- 支持20GB以上超大文件传输
- 支持文件夹结构上传/下载（保持目录层级）
- 支持断点续传、分片校验、传输加密
- 支持传输队列管理（优先级控制）
兼容性要求：
- 主流浏览器（Chrome/Firefox/Edge/国产浏览器）
- 信创国产化环境（麒麟/统信UOS + 飞腾/鲲鹏/龙芯）
- 数据库兼容性（SQL Server/达梦/人大金仓）
技术架构约束：
- 后端：ASP.NET Framework 4.8（暂不考虑.NET Core迁移）
- 前端：ASP.NET WebForms（需兼容IE11及现代浏览器）
- 需提供完整源代码及知识产权
特殊需求：
- 军工级安全要求（等保三级）
- 传输过程不可逆加密
- 详细的操作审计日志

二、现有方案评估

2.1 已评估开源方案

组件名称	优点	缺点
WebUploader	成熟度高	已停更（最后更新2018年），不支持信创环境
Fine Uploader	商业级功能	许可证成本高，定制开发受限
Dropzone.js	简单易用	仅支持基础上传，缺乏大文件处理能力
Plupload	多后端支持	文档陈旧，.NET实现效率低

2.2 核心问题

信创环境兼容性：现有组件均未针对国产CPU架构和操作系统进行优化
技术架构限制：ASP.NET WebForms的异步处理能力有限
安全合规性：开源组件缺乏军工级加密和审计功能
文件夹支持：大多数组件仅支持单文件上传

三、自研组件技术方案

3.1 架构设计

┌─────────────────────┐ ┌─────────────────────┐ ┌─────────────────────┐ │ ASP.NET WebForms │ │ IIS (WebDAV) │ │ WCF/ASP.NET服务 │ │ (前端上传控件) │←──→│ (静态资源+代理) │←──→│ (传输处理服务) │ └─────────────────────┘ └─────────────────────┘ └─────────────────────┘ ↑ ↑ ↑ HTML5 File API SignalR实时通知 ADO.NET多数据库适配 (Folder API polyfill) (传输进度推送) (SQL Server/达梦/人大金仓)

3.2 核心代码实现

前端实现（ASP.NET WebForms控件）

// FileTransferControl.ascx.cspublicpartialclassFileTransferControl:System.Web.UI.UserControl{protectedvoidPage_Load(objectsender,EventArgse){if(!IsPostBack){RegisterClientScripts();}}privatevoidRegisterClientScripts(){stringscript=@" // 文件夹选择兼容性处理（IE11+现代浏览器） function handleFolderSelect(event) { const input = event.target; if (input.files && input.files.length > 0) { processFiles(input.files); } } // 分片上传核心逻辑 async function uploadFile(file, options) { const chunkSize = 10 * 1024 * 1024; // 10MB分片 const chunks = Math.ceil(file.size / chunkSize); let uploadedChunks = 0; // 计算文件SM3哈希（国产密码算法） const fileHash = await calculateSM3Hash(file); // 检查文件是否已存在 const checkResult = await $.ajax({ url: 'FileTransferHandler.ashx?action=check', type: 'POST', data: { fileName: file.name, fileSize: file.size, fileHash } }); if (checkResult.exists) { showProgress(file.name, 100); return; } // 分片上传 for (let i = 0; i < chunks; i++) { const start = i * chunkSize; const end = Math.min(start + chunkSize, file.size); const chunk = file.slice(start, end); const formData = new FormData(); formData.append('file', chunk); formData.append('fileId', options.fileId); formData.append('chunkIndex', i); formData.append('totalChunks', chunks); formData.append('fileHash', fileHash); formData.append('relativePath', options.relativePath || ''); await $.ajax({ url: 'FileTransferHandler.ashx?action=upload', type: 'POST', data: formData, processData: false, contentType: false, xhr: function() { const xhr = new XMLHttpRequest(); xhr.upload.addEventListener('progress', function(e) { if (e.lengthComputable) { const progress = Math.round( (uploadedChunks * chunkSize + e.loaded) / file.size * 100 ); showProgress(file.name, progress); } }, false); return xhr; } }); uploadedChunks++; } // 通知服务器合并 await $.ajax({ url: 'FileTransferHandler.ashx?action=merge', type: 'POST', data: { fileId: options.fileId, fileHash, totalChunks: chunks, originalName: file.name, relativePath: options.relativePath } }); showProgress(file.name, 100); } // SM3哈希计算（通过Web Worker） function calculateSM3Hash(file) { return new Promise((resolve) => { const worker = new Worker('/Scripts/sm3.worker.js'); worker.postMessage({ file }); worker.onmessage = (e) => resolve(e.data.hash); }); }";ScriptManager.RegisterStartupScript(this,GetType(),"FileTransferScript",script,true);}protectedvoidbtnUpload_Click(objectsender,EventArgse){// 服务器端初始化上传会话stringsessionId=Guid.NewGuid().ToString();Session["FileTransfer_"+sessionId]=newFileTransferSession{StartTime=DateTime.Now,UserId=User.Identity.Name,ClientIP=Request.UserHostAddress};hdnSessionId.Value=sessionId;}}

后端实现（ASP.NET通用处理程序）

// FileTransferHandler.ashx.cspublicclassFileTransferHandler:IHttpHandler{privatereadonlyIFileStorageService_storageService;privatereadonlyIAuditLogService_auditLog;publicFileTransferHandler(){// 通过依赖注入或服务定位器获取服务_storageService=ServiceLocator.Current.GetInstance();_auditLog=ServiceLocator.Current.GetInstance();}publicvoidProcessRequest(HttpContextcontext){context.Response.ContentType="application/json";try{varaction=context.Request["action"];varsessionId=context.Request["sessionId"]??context.Request.Cookies["FileTransferSession"];varsession=context.Session["FileTransfer_"+sessionId]asFileTransferSession;if(session==null){thrownewInvalidOperationException("无效的传输会话");}switch(action?.ToLower()){case"check":HandleCheckRequest(context,session);break;case"upload":HandleUploadRequest(context,session);break;case"merge":HandleMergeRequest(context,session);break;case"download":HandleDownloadRequest(context,session);break;default:thrownewNotSupportedException("不支持的操作");}}catch(Exceptionex){context.Response.StatusCode=500;context.Response.Write(JsonConvert.SerializeObject(new{success=false,message=ex.Message}));// 记录错误日志_auditLog.LogError("FileTransfer",ex.ToString(),context.Request.UserHostAddress,User.Identity.Name);}}privatevoidHandleCheckRequest(HttpContextcontext,FileTransferSessionsession){varfileName=context.Request["fileName"];varfileSize=long.Parse(context.Request["fileSize"]);varfileHash=context.Request["fileHash"];// 多数据库适配查询varexists=_storageService.CheckFileExists(fileHash,fileSize);context.Response.Write(JsonConvert.SerializeObject(new{success=true,exists,fileId=Guid.NewGuid().ToString()}));// 记录审计日志_auditLog.LogAccess("FileCheck",$"{fileName}({fileSize}bytes)",context.Request.UserHostAddress,User.Identity.Name);}privatevoidHandleUploadRequest(HttpContextcontext,FileTransferSessionsession){if(context.Request.Files.Count==0){thrownewArgumentException("未接收到文件数据");}varfile=context.Request.Files[0];varfileId=context.Request["fileId"];varchunkIndex=int.Parse(context.Request["chunkIndex"]);vartotalChunks=int.Parse(context.Request["totalChunks"]);varfileHash=context.Request["fileHash"];varrelativePath=context.Request["relativePath"];// 临时存储路径（按会话ID分目录）vartempPath=Path.Combine(_storageService.TempDirectory,fileId);Directory.CreateDirectory(tempPath);varchunkPath=Path.Combine(tempPath,$"chunk-{chunkIndex}");file.SaveAs(chunkPath);// 记录分片上传日志（数据库适配）using(vardb=DatabaseFactory.CreateDatabase()){db.ExecuteNonQuery("INSERT INTO FileTransferChunks (FileId, ChunkIndex, Size, UploadTime) "+"VALUES (@fileId, @chunkIndex, @size, GETDATE())",fileId,chunkIndex,file.ContentLength);}context.Response.Write(JsonConvert.SerializeObject(new{success=true,chunkIndex,receivedSize=file.ContentLength}));}// 其他处理方法...}

多数据库适配层

// DatabaseFactory.cspublicstaticclassDatabaseFactory{privatestaticreadonlystring_dbType=ConfigurationManager.AppSettings["DatabaseType"];publicstaticIDatabaseCreateDatabase(){switch(_dbType?.ToUpper()){case"DM":returnnewDamengDatabaseAdapter();case"KINGBASE":returnnewKingbaseDatabaseAdapter();case"SQLSERVER":default:returnnewSqlServerDatabaseAdapter();}}}publicinterfaceIDatabase:IDisposable{intExecuteNonQuery(stringsql,paramsobject[]parameters);objectExecuteScalar(stringsql,paramsobject[]parameters);DataTableExecuteDataTable(stringsql,paramsobject[]parameters);}// SQL Server实现publicclassSqlServerDatabaseAdapter:IDatabase{privateSqlConnection_connection;publicSqlServerDatabaseAdapter(){_connection=newSqlConnection(ConfigurationManager.ConnectionStrings["SqlServer"].ConnectionString);_connection.Open();}publicintExecuteNonQuery(stringsql,paramsobject[]parameters){using(varcmd=newSqlCommand(sql,_connection)){cmd.Parameters.AddRange(parameters.Select((p,i)=>newSqlParameter($"@param{i}",p??DBNull.Value)).ToArray());returncmd.ExecuteNonQuery();}}// 其他方法实现...publicvoidDispose(){_connection?.Dispose();}}// 达梦数据库实现publicclassDamengDatabaseAdapter:IDatabase{privateDmConnection_connection;publicDamengDatabaseAdapter(){_connection=newDmConnection(ConfigurationManager.ConnectionStrings["Dameng"].ConnectionString);_connection.Open();}publicintExecuteNonQuery(stringsql,paramsobject[]parameters){// 达梦特定语法适配sql=sql.Replace("GETDATE()","SYSDATE").Replace("[","\"").Replace("]","\"");using(varcmd=newDmCommand(sql,_connection)){cmd.Parameters.AddRange(parameters.Select((p,i)=>newDmParameter($":param{i}",p??DBNull.Value)).ToArray());returncmd.ExecuteNonQuery();}}// 其他方法实现...}

3.3 信创环境适配方案

国产密码算法集成：

// SM3哈希计算（通过P/Invoke调用国产密码库）publicstaticclassSM3Helper{[DllImport("GMSSL.dll",EntryPoint="SM3_Compute",CharSet=CharSet.Ansi)]privatestaticexternintNativeSM3Compute(byte[]input,intinputLen,byte[]output);publicstaticstringComputeHash(Streamstream){constintbufferSize=8192;byte[]buffer=newbyte[bufferSize];intbytesRead;using(varsm3=SM3.Create())// 使用BouncyCastle的SM3实现或国产密码库{while((bytesRead=stream.Read(buffer,0,bufferSize))>0){sm3.TransformBlock(buffer,0,bytesRead,null,0);}sm3.TransformFinalBlock(buffer,0,0);returnBitConverter.ToString(sm3.Hash).Replace("-","").ToLower();}}}

国产操作系统文件系统优化：

publicclassKylinFileOptimizer:IFileOptimizer{publicvoidOptimizeFileHandle(FileInfofile){if(IsKylinOS()){// 调用国产文件系统特性NativeMethods.SetFileAttribute(file.FullName,FileAttributes.KylinOptimized);}}privateboolIsKylinOS(){returnDirectory.Exists("/etc/kylin")||Directory.Exists("/usr/lib/kylin");}}