在了解HTTP断点续传的原理之前
让我们先来了解一下HTTP协议
HTTP协议是一种基于tcp的简单协议
分为请求和回复两种
请求协议是由客户机(浏览器)向服务器（WEB SERVER）提交请求时发送报文的协议
回复协议是由服务器(web server)
向客户机(浏览器)回复报文时的协议
请求和回复协议都由头和体组成
头和体之间以一行空行为分隔
以下是一个请求报文与相应的回复报文的例子
GET /image/index_r_cjpg HTTP/
Accept: */*
Referer:
AcceptLanguage: zhcn
AcceptEncoding: gzip deflate
UserAgent: Mozilla/ (compatible; MSIE ; Windows NT ; NET CLR )
Host: :
Connection: KeepAlive
HTTP/ OK
Server: MicrosoftIIS/
Date: Tue Jun :: GMT
ContentType: image/jpeg
AcceptRanges: bytes
LastModified: Thu May :: GMT
ETag: becebc:
ContentLength:
…
下面我们就来说说断点续传顾名思义断点续传就是在上一次下载时断开的位置开始继续下载
在HTTP协议中可以在请求报文头中加入Range段来表示客户机希望从何处继续下载
比如说从第字节开始下载请求报文如下
GET /image/index_r
_c
jpg HTTP/
Accept: */*
Referer:
AcceptLanguage: zhcn
AcceptEncoding: gzip deflate
UserAgent: Mozilla/ (compatible; MSIE ; Windows NT ; NET CLR )
Host: :
Range:bytes=
Connection: KeepAlive
NET中的相关类
明白了上面的原理那么我们来看看NET FRAMEWORK中为我们提供了哪些类可以来做这些事
完成HTTP请求
SystemNetHttpWebRequest
HttpWebRequest 类对 WebRequest 中定义的属性和方法提供支持也对使用户能够直接与使用 HTTP 的服务器交互的附加属性和方法提供支持
HttpWebRequest 将发送到 Internet 资源的公共 HTTP 标头值公开为属性由方法或系统设置下表包含完整列表可以将 Headers 属性中的其他标头设置为名称/值对但是注意某些公共标头被视为受限制的它们或者直接由 API公开或者受到系统保护不能被更改Range也属于被保护之列不过NET为开发者提供了更方便的操作就是 AddRange方法向请求添加从请求数据的开始处或结束处的特定范围的字节范围标头
完成文件访问
SystemIOFileStream
FileStream 对象支持使用Seek方法对文件进行随机访问 Seek 允许将读取/写入位置移动到文件中的任意位置这是通过字节偏移参考点参数完成的字节偏移量是相对于查找参考点而言的该参考点可以是基础文件的开始当前位置或结尾分别由SeekOrigin类的三个属性表示
代码实现
了解了NET提供的相关的类那么我们就可以方便的实现了
代码如下
static void Main(string[] args)
{
string StrFileName=c:\\aazip; //根据实际情况设置
string StrUrl=; //根据实际情况设置
//打开上次下载的文件或新建文件
long lStartPos =;
SystemIOFileStream fs;
if (SystemIOFileExists(StrFileName))
{
fs= SystemIOFileOpenWrite(StrFileName);
lStartPos=fsLength;
fsSeek(lStartPosSystemIOSeekOriginCurrent); //移动文件流中的当前指针
}
else
{
fs = new SystemIOFileStream(StrFileNameSystemIOFileModeCreate);
lStartPos =;
}
//打开网络连接
try
{
SystemNetHttpWebRequest request =(SystemNetHttpWebRequest)SystemNetHttpWebRequestCreate(StrUrl);
if ( lStartPos>)
requestAddRange((int)lStartPos); //设置Range值
//向服务器请求获得服务器回应数据流
SystemIOStream ns= requestGetResponse()GetResponseStream();
byte[] nbytes = new byte[];
int nReadSize=;
nReadSize=nsRead(nbytes);
while( nReadSize >)
{
fsWrite(nbytesnReadSize);
nReadSize=nsRead(nbytes);
}
fsClose();
nsClose();
ConsoleWriteLine(下载完成);
}
catch(Exception ex)
{
fsClose();
ConsoleWriteLine(下载过程中出现错误:+exToString());
}
}
