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

网页如何设计.NET Core大文件上传的日志记录与监控系统？

news 2026/5/12 11:31:47

作为上海某软件公司项目负责人，我最近正为“大文件传输功能集成”的事儿焦头烂额——公司现有产品覆盖政府、金融、能源等多个行业，客户对文件传输的需求从“能用”升级到了“好用、稳定、安全”。但市面上开源组件要么停更（如WebUploader）、要么功能残缺（不支持文件夹层级、断点续传不稳定），甚至遇到问题找不到技术支持，这让我们在和国企、央企客户谈合作时底气不足。

我们的核心需求（挑明不绕弯）

大文件传输能力：单文件100G+，文件夹保留层级（含10万+子文件场景），必须支持断点续传（刷新/关闭浏览器不丢进度）。
安全合规：加密传输（HTTPS+国密SM4/AES可选）、加密存储（密钥可配置），满足信创要求。
兼容与稳定：兼容IE8（Windows 7老机器）、主流浏览器；支持ASP.NET WebForm/.NET Core双技术栈；前端兼容vue2/vue3/React。
轻量集成：无缝嵌入现有产品，不改动原有业务流程和数据结构，避免“为了传文件把系统重构一遍”。
可维护性：供应商需提供长期技术支持（至少5年），附带央企/国企合作案例（合同、软著、信创认证等），降低决策风险。

我们的解决方案（从架构到代码）

经过3个月调研和内部测试，我们最终选择了“自研核心模块+成熟组件适配”的方案——基于分片上传、断点续传、加密存储三大核心技术，结合阿里云OSS的扩展能力，同时兼容旧系统和新框架。以下是关键实现细节：

一、架构设计（一张图说清）

二、关键技术点（附代码示例）

1. 前端：跨框架分片上传（兼容IE8+）

（基于原生JS封装，支持vue2/vue3/React，IE8用iframe fallback）

// utils/FileUploader.js（核心上传逻辑）classFileUploader{constructor(options){this.chunkSize=options.chunkSize||5*1024*1024;// 5MB分片（100G分2万片）this.file=options.file;this.uploadId=options.uploadId;// 全局唯一上传ID（用于断点续传）this.progressCallback=options.progressCallback;this.onSuccess=options.onSuccess;this.onError=options.onError;}}// 使用示例（vue3组件）exportdefault{methods:{asynchandleFileUpload(file){constuploadId=uuidv4();// 生成全局唯一IDconstuploader=newFileUploader({file,uploadId,chunkSize:5*1024*1024,progressCallback:(progress)=>{this.progress=progress;},onSuccess:(res)=>{this.$message.success('上传成功！');},onError:(err)=>{this.$message.error(`上传失败：${err.msg}`);}});awaituploader.start();}}};

2. 后端：ASP.NET WebForm/.NET Core 双栈支持（分片接收+加密存储）

（核心逻辑兼容新旧技术栈，SQL Server记录进度，阿里云OSS存储）

// ASP.NET WebForm 版本（UploadHandler.ashx）publicclassUploadHandler:IHttpHandler{publicvoidProcessRequest(HttpContextcontext){context.Response.ContentType="application/json";varaction=context.Request["action"];switch(action){case"check":// 检查已上传分片CheckChunks(context);break;case"chunk":// 接收分片UploadChunk(context);break;case"merge":// 合并分片MergeChunks(context);break;}}privatevoidCheckChunks(HttpContextcontext){varuploadId=context.Request["uploadId"];using(varconn=newSqlConnection(ConfigurationManager.ConnectionStrings["FileDB"].ConnectionString)){conn.Open();varcmd=newSqlCommand("SELECT ChunkIndex FROM UploadProgress WHERE UploadId = @UploadId",conn);cmd.Parameters.AddWithValue("@UploadId",uploadId);varreader=cmd.ExecuteReader();varuploadedChunks=newList();while(reader.Read()){uploadedChunks.Add(reader.GetInt32(0));}context.Response.Write(JsonConvert.SerializeObject(new{uploadedChunks}));}}privatebyte[]AesEncrypt(byte[]data,stringkey){using(varaes=Aes.Create()){aes.Key=Encoding.UTF8.GetBytes(key);aes.IV=newbyte[16];// 实际需生成随机IV并存储varencryptor=aes.CreateEncryptor(aes.Key,aes.IV);using(varms=newMemoryStream()){using(varcs=newCryptoStream(ms,encryptor,CryptoStreamMode.Write)){cs.Write(data,0,data.Length);}returnms.ToArray();}}}publicboolIsReusable=>false;}

3. 下载功能：非打包+自动解密（防服务器崩溃）

（通过分片下载+前端合并，支持10万+文件场景）

// 前端下载逻辑（vue组件）methods:{asyncdownloadFolder(folderId){// 获取文件夹结构（后端返回文件列表）const{data}=awaitthis.$http.get(`/api/folder/${folderId}/files`);constfiles=data.files;// 并发下载分片（控制并发数防服务器压力）constconcurrency=5;constdownloadPromises=[];for(leti=0;i<files.length;i+=concurrency){constbatch=files.slice(i,i+concurrency);batch.forEach(async(file)=>{const{data:chunks}=awaitthis.$http.get(`/api/file/${file.id}/chunks`);constdecryptedChunks=[];for(constchunkofchunks){constres=awaitthis.$http.get(`/api/file/chunk/${chunk.id}`,{responseType:'blob'});decryptedChunks.push(awaitthis.decryptChunk(res.data));}constmergedFile=awaitthis.mergeChunks(decryptedChunks);this.saveFile(mergedFile,file.name);// 保存到本地});}},// 解密分片（AES/SM4）asyncdecryptChunk(encryptedChunk){constkey=awaitthis.$http.get('/api/config/decryptKey');// 从后端获取密钥constiv=encryptedChunk.slice(0,16);// 假设IV存储在分片前16字节constdata=encryptedChunk.slice(16);constdecipher=crypto.createDecipheriv('aes-256-cbc',key,iv);returnBuffer.concat([decipher.update(data),decipher.final()]);},// 合并分片mergeChunks(chunks){returnnewBlob(chunks,{type:'application/octet-stream'});},// 保存文件到本地saveFile(blob,fileName){consturl=URL.createObjectURL(blob);consta=document.createElement('a');a.href=url;a.download=fileName;a.click();URL.revokeObjectURL(url);}}