ASP.NET WebAPi之断点续传下载（上）

前言

之前一直感觉断点续传比较神秘，于是想去一探究竟，不知从何入手，以为就写写逻辑就行，结果搜索一番，还得了解相关http协议知识，又花了许久功夫去看http协议中有关断点续传知识，有时候发觉东西只有当你用到再去看相关内容时才会掌握的更加牢固，理解的更加透彻吧，下面我们首先来补补关于http协议中断点续传的知识。

http协议知识恶补

当请求一个html页面时我们会看到请求页面如下：

第一眼看到上面Accept中的参数时我是懵逼的，之前也就看看缓存cookie等常见的头信息，于是借此机会也学习下这部分内容。

我们知道Accept是指客户端允许请求返回的内容类型，那为何这里面参数有如此之多呢？在学习WebAPi时，我们在服务端未进行过滤时既可以返回xml，也可以返回json，此时如上图一样，text/html未匹配上，接着匹配xml类型，匹配后则进行相应格式内容返回，所以客户端接受如此多类型内容，也是为了服务端那边未设置特定内容响应，此时则根据客户端设置的内容进行最合适的匹配。

那么问题来了，上面的q是啥玩意？

q（quality）

上面给出了客户端能够接受响应的内容类型，自然就有最合适的匹配，此时就用到了q这个参数，在此我将q翻译为quality即权重的意思，应该是比较合适的，它用来表示我们期待接受内容偏爱的程度即所占的权重。它的范围是0-1，其默认值为1，这就类似质检部门对产品合格判断的一种介质。例如当我们需要返回视频资源时，我们客户端设置为如下：

Accept: audio/*; q=0.2, audio/basic

此时我们将上述翻译如下：

audio/basic; q=1
audio/*; q=0.2

我们更加期待返回的是audio/basic类型的资源，因为其权重为1大于audio/*类型的资源，若为匹配到则继续匹配下一个资源，audio/*则表示属于audio类型的所有子类型资源。

接下来，我们再来看一个例子：

Accept: text/plain; q=0.5, text/html,text/x-dvi; q=0.8, text/x-c

此时我们则可以翻译为如下：

Accept: 
text/html;q=1或者 text/x-c;q=1
text/x-dvi; q=0.8
text/plain; q=0.5

倾向于返回text/html或者text/x-c类型资源，若都不存在，则返回权重为0.8的text/x-dvi，最终还是不存在则返回text/plain。

Accept-Ranges

在响应头中添加此字段允许服务端来显示表明对资源范围的接受。如果服务端接受一个字节范围的资源的请求则此时变成如下：

Accept-Ranges: bytes

如果服务端不接受任何范围的请求资源此时则在响应头添加如下来告诉客户端不要发送范围请求的资源：

Accept-Ranges: none

Content-Range

当在响应头中添加接受字节范围的资源时，此时若客户端请求资源文件比较大时即只是返回部分数据时，此时则返回状态码为206的部分内容，在Content-Range响应头信息中实时显示当前数据的进度。比如如下：

//开始500个字节数据
Content-Range: bytes 0-499/1234//第二个500个字节数据
Content-Range: bytes 500-999/1234//除了开始500个字节之外的数据
Content-Range: bytes 500-1233/1234//最后500个字节数据（表示数据最终传输完毕）
Content-Range: bytes 734-1233/1234

如果客户端请求资源到达所给资源的界限此时则返回416的状态码。

注意：当请求资源为字节范围请求时，不要在响应头中使用 multipart/byteranges 类型的content-type。 

断点续传场景

当正在下载时出于其他任何原因此时下载中断，那么下载用户只能重新下载，这样的体验想必是比较痛苦的，最烦躁的是如果用户是在移动端下载大文件时，居然下载中断了，接下来又得重新下载，此时想必用户会放弃下载。此时断点续传则应运而生。 断点续传则需要用到上述Accept-Ranges和Content-Range将其添加到响应头中。例如如下：

HEAD http://localhost/api/files/get?filename=blog_backup.zip 
User-Agent: IIS
Host: localhostHTTP/1.1 200 OK  
Content-Length: 1182367743  
Content-Type: application/octet-stream  
Accept-Ranges: bytes  
Server: Microsoft-IIS/10.0  
Content-Disposition: attachment; filename=blog_backup.zip
HEAD http://localhost/api/files/get?filename=blog_backup.zip   
User-Agent: IIS
Host: localhost  
Range: bytes=0-999HTTP/1.1 206 Partial Content  
Content-Length: 1000  
Content-Type: application/octet-stream  
Content-Range: bytes 0-999/1182367743  
Accept-Ranges: bytes  
Server: Microsoft-IIS/10.0  
Content-Disposition: attachment; filename=blog_backup.zip

接下来我们来实现简单的下载以及断点续传下载对比看看效果。 

在webapi中提供了一系列方便我们调用的api，比如 ContentDispositionHeaderValue 来设置附件而不像在webform中手动在响应头中进行拼接。以及返回的MimeType类型 MediaTypeHeaderValue 。首先我们看看最普通的下载。

普通下载

普通的下载无非就是获取到文件的标识再打开下载的文件夹，最后得到文件流返回到响应的HttpContent对象中以及设置附件即可。我们看看如下代码还是比较简单的，这种相对比较简单的下载想必我们大家定是信手拈来。

        //响应的MimeType类型private const string MimeType = "application/octet-stream";//配置文件中配置的文件所在路径private const string AppSettingDirPath = "DownloadDir";//将配置文件中取得的路径赋给此变量private readonly string DirFilePath;this.DirFilePath = ConfigurationManager.AppSettings[AppSettingDirPath];

接下来就是最重要的下载逻辑了，如下：

        public HttpResponseMessage Download(string fileName){var fullFilePath = Path.Combine(this.DirFilePath, fileName);if (!File.Exists(fullFilePath)){throw new HttpResponseException(HttpStatusCode.NotFound);}FileStream fileStream = File.Open(fullFilePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);var response = new HttpResponseMessage();response.Content = new StreamContent(fileStream);response.Content.Headers.ContentDisposition= new ContentDispositionHeaderValue("attachment") { FileName = fileName };response.Content.Headers.ContentType= new MediaTypeHeaderValue(MimeType);response.Content.Headers.ContentLength= fileStream.Length;return response;}

那么问题来了，我们可不可以在获取文件流返回到HttpContent之前是不是应该首先将文件流放入到缓冲流中然后再返回呢？如下：

 var bufferStream = new BufferedStream(fileStream);response.Content = new StreamContent(bufferStream);

我们想着是不是将文件流率先放入到缓冲流中效果是否更佳呢？刚开始我也是这样想来着，但是经过查证资料发现:

为了得到更好的性能，在文件流中已经包含有缓冲流的缓冲逻辑，对于用缓冲流来包裹文件流的情况没有任何好处，还有一点就是在.NET Framework中没有任何一个流需要用到缓冲流，但是，但是有一种情况除外则是若我们自定义实现流且默认没有实现缓冲的逻辑情况下需要用到缓冲流，资料来源于：Filestream and BufferedStream

上述也算是涨知识了。继续回到我们的话题，此时我们下载一个文件则看到如下图所示：

 

因为未实现断点续传，此时我们通过右键可以看到无法暂停，如下：

我们继续往下走，接下来来实现断点续传看看：

断点续传下载

在WebAPi提供了Range属性其返回对象为 RangeHeaderValue 里面有存在每个范围的集合如下：

        // 摘要: //     Gets the ranges specified from the System.Net.Http.Headers.RangeHeaderValue//     object.//// 返回结果: //     Returns System.Collections.Generic.ICollection<T>.The ranges from the System.Net.Http.Headers.RangeHeaderValue//     object.public ICollection<RangeItemHeaderValue> Ranges { get; }

这是为利用多线程下载而提供，这里我们仅仅实现一个范围的下载。我们通过判断这个对象的值是否为null来实现断点续传。

            if (Request.Headers.Range == null || Request.Headers.Range.Ranges.Count == 0 || Request.Headers.Range.Ranges.FirstOrDefault().From.Value == 0){var sourceStream = File.Open(fullFilePath, FileMode.Open, FileAccess.Read, FileShare.Read);response = new HttpResponseMessage(HttpStatusCode.OK);response.Content = new StreamContent(sourceStream);response.Headers.AcceptRanges.Add("bytes");//告诉客户端接受资源为字节response.Content.Headers.ContentLength = sourceStream.Length;response.Content.Headers.ContentType = new MediaTypeHeaderValue(MimeType);response.Content.Headers.ContentDisposition = new ContentDispositionHeaderValue("attachment"){FileName = fileName};}

获取当前已经下载字节数，接着继续进行剩下字节下载。

            else{var item = Request.Headers.Range.Ranges.FirstOrDefault();if (item != null && item.From.HasValue){response = this.GetPartialContent(fileName, item.From.Value);}}

剩余字节数下载

        private HttpResponseMessage GetPartialContent(string fileName, long partial){var response = new HttpResponseMessage();var fullFilePath = Path.Combine(this.DirFilePath, fileName);FileInfo fileInfo = new FileInfo(fullFilePath);long startByte = partial;var memoryStream = new MemoryStream();var buffer = new byte[65536];using (var fileStream = File.Open(fullFilePath, FileMode.Open, FileAccess.Read, FileShare.Read)){var bytesRead = 0;fileStream.Seek(startByte, SeekOrigin.Begin);int length = Convert.ToInt32((fileInfo.Length - 1) - startByte) + 1;while (length > 0 && bytesRead > 0){bytesRead = fileStream.Read(buffer, 0, Math.Min(length, buffer.Length));memoryStream.Write(buffer, 0, bytesRead);length -= bytesRead;}response.Content = new StreamContent(memoryStream); }response.Headers.AcceptRanges.Add("bytes");response.StatusCode = HttpStatusCode.PartialContent;response.Content.Headers.ContentType = new MediaTypeHeaderValue(MimeType);response.Content.Headers.ContentLength = File.Open(fullFilePath, FileMode.Open, FileAccess.Read, FileShare.Read).Length;response.Content.Headers.ContentDisposition = new ContentDispositionHeaderValue("attachment"){FileName = fileName};return response;}

接下来我们看看演示结果：

从上面演示我们看出目前已经实现了断点续传，浏览器下载管理器出现了暂停的按钮，但是当暂停后无法继续进行后续下载，在这里存在问题，我们下节再进行后续讲解。同时当返回HttpContent发现居然还有一个可以返回的HttpContent即 PushStreamContent ，此时我们可以将剩余部分字节下载进行如下修改：

            Action<Stream, HttpContent, TransportContext> pushContentAction = (outputStream, content, context) =>{try{var buffer = new byte[65536];using (var fileStream = File.Open(fullFilePath, FileMode.Open, FileAccess.Read, FileShare.Read)){var bytesRead = 0;fileStream.Seek(startByte, SeekOrigin.Begin);int length = Convert.ToInt32((fileInfo.Length - 1) - startByte) + 1;while (length > 0 && bytesRead > 0){bytesRead = fileStream.Read(buffer, 0, Math.Min(length, buffer.Length));outputStream.Write(buffer, 0, bytesRead);length -= bytesRead;}}}catch (HttpException ex){throw ex;}finally{outputStream.Close();}};  response.Content = new PushStreamContent(pushContentAction, new MediaTypeHeaderValue(MimeType));response.StatusCode = HttpStatusCode.PartialContent;response.Headers.AcceptRanges.Add("bytes");response.Content.Headers.ContentType = new MediaTypeHeaderValue(MimeType);response.Content.Headers.ContentLength = File.Open(fullFilePath, FileMode.Open, FileAccess.Read, FileShare.Read).Length;response.Content.Headers.ContentDisposition = new ContentDispositionHeaderValue("attachment"){FileName = fileName};return response;

如上所做也可行，返回StreamContent不就ok了吗，为何还出现一个PushStreamContent呢？这又是一个遗留问题！

总结

本节我们讲述了在webapi中普通下载以及断点续传下载，对于断点续传下载当暂停后无法继续进行下载，暂时还存在一定问题，对于返回的内容既可以为StreamContent，也可以是PushStreamContent，这二者有何区别呢？二者的应用场景是什么呢？这又是一个问题，关于此二者我们下节再讲，webapi一个很轻量的服务框架，你值得拥有，see u。

转载于:https://www.cnblogs.com/CreateMyself/p/6063646.html

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

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

相关文章

贪吃蛇（C++实现，VC6.0编译，使用了EasyX图形库）

贪吃蛇（C++实现，VC6.0编译，使用了EasyX图形库）

程序效果&#xff1a; 代码&#xff1a; //main.cpp 1 #include <iostream>2 #include<fstream>3 #include <graphics.h>4 #include <conio.h>5 #include<ctime>6 #include<windows.h>7 #include<mmsystem.h>8 #pragma comment(lib…
阅读更多...
3.0 C++远征：is a

3.0 C++远征：is a

4-4is_a 0.派生类Soldier继承自基类Person //Person.h class Person { public:Person(string name "Jim");~Person();void play(); protected:string m_strName; };//Soldier.h class Soldier : public Person { public:Soldier(string name "James", in…
阅读更多...
python中sorted的用法append_python sorted()排序详解

python中sorted的用法append_python sorted()排序详解

排序&#xff0c;在编程中经常遇到的算法&#xff0c;我也在几篇文章中介绍了一些关于排序的算法。有的高级语言内置了一些排序函数。本文讲述Python在这方面的工作。供使用内置函数sorted()/list.sort()的使用简单应用python对list有一个内置函数&#xff1a;>>> a[5…
阅读更多...
云上的播放框架变得简单：Openshift模块

云上的播放框架变得简单：Openshift模块

仅仅几年前&#xff0c;找到一个负担得起的Java Web应用程序托管解决方案是一项艰巨的任务&#xff0c;而寻找免费的托管解决方案是一项不可能的任务。 更不用说甚至考虑自动缩放&#xff0c;单命令部署&#xff0c;持续集成等事情&#xff0c;这都是科幻小说。 去年见证了云计…
阅读更多...
C#中的yield return与Unity中的Coroutine（协程）（下）

C#中的yield return与Unity中的Coroutine（协程）（下）

Unity中的Coroutine&#xff08;协程&#xff09; 估计熟悉Unity的人看过或者用过StartCoroutine() 假设我们在场景中有一个UGUI组件&#xff0c; Image&#xff1a; 将以下代码绑定到Image 1 using UnityEngine;2 using System.Collections;3 using System.Threading;4 using …
阅读更多...
字节流转化为文件流_C#文件转换为字节流及字节流转换为文件

字节流转化为文件流_C#文件转换为字节流及字节流转换为文件

本文讲解了C#实现文件转换为字节流的方法。文件转换为字节流的步骤如下1、通过文件流打开指定文件(FileStream fs)&#xff1b;2、定义字节流(byte[] fileBytenew byte[fs.Length])&#xff1b;3、把文件读取到字节流(fs.Read(fileByte,0,fileByte.Length))&#xff1b;4、关闭…
阅读更多...
Spring和JSF集成：导航

Spring和JSF集成：导航

我希望这是有关我在Spring和JavaServer Faces之间提供深度集成的努力的一系列博客中的第一篇。 这里提到的所有内容都是“正在进行中的工作”&#xff0c;因此&#xff0c;如果您签出代码&#xff0c;请注意它是一个不断变化的目标。 期待一些粗糙的边缘&#xff0c;如果有时会…
阅读更多...
【CSS3动画】transform对文字及图片的旋转、缩放、倾斜和移动

【CSS3动画】transform对文字及图片的旋转、缩放、倾斜和移动

前言&#xff1a;之前我有写过CSS3的transform这一这特性&#xff0c;对于它的用法&#xff0c;还不是很透彻&#xff0c;今天补充补充&#xff0c;呵呵 你懂的&#xff0c;小司机准备开车了。 a)再提一提transform的四个属性 ①旋转--->rotate(参数a)&#xff0c;单位deg&a…
阅读更多...
宏的用法与简介

宏的用法与简介

预处理指令&#xff1a;例如&#xff1a;#include<stdio.h> #include<stdlib.h> #define MAX 20 ............. 因为他们由预处理器解释的&#xff0c;所以称作预处理指令。预处理器读取源代码&#xff0c;然后对其修改&#xff0c;并把修改过的…
阅读更多...
django 日志写入mysql_如何将django orm模型 写入数据库

django 日志写入mysql_如何将django orm模型 写入数据库

1、指定连接pymysql(python3.x)先配置_init_.pyimport pymysqlpymysql.install_as_MySQLdb()2、配置连接mysql文件信息settings.pyDATABASES {default: {ENGINE: django.db.backends.mysql,NAME: django_orm, #你的数据库名称USER: root, #你的数据库用户名PASSWORD: , #你的数…
阅读更多...
ORM的问题第2部分–查询

ORM的问题第2部分–查询

在我以前关于对象关系映射工具&#xff08;ORM&#xff09;的帖子中&#xff0c;我讨论了在处理当今常见的ORM&#xff08;包括Hibernate&#xff09;时遇到的各种问题。 其中包括与从POJO生成架构有关的问题&#xff0c;实际性能和不断出现的维护问题。 本质上&#xff0c;结论…
阅读更多...
【转】如何减少接口响应时间

【转】如何减少接口响应时间

Premature optimization is the root of all evil. — Donald Knuth 对于程序优化&#xff0c;我一直采取保守的态度&#xff0c;除非万不得已。但是随着业务的不断发展&#xff0c;程序越来越复杂&#xff0c;代码越写越多&#xff0c;优化似乎是终有一天会到来的事情。 那么对…
阅读更多...
数据库行转列在现实需求中的用法

数据库行转列在现实需求中的用法

select t.客户姓名,sum(case when t.收款类型首款 then t.金额 else 0 end as 首款),sum(case when t.收款类型尾款 then t.金额 else 0 end as 尾款) from table t group by t.客户姓名 这段sql的意思 是 查询出所有客户收款信息 然后按客户分组 分组后 然后将这个客户的所…
阅读更多...
mysql生产环境加索引_【生产篇】_MySQL环境下如何查看基于表的索引定义

mysql生产环境加索引_【生产篇】_MySQL环境下如何查看基于表的索引定义

【引言】今天中午项目组来一需求&#xff0c;欲在MySQL环境的某张表下创建几个BTREE索引。要创建索引&#xff0c;首先需要了解基表的表结构&#xff0c;以及已经包含的索引。Oracle的表结构大家都很熟悉&#xff0c;但MySQL表结构和已创建索引的查看怎么操作&#xff0c;本文将…
阅读更多...
Hadoop模式介绍-独立，伪分布式，分布式

Hadoop模式介绍-独立，伪分布式，分布式

了解了什么是Hadoop之后&#xff0c;让我们在单机上启动Hadoop&#xff1a; 这篇文章包含在ubuntu上安装Hadoop的说明。 这是Hadoop安装的快速分步教程。 在这里&#xff0c;您将获得以独立模式 &#xff08;单节点集群&#xff09;安装Hadoop所需的所有命令及其说明&#xff0…
阅读更多...
apk反编译方式

apk反编译方式

一、Apk反编译得到Java源代码 下载上述反编译工具包&#xff0c;打开apk2java目录下的dex2jar-0.0.9.9文件夹&#xff0c;内含apk反编译成java源码工具&#xff0c;以及源码查看工具。 apk反编译工具dex2jar&#xff0c;是将apk中的classes.dex转化成jar文件 源码查看工具jdgui…
阅读更多...
优化Hibernate所鼓励的7大措施

优化Hibernate所鼓励的7大措施

优化Hibernate所鼓励的7大措施&#xff1a; 1.尽量使用many-to-one&#xff0c;避免使用单项one-to-many2.灵活使用单向one-to-many3.不用一对一&#xff0c;使用多对一代替一对一4.配置对象缓存&#xff0c;不使用集合缓存5.一对多使用Bag 多对一使用Set6.继承使用显示多态 HQ…
阅读更多...
如何用c 控制mysql数据库_用C语言操作MySQL数据库

如何用c 控制mysql数据库_用C语言操作MySQL数据库

函数描述mysql_affected_rows()返回上次UPDATE、DELETE或INSERT查询更改&#xff0f;删除&#xff0f;插入的行数。mysql_autocommit()切换autocommit模式&#xff0c;ON/OFFmysql_change_user()更改打开连接上的用户和数据库。mysql_charset_name()返回用于连接的默认字符集的…
阅读更多...
数据结构(RMQ)：POJ 3624 Balanced Lineup

数据结构(RMQ)：POJ 3624 Balanced Lineup

Balanced LineupDescription For the daily milking, Farmer Johns N cows (1 ≤ N ≤ 50,000) always line up in the same order. One day Farmer John decides to organize a game of Ultimate Frisbee with some of the cows. To keep things simple, he will take a conti…
阅读更多...
Apache Thrift快速入门教程

Apache Thrift快速入门教程

Thrift是一种跨语言RPC框架&#xff0c;最初是在Facebook上开发的&#xff0c;现在作为Apache项目开源。 这篇文章将描述如何以不同的模式&#xff08;例如阻塞&#xff0c;非阻塞和异步&#xff09;编写Thrift服务和客户端。 &#xff08;我觉得后两种模式的文档较少&#xff…
阅读更多...
最新文章

Copyright @ 2022~2023