.NET或.NET Core Web APi基于tus协议实现断点续传

【导读】前两天我采用技巧式方案基本实现大文件分片上传,这里只是重点在于个人思路和亲身实践,若在实际生产环境要求比较高的话肯定不行,仍存在一些问题需要深入处理,本文继续在之前基础上给出基于tus协议的轮子方案,本打算再次尝试利用.NET Core实现此协议,但在github上一搜索早在2016年就已有此协议对应的.NET和.NET Core方案,并且一直更新到最近的.NET Core 3.x版本,完全满足各位所需,本文是我写出的一点demo。

基于tus协议实现断点续传演示

基于tus协议前端脚本

关于此协议实现原理这里不做阐述,请参照上述github地址自行了解,本文只是给出.NET Core方案下的基本demo,我们上传一个大文件然后通过进度显示上传进度以及对上传可暂停可继续,专业点讲就是断点续传,首先肯定是引入tus脚本和需要用到的bootstrap样式,我们将进度条默认隐藏,当上传时才显示,所以我们给出如下HTML。

<div class="form-horizontal" style="margin-top:80px;"><div class="form-group" id="progress-group" style="display:none;"><div id="size"></div><div class="progress"><div id="progress" class="progress-bar progress-bar-success progress-bar-animated progress-bar-striped" role="progressbar"aria-valuemin="0" aria-valuemax="100"><span id="percentage"></span></div></div></div><div class="form-group"><div class="col-md-10"><input name="file" id="file" type="file" /></div></div><div class="form-group"><div class="col-md-offset-2 col-md-10"><input type="submit" id="submit" value="上传" class="btn btn-success" /><input type="button" id="pause" value="暂停" class="btn btn-danger" /><input type="button" id="continue" value="继续" class="btn btn-info" /></div></div>
</div>


接下来就是使用引入的tus脚本,也没什么太多要讲解的,直接上代码,这里稍微注意的是在如下元数据(metadata)属性对象定义给出实际文件名,便于在后台最终将上传的文件转换为目标文件,至少得知道文件扩展名,对吧。

<script type="text/javascript">$(function () {var upload;//上传$('#submit').click(function () {$('#progress-group').show();var file = $('#file')[0].files[0];// 创建tus上传对象upload = new tus.Upload(file, {// 文件服务器上传终结点地址设置endpoint: "files/",// 重试延迟设置retryDelays: [0, 3000, 5000, 10000, 20000],// 附件服务器所需的元数据metadata: {name: file.name,contentType: file.type || 'application/octet-stream',emptyMetaKey: ''},// 回调无法通过重试解决的错误onError: function (error) {console.log("Failed because: " + error)},// 上传进度回调onProgress: onProgress,// 上传完成后回调onSuccess: function () {console.log("Download %s from %s", upload.file.name, upload.url)}})upload.start()});//暂停$('#pause').click(function () {upload.abort()});//继续$('#continue').click(function () {upload.start()});//上传进度展示function onProgress(bytesUploaded, bytesTotal) {var percentage = (bytesUploaded / bytesTotal * 100).toFixed(2);$('#progress').attr('aria-valuenow', percentage);$('#progress').css('width', percentage + '%');$('#percentage').html(percentage + '%');var uploadBytes = byteToSize(bytesUploaded);var totalBytes = byteToSize(bytesTotal);$('#size').html(uploadBytes + '/' + totalBytes);}//将字节转换为Byte、KB、MB等function byteToSize(bytes, separator = '', postFix = '') {if (bytes) {const sizes = ['Bytes', 'KB', 'MB', 'GB', 'TB'];const i = Math.min(parseInt(Math.floor(Math.log(bytes) / Math.log(1024)).toString(), 10), sizes.length - 1);return `${(bytes / (1024 ** i)).toFixed(i ? 1 : 0)}${separator}${sizes[i]}${postFix}`;}return 'n/a';}});</script>

基于tus协议tusdotnet

接下来进入后台,首先安装对应tus协议实现包,如下:

接下来则是添加tus中间件,说白了就是对tus的配置,各种配置都可满足你所需,这里我只实现了文件上传完成后将上传文件转换为目标文件的处理,紧接着将如下实现tus配置以单例形式注入即可

private DefaultTusConfiguration CreateTusConfiguration(IServiceProvider serviceProvider)
{var env = (IWebHostEnvironment)serviceProvider.GetRequiredService(typeof(IWebHostEnvironment));//文件上传路径var tusFiles = Path.Combine(env.WebRootPath, "tusfiles");return new DefaultTusConfiguration{UrlPath = "/files",//文件存储路径Store = new TusDiskStore(tusFiles),//元数据是否允许空值MetadataParsingStrategy = MetadataParsingStrategy.AllowEmptyValues,//文件过期后不再更新Expiration = new AbsoluteExpiration(TimeSpan.FromMinutes(5)),//事件处理(各种事件,满足你所需)Events = new Events{//上传完成事件回调OnFileCompleteAsync = async ctx =>{//获取上传文件var file = await ctx.GetFileAsync();//获取上传文件元数据var metadatas = await file.GetMetadataAsync(ctx.CancellationToken);//获取上述文件元数据中的目标文件名称var fileNameMetadata = metadatas["name"];//目标文件名以base64编码,所以这里需要解码var fileName = fileNameMetadata.GetString(Encoding.UTF8);var extensionName = Path.GetExtension(fileName);//将上传文件转换为实际目标文件File.Move(Path.Combine(tusFiles, ctx.FileId), Path.Combine(tusFiles, $"{ctx.FileId}{extensionName}"));}}};
}</script>

然后获取并使用上述添加的tus配置服务

app.UseTus(httpContext => Task.FromResult(httpContext.RequestServices.GetService<DefaultTusConfiguration>()));

在脚本中我们看到有个endpoint属性,此属性表示上传到服务器的上传结点地址,因为在上到服务器时我们可能需对此请求进行额外处理,比如元数据中的文件名是否已提供等等,所以我们在使用结点映射时,添加对上述结点名称的映射,如下

endpoints.MapGet("/files/{fileId}", DownloadFileEndpoint.HandleRoute);

该映射第二个参数为RequestDelegate,这个参数用过.NET Core的童鞋都知道,这里我是直接拷贝该包的路由实现,如下:

public static class DownloadFileEndpoint
{public static async Task HandleRoute(HttpContext context){var config = context.RequestServices.GetRequiredService<DefaultTusConfiguration>();if (!(config.Store is ITusReadableStore store)){return;}var fileId = (string)context.Request.RouteValues["fileId"];var file = await store.GetFileAsync(fileId, context.RequestAborted);if (file == null){context.Response.StatusCode = 404;await context.Response.WriteAsync($"File with id {fileId} was not found.", context.RequestAborted);return;}var fileStream = await file.GetContentAsync(context.RequestAborted);var metadata = await file.GetMetadataAsync(context.RequestAborted);context.Response.ContentType = GetContentTypeOrDefault(metadata);context.Response.ContentLength = fileStream.Length;if (metadata.TryGetValue("name", out var nameMeta)){context.Response.Headers.Add("Content-Disposition",new[] { $"attachment; filename=\"{nameMeta.GetString(Encoding.UTF8)}\"" });}using (fileStream){await fileStream.CopyToAsync(context.Response.Body, 81920, context.RequestAborted);}}private static string GetContentTypeOrDefault(Dictionary<string, Metadata> metadata){if (metadata.TryGetValue("contentType", out var contentType)){return contentType.GetString(Encoding.UTF8);}return "application/octet-stream";}
}

文件上传大小限制统一说明

我们知道无论是.NET还是.NET Core对于文件上传大小都有默认限制大小,这里对.NET Core中文件大小各种环境配置做一个统一说明,如果你将.NET Core寄宿在IIS上运行,那么请修改web.config配置文件大小限制

<system.webServer><security><requestFiltering>//若不配置,默认是28.6兆<requestLimits maxAllowedContentLength="1073741824" /></requestFiltering></security>
</system.webServer>

如果在开发环境默认使用IIS运行应用程序,请通过如下根据实际情况配置文件上传大小

services.Configure<IISServerOptions>(options =>{options.MaxRequestBodySize = int.MaxValue;});

如果程序运行在Kestrel服务器,那么请通过如下根据实际情况配置文件上传大小

services.Configure<KestrelServerOptions>(options =>
{//若不配置,默认是30兆(没记错的话)options.Limits.MaxRequestBodySize = int.MaxValue; 
});

如果是通过表单上传文件,那么请通过如下根据实际情况配置文件上传大小

services.Configure<FormOptions>(x =>
{x.ValueLengthLimit = int.MaxValue;//如果不配置,默认是128兆(没记错的话)x.MultipartBodyLengthLimit = int.MaxValue; x.MultipartHeadersLengthLimit = int.MaxValue;
});

为了更好体验可以再加上当前网络宽带情况或剩余多少分钟,更详细内容请参考:https://github.com/tusdotnet/tusdotnet 、https://github.com/tus/tus-js-client,关于大文件上传处理到此结束,希望对那些苦苦寻找最终解决方案而无助的童鞋们提供最佳轮子,谢谢。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/308300.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

省钱攻略送上!戴尔官网OptiPlex商用台式机到手仅需2279元!速速抢购!

如何用最少的钱磕到性价比超优的设备&#xff1f;两三千元左右的价格能买到狠货吗&#xff1f;来戴尔小企业官网&#xff0c;助力业务在线&#xff0c;Slay全场&#xff01;粉丝额外宠粉福利1.关注公众号 2.通过戴尔官网客服采购电脑产品3.发送订单截图至公众号后台就会有机会…

如何面对人生危机?

点击蓝字关注&#xff0c;回复“职场进阶”获取职场进阶精品资料一份一名读者提问&#xff1a;洋哥&#xff0c;我7年前从大厂出来&#xff0c;创业多年。连续失败&#xff0c;没买车也没房&#xff0c;女朋友也和我分手了&#xff0c;父母也对我失望至极。最近我开始焦虑、失眠…

不用虚机不用Docker使用Azure应用服务部署ASP.NET Core程序

一般我们写好了应用程序想要部署发布它&#xff0c;要么发布到物理机&#xff0c;要么发布到虚拟机&#xff0c;要么发布到容器来运行它。现在有了Azure应用服务&#xff0c;我们可以完全不用管这些东西&#xff0c;只管写好自己的代码&#xff0c;然后使用VisualStudio的发布功…

数码管显示1到8c语言,单片机控制八只数码管滚动显示1~8 附PROTEUS软件仿真图

数码管显示是每一个单片机初学者都必须学的&#xff0c;而单片机驱动数码管的数字循环显示实验&#xff0c;又是单片机基础中的基础&#xff0c;同时也是学好C语言编程的关键&#xff0c;此实验在硬件上可以弄清楚单片机驱动原理和数码管的显示原理&#xff0c;在软件上可以帮助…

.NET Core + Consul 服务注册与发现

在分布式架构中&#xff0c;服务治理是必须面对的问题&#xff0c;如果缺乏简单有效治理方案&#xff0c;各服务之间只能通过人肉配置的方式进行服务关系管理&#xff0c;当遇到服务关系变化时&#xff0c;就会变得极其麻烦且容易出错。Consul[1] 是一个用来实现分布式系统服务…

.NET Core + Spring Cloud:API 网关

API 网关是系统的唯一入口&#xff0c;调用任何服务的请求都需要经过网关层&#xff0c;最终才可能到达目标服务&#xff0c;既然是必经之路&#xff0c;那我们可以在网关层进行一些通用的操作&#xff0c;如&#xff1a;认证、鉴权、限流、智能路由、缓存、日志、监控、超时、…

VS Code 黑宝书背后的故事

自开售以来&#xff0c;《Visual Studio Code 权威指南》就受到了许多读者朋友的青睐。在京东和当当两大平台上&#xff0c;都分别取得了不错的绩&#xff1a;当当&#xff1a;计算机新书热卖榜第一名京东&#xff1a;科技IT新书榜第一名那么&#xff0c;热销背后&#xff0c;这…

ASP.net Core MVC项目给js文件添加版本号

需求&#xff1a;使用ASP.net Core Mvc开发公司内部web系统&#xff0c;给视图中js(css,image也可以)文件添加版本号避免缓存问题。解决方法&#xff1a;利用Taghelper提供的标签&#xff08;asp-append-version&#xff09;可以实现<script src"~/Scripts/Biz/Village…

c语言网格搜索,基于C

引言教室作为学生长期使用的建筑类型&#xff0c;对光环境舒适度的需求尤为明显。相关研究表明&#xff0c;不仅照明会影响学习效率[1]&#xff0c;而且不当照明会引起使用者不适甚至损害视力[2]。随着多媒体教学设施的普及&#xff0c;幻灯片投影教学现已成为教师授课的主要形…

初识ABP vNext(1):开篇计划基础知识

点击上方蓝字"小黑在哪里"关注我吧审计(Audit)本地化(Localization)事件总线(Event Bus)多租户(multi-tenancy technology)DDD分层实体(Entity)值对象(Value Object)聚合根(Aggregate Root)仓储(Repository)应用服务(Application Services)数据传输对象(DTO)工作单元…

[开源] .Net ORM FreeSql 1.8.0-preview 最新动态播报

FreeSql 是 .NET 开源生态下的 ORM 轮子&#xff0c;在一些人眼里属于重复造轮子&#xff1a;不看也罢。就像昨天有位朋友截图某培训直播发给我看&#xff0c;内容为&#xff1a;“FreeSQL&#xff08;个人产品&#xff09;&#xff0c;自己玩可以&#xff0c;不要商用。ORM框架…

懂程序员的产品经理是什么样子?

这里是Z哥的个人公众号每周五11&#xff1a;45 按时送达当然了&#xff0c;也会时不时加个餐&#xff5e;我的第「155」篇原创敬上大家好&#xff0c;我是Z哥。在互联网行业&#xff0c;产品经理和程序员之间的关系很微妙。表面看上去水火不容&#xff0c;在一方的眼里看另外一…

初识ABP vNext(2):ABP启动模板

点击上方蓝字"小黑在哪里"关注我吧AbpHelper模块安装前言上一篇介绍了ABP的一些基础知识&#xff0c;本篇继续介绍ABP的启动模板。使用ABP CLI命令就可以得到这个启动模板&#xff0c;其中包含了一些基础功能模块&#xff0c;你可以基于这个模板来快速开发。开始首先…

关于Dapper实现读写分离的个人思考

概念相关为了确保多线上环境数据库的稳定性和可用性&#xff0c;大部分情况下都使用了双机热备的技术。一般是一个主库一个从库或者多个从库的结构&#xff0c;从库的数据来自于主库的同步。在此基础上我们可以通过数据库反向代理工具或者使用程序的方式实现读写分离&#xff0…

135. 分发糖果002(贪心算法+思路+详解)

一&#xff1a;题目 老师想给孩子们分发糖果&#xff0c;有 N 个孩子站成了一条直线&#xff0c;老师会根据每个孩子的表现&#xff0c;预先给他们评分。 你需要按照以下要求&#xff0c;帮助老师给这些孩子分发糖果&#xff1a; 每个孩子至少分配到 1 个糖果。 评分更高的孩…

Enumerable 下又有新的扩展方法啦,快来一睹为快吧

一&#xff1a;背景1. 讲故事前段时间将公司的一个项目从 4.5 升级到了 framework 4.8 &#xff0c;编码的时候发现 Enumerable 中多了三个扩展方法&#xff1a; Append, Prepend, ToHashSet&#xff0c;想必玩过jquery的朋友一眼就能看出这三个方法的用途&#xff0c;这篇就和…

Jdbc创建表 利用循环添加数据 ,更新数据

一&#xff1a;上码 1.有的已经实现的就注释了 2.配置文件信息 package com.wyjedu.jdbc.PreparedStatement;import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet;…

荣耀智慧屏功能曝光 首发华为鸿蒙OS,荣耀智慧屏功能曝光:首发华为鸿蒙OS,全场景智慧体验...

IT之家8月9日消息 今日&#xff0c;华为开发者大会于东莞松山湖正式拉开帷幕。今天下午的焦点毫无疑问是鸿蒙OS与EMUI10。明日下午14:00&#xff0c;华为的另一个重磅产品荣耀智慧屏也将正式发布。7月中旬&#xff0c;荣耀总裁赵明正式宣布了荣耀智慧屏&#xff0c;这也意味着华…

旧 WCF 项目迁移到 asp.net core + gRPC 的尝试

一个月前&#xff0c;公司的运行WCF的windows服务器down掉了&#xff0c;由于 AWS 没有通知&#xff0c;没有能第一时间发现问题。所以&#xff0c;客户提出将WCF服务由C#改为JAVA&#xff0c;在Linux上面运行&#xff1b;一方面&#xff0c;AWS对Linux有较多的监控措施&#x…

黑鲨会升级鸿蒙吗,买华为别乱选!这3款才是“最佳选择”,未来能升级鸿蒙系统...

原标题&#xff1a;买华为别乱选&#xff01;这3款才是“最佳选择”&#xff0c;未来能升级鸿蒙系统众所周知&#xff0c;当下国产手机品牌的进步很快&#xff0c;越来越多品牌的崛起让消费者们十分的纠结。而在国产品牌当中&#xff0c;华为一直都处于“领头羊”大家都知道现在…