DELPHI如何实现下载的断点续传功能(119分)

nccxl · 2006-03-21

本人刚接触，手头资料比较少，请知道的朋友给点帮助。 具体的实现代码到不重要，有个思路或者该了解的知识面的方向就可以。

waterspace · 2006-03-21

你用的什么控件来下载？

nccxl · 2006-03-21

我比较菜，什么控件都没用，只是想了解这方面的知识。想自己做这个功能。

waterspace · 2006-03-21

这个一时不好说，下载也分好多种协议的。建议了解一下协议

nccxl · 2006-03-21

一般的下载吧，走HTTP的协议就行。主要是现在也不大清楚该看哪方面的资料。

waterspace · 2006-03-21

可以先看关于WinSock和HTTP协议的资料。其实实现起来比较简单。也就是发包，收包，存文件。断点续传就是Range改个值就行了。如果不想做比较复杂的，可以直接用IdHTTP控件，GET一下就下下来了。不过这个控件我现在还没用好。

iamy · 2006-03-21

参考下这些代码 http://www.2ccc.com/article.asp?articleid=775 http://www.2ccc.com/article.asp?articleid=680

网中戏 · 2006-03-21

断点续传就是把断点做为参数。再次传递时从该点开始传递

nccxl · 2006-03-22

有没有推荐看的书呢？或者是有哪些资料文档可以看看，大家推荐一下吧。

余远源 · 2006-03-23

unit Unit1; interface uses  {}filectrl,inifiles,{}Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,  Dialogs, StdCtrls, ScktComp, ExtCtrls; type  Tbuf_char=array[0..4095] of char;  Tbuf_byte=array[0..4095] of byte; type  TForm1 = class(TForm)    ClientSocket1: TClientSocket;    Memo1: TMemo;    Panel1: TPanel;    Edit1: TEdit;    Button1: TButton;    Edit2: TEdit;    Button3: TButton;    Button4: TButton;    Label2: TLabel;    Label3: TLabel;    Label1: TLabel;    procedure ClientSocket1Read(Sender: TObject; Socket: TCustomWinSocket);    procedure Button1Click(Sender: TObject);    procedure ClientSocket1Connect(Sender: TObject;      Socket: TCustomWinSocket);    procedure Edit1Change(Sender: TObject);    procedure FormCreate(Sender: TObject);    procedure Edit2Change(Sender: TObject);    procedure Button3Click(Sender: TObject);    procedure Button4Click(Sender: TObject);  private    { Private declarations }  public    { Public declarations }    filename1:string; //本地文件名    serfilename:string;  //服务器端文件名    serhost1:string;  //服务器地址    can_rec1:boolean; //是否可以接收    stop1:boolean; //是否停止  end; var  Form1: TForm1;  pos1:longint; //上次下载到的位置 implementation {$R *.dfm} function app_path1:string; begin  result:=extractfilepath(application.ExeName); end; //接收一行数据//socket,超时，结束符 function socket_rec_line1(socket1:TCustomWinSocket;timeout1:integer;crlf1:string=#13#10):string; var  buf1:Tbuf_char;  r1:integer;  ts1:TStringStream; //保存所有的数据  FSocketStream: TWinSocketStream; begin  ts1:=TStringStream.Create('');  FSocketStream:= TWinSocketStream.create(Socket1, timeout1);  //while true do//下面的一句更安全,不过对本程序好象没起作用  while (socket1.Connected=true) do  begin    //确定是否可以接收数据    //只能确定接收的超时，可见WaitForData的源码    if not FSocketStream.WaitForData(timeout1) then break; //continue;    //这一句是一定要有的，以免返回的数据不正确    zeromemory(@buf1,sizeof(buf1));    r1 := FsocketStream.Read(buf1, 1); //每次只读一个字符，以免读入了命令外的数据    //读不出数据时也要跳出，要不会死循环    if r1=0 then break; //test    //用FsocketStream.Read能设置超时    //r1:=socket1.ReceiveBuf(buf1,sizeof(buf1));    ts1.Write(buf1,r1);    //读到回车换行符了    if pos(crlf1,ts1.DataString)<>0 then    begin      break;    end;  end;  result:=ts1.DataString;  //没有读到回车换行符,就表示有超时错，这时返回空字符串  if pos(crlf1,result)=0 then  begin    result:='';  end;  ts1.Free;  FSocketStream.Free; end;  function get_host1(in1:string):string;  begin    in1:=trim(in1);    if pos('http://',lowercase(in1))=1 then    begin      in1:=copy(in1,length('http://')+1,length(in1));    end;    if pos('/',in1)<>0 then    begin      in1:=copy(in1,0,pos('/',in1)-1);    end;      result:=in1;  end;  function get_file1(in1:string):string;  begin    in1:=trim(in1);    if pos('http://',lowercase(in1))=1 then    begin      in1:=copy(in1,length('http://')+1,length(in1));    end;    if pos('/',in1)<>0 then    begin      in1:=copy(in1,pos('/',in1)+1,length(in1));    end;      result:=in1;  end; procedure TForm1.ClientSocket1Read(Sender: TObject;  Socket: TCustomWinSocket); begin  memo1.Lines.Add(socket.ReceiveText); end; procedure TForm1.Button1Click(Sender: TObject); var  url1:string;  buf1:Tbuf_byte;  rec1:longint;  f1:file;  cmd1:string; //这一行的内容  reclen1,real_reclen1:longint; //服务器返回的长度;实际已经收到的长度  value1:string; //标志们的值  total_len1:longint; //数据总长 begin  try    //self.filename1:='c:/temp1.dat';    assignfile(f1,self.filename1);    can_rec1:=false;    self.stop1:=false;    if FileExists(self.filename1)=true then    begin      reset(f1,1);      pos1:=filesize(f1);    end    else    begin      rewrite(f1,1);      pos1:=0;    end;    seek(f1,pos1);    ClientSocket1.Active:=false;    ClientSocket1.Host:=get_host1(edit1.Text);    ClientSocket1.Port:=80;    url1:='';    self.serfilename:=get_file1(edit1.Text);    self.serhost1:=get_host1(edit1.Text);    //取得文件长度以确定什么时候结束接收[通过"head"请求得到]    ClientSocket1.Active:=false;    ClientSocket1.Active:=true;    url1:='';        url1:=url1+'HEAD /'+self.serfilename+' HTTP/1.1'+#13#10;    //不使用缓存,我附加的    //与以前的服务器兼容    url1:=url1+'Pragma: no-cache'+#13#10;    //新的    url1:=url1+'Cache-Control: no-cache'+#13#10;    //不使用缓存,我附加的_end;    url1:=url1+'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; .NET CLR 1.0.3705)'+#13#10;    //下面这句必须要有    //url1:=url1+'Host: clq.51.net'+#13#10;    url1:=url1+'Host: '+self.serhost1+#13#10;    url1:=url1+#13#10;        ClientSocket1.Socket.SendText(url1);    while ClientSocket1.Active=true do    begin      if self.stop1=true then break;      cmd1:=socket_rec_line1(ClientSocket1.Socket,60*1000);      //计算文件的长度      if pos(lowercase('Content-Length: '),lowercase(cmd1))=1 then      begin        value1:=copy(cmd1,length('Content-Length: ')+1,length(cmd1));        total_len1:=strtoint(trim(value1));      end;      //计算文件的长度_end;      if cmd1=#13#10 then break;    end;      //取得文件长度以确定什么时候结束接收_end;    //发送get请求，以得到实际的文件数据    clientsocket1.Active:=false;    clientsocket1.Active:=true;    url1:='';    //url1:=url1+'GET http://clq.51.net/textfile.zip HTTP/1.1'+#13#10;    //url1:=url1+'GET /textfile.zip HTTP/1.1'+#13#10;    url1:=url1+'GET /'+self.serfilename+' HTTP/1.1'+#13#10;    url1:=url1+'Accept: image/gif, image/x-xbitmap, image/jpeg, image/pjpeg, */*'+#13#10;    //应该可以不要url1:=url1+'Accept-Language: zh-cn'+#13#10;    //应该可以不要url1:=url1+'Accept-Encoding: gzip, deflate'+#13#10;    //不使用缓存,我附加的    //与以前的服务器兼容    //url1:=url1+'Pragma: no-cache'+#13#10;    //新的    //url1:=url1+'Cache-Control: no-cache'+#13#10;    //不使用缓存,我附加的_end;    url1:=url1+'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; .NET CLR 1.0.3705)'+#13#10;    //接受数据的范围,可选    //url1:=url1+'RANGE: bytes=533200-'+#13#10;    url1:=url1+'RANGE: bytes='+inttostr(pos1)+'-'+#13#10;    //下面这句必须要有    //url1:=url1+'Host: clq.51.net'+#13#10;    url1:=url1+'Host: '+self.serhost1+#13#10;    //应该可以不要    //url1:=url1+'Connection: Keep-Alive'+#13#10;    url1:=url1+#13#10;    ClientSocket1.Socket.SendText(url1);    while ClientSocket1.Active=true do    begin      if self.stop1=true then break;      cmd1:=socket_rec_line1(ClientSocket1.Socket,60*1000);      //是否可接收      if pos(lowercase('Content-Range:'),lowercase(cmd1))=1 then      begin        can_rec1:=true;      end;      //是否可接收_end;      //计算要接收的长度            if pos(lowercase('Content-Length: '),lowercase(cmd1))=1 then      begin        value1:=copy(cmd1,length('Content-Length: ')+1,length(cmd1));        reclen1:=strtoint(trim(value1));      end;      //计算要接收的长度_end;      //头信息收完了      if cmd1=#13#10 then break;    end;    real_reclen1:=0;    while ClientSocket1.Active=true do    begin      if self.stop1=true then break;      //不能接收则退出      if can_rec1=false then break;      //如果文件当前的长度大于服务器标识的长度,则是出错了，不要写入文件中      if filesize(f1)>=total_len1 then      begin        showmessage('文件已经下载完毕了！');        break;      end;      zeromemory(@buf1,sizeof(buf1));      rec1:=ClientSocket1.Socket.ReceiveBuf(buf1,sizeof(buf1));      //如果实际收到的长度大于服务器标识的长度,则是出错了，不要写入文件中      if real_reclen1>=reclen1 then      begin        showmessage('文件已经下载完毕了！');        break;      end;      //如果当前的长度大于服务器标识的长度,则是出错了，不要写入文件中      if pos1=reclen1 then      begin        showmessage('文件已经下载完毕了！');        break;      end;      blockwrite(f1,buf1,rec1);      real_reclen1:=real_reclen1+rec1;      Label1.Caption:=FormatFloat('#,##',real_reclen1)+'/'+FormatFloat('#,##',reclen1);      Label1.Caption:=Label1.Caption+'->'+inttostr(trunc((real_reclen1/reclen1)*100))+'%';      application.ProcessMessages;    end;    closefile(f1);    showmessage('ok');    //发送get请求，以得到实际的文件数据_end;    ClientSocket1.Active:=false;      except    closefile(f1);    showmessage('discon...');  end; end; procedure TForm1.ClientSocket1Connect(Sender: TObject;  Socket: TCustomWinSocket); var  url1:string;   begin {  url1:='';  url1:=url1+'GET http://clq.51.net/textfile.zip HTTP/1.1'+#13#10;  url1:=url1+'Accept: image/gif, image/x-xbitmap, image/jpeg, image/pjpeg, */*'+#13#10;  //应该可以不要url1:=url1+'Accept-Language: zh-cn'+#13#10;  //应该可以不要url1:=url1+'Accept-Encoding: gzip, deflate'+#13#10;  //不使用缓存,我附加的  //与以前的服务器兼容  url1:=url1+'Pragma: no-cache'+#13#10;  //新的  url1:=url1+'Cache-Control: no-cache'+#13#10;  //不使用缓存,我附加的_end;  url1:=url1+'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; .NET CLR 1.0.3705)'+#13#10;  //接受数据的范围,可选  url1:=url1+'RANGE: bytes=533200-'+#13#10;  //下面这句必须要有  url1:=url1+'Host: clq.51.net'+#13#10;  url1:=url1+'Connection: Keep-Alive'+#13#10;  url1:=url1+#13#10;  ClientSocket1.Socket.SendText(url1); } end; procedure TForm1.Edit1Change(Sender: TObject); var  ini1:tinifile; begin  ini1:=tinifile.Create(app_path1+'sys1.ini');  ini1.WriteString('file1','host1',edit1.Text);  ini1.Free; end; procedure TForm1.FormCreate(Sender: TObject); var  ini1:tinifile; begin  ini1:=tinifile.Create(app_path1+'sys1.ini');  edit1.Text:=ini1.ReadString('file1','host1',edit1.Text);  self.filename1:=ini1.ReadString('file1','filename1','c:/temp1.dat');  edit2.Text:=self.filename1;  //pos1:=filesize(  ini1.Free; end; procedure TForm1.Edit2Change(Sender: TObject); var  ini1:tinifile; begin  ini1:=tinifile.Create(app_path1+'sys1.ini');  ini1.WriteString('file1','filename1',edit2.Text);  self.filename1:=edit2.Text;  ini1.Free; end; procedure TForm1.Button3Click(Sender: TObject); var  url1:string;  buf1:Tbuf_byte;  rec1:longint;  f1:file;  cmd1:string; //这一行的内容  reclen1,real_reclen1:longint; //服务器返回的长度;实际已经收到的长度  value1:string; //标志们的值 begin    self.stop1:=false;    ClientSocket1.Active:=false;    ClientSocket1.Host:=get_host1(edit1.Text);    ClientSocket1.Port:=80;    ClientSocket1.Active:=true;    url1:='';    self.serfilename:=get_file1(edit1.Text);    self.serhost1:=get_host1(edit1.Text);    //url1:=url1+'GET http://clq.51.net/textfile.zip HTTP/1.1'+#13#10;    //url1:=url1+'GET /textfile.zip HTTP/1.1'+#13#10;    url1:=url1+'GET /'+self.serfilename+' HTTP/1.1'+#13#10;    //url1:=url1+'HEAD /'+self.serfilename+' HTTP/1.1'+#13#10;    url1:=url1+'Accept: image/gif, image/x-xbitmap, image/jpeg, image/pjpeg, */*'+#13#10;    //应该可以不要    //url1:=url1+'Accept-Language: zh-cn'+#13#10;    //应该可以不要    //url1:=url1+'Accept-Encoding: gzip, deflate'+#13#10;    //不使用缓存,我附加的    //与以前的服务器兼容    //url1:=url1+'Pragma: no-cache'+#13#10;    //新的    //url1:=url1+'Cache-Control: no-cache'+#13#10;    //不使用缓存,我附加的_end;    url1:=url1+'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; .NET CLR 1.0.3705)'+#13#10;    //接受数据的范围,可选    //url1:=url1+'RANGE: bytes=533200-'+#13#10;    url1:=url1+'RANGE: bytes='+inttostr(533263)+'-533263'+#13#10;    //下面这句必须要有    //url1:=url1+'Host: clq.51.net'+#13#10;    url1:=url1+'Host: '+self.serhost1+#13#10;    //应该可以不要    //url1:=url1+'Connection: Keep-Alive'+#13#10;    url1:=url1+#13#10;    ClientSocket1.Socket.SendText(url1);    //while  ClientSocket1.Active=true do    begin      zeromemory(@buf1,sizeof(buf1));      rec1:=ClientSocket1.Socket.ReceiveBuf(buf1,sizeof(buf1));      real_reclen1:=real_reclen1+rec1;      memo1.Lines.Add(strpas(@buf1));      application.ProcessMessages;      //if self.stop1=true then break;    end;    ClientSocket1.Active:=false;    showmessage('ok'); end; procedure TForm1.Button4Click(Sender: TObject); begin  self.stop1:=true; end; end.

nccxl · 2006-03-28

我用 IdHTTP1.Response.RawHeaders.Values['Content-Length']; IdHTTP1.Request.CustomHeaders.Clear; IdHTTP1.Request.CustomHeaders.Add('Range: bytes=0-'+IntToStr(mBuffer)+#13#10); IdHTTP1.Get(FileURL,mStream); 方法取，好象最后一次的mStream的内容很奇怪，很大。 为什么啊？

waterspace · 2006-03-28

什么叫最后一次？你一共用了几次啊？都是从0开始？

nccxl · 2006-03-28

我设置了一个BUFFER，每次请求BUFFER长度的内容。前面都是正常的。就是最后一次，或者最后一两次不正常。不明白什么原因。

waterspace · 2006-03-28

把代码贴出来看看吧，按理说不会有这种问题的

nccxl · 2006-03-28

function TFDownLoadEasy.GetFileBody(FileURL: string): Boolean; var  mStream:TFileStream;  mCount:int64;  mFileSize:int64;  mDownLoadSize:int64;  mBuffer:integer;  I:integer; begin  mBuffer:=1024*BlockSize;  mFileSize:=GetFileSize(FileUrl);      mCount:=mFileSize div mBuffer;  if mCount*mBuffer < mFileSize then mCount:=mCount+1;    ProgressBar1.Position:=0;  ProgressBar1.Min:=0;  ProgressBar1.Max:=mCount;  FileName:= GetLastName(FileURL,'/');  try    try      mDownLoadSize:=0;      FDownLoadEasy.ListBox2.Items.Add('一共要循环：'+IntToStr(mCount));      //下载      IdHTTP1.Response.RawHeaders.Values['Content-Length'];      for I := 1 to mCount do      begin        IdHTTP1.Request.CustomHeaders.Clear;  //清除        if I=1 then        begin          mStream:=TFileStream.Create(FileName,fmCreate);          IdHTTP1.Request.CustomHeaders.Add('Range: bytes=0-'+IntToStr(mBuffer)+#13#10);        end        else if I<mCount then begin          mStream:=TFileStream.Create(FileName,fmOpenWrite);          IdHTTP1.Request.CustomHeaders.Add('Range: bytes='+IntToStr(I*mBuffer+1)+'-'+IntToStr((I+1)*mBuffer)+#13#10);        end        else begin          mStream:=TFileStream.Create(FileName,fmOpenWrite);          IdHTTP1.Request.CustomHeaders.Add('Range: bytes='+IntToStr(I*mBuffer+1)+'-'+IntToStr(mFileSize)+#13#10);        end;        IdHTTP1.Get(FileURL,mStream);        mDownLoadSize:=mDownLoadSize+mStream.Size;        FDownLoadEasy.ListBox1.Items.Add('第'+IntToStr(I)+'次循环，下载文件长度：'+IntToStr(mStream.Size));        FDownLoadEasy.ListBox2.Items.Add('第'+IntToStr(I)+'次循环，已经下载文件长度：'+IntToStr(mDownLoadSize));        ProgressBar1.StepBy(1);        //FDownLoadEasy.Refresh;        ListBox1.Refresh;        ListBox2.Refresh;        ProgressBar1.Refresh;        FreeAndNil(mStream);      end;      Result:=True;      MessageBox(handle,'下载成功','下载提示',MB_OK);    except on E: Exception do      begin        Result:=False;        ShowMessage('下载失败,原因是:'+e.Message);      end;    end;  finally    //FreeAndNil(mStream);    IdHTTP1.Disconnect;  end; end;

waterspace · 2006-03-31

。。。你的Range写错了 'Range: bytes='+IntToStr((I-1)*mBuffer+1)+'-'+IntToStr(I*mBuffer)+#13#10; 'Range: bytes='+IntToStr((I-1)*mBuffer+1)+'-'+IntToStr(mFileSize)+#13#10

nccxl · 2006-04-01

错在哪里了？应该怎么写呢？

waterspace · 2006-04-03

我已经写了该怎么改了啊。你看看你运行时rangestart和rangeend的值都是什么！！！ 如果rangestart>rangeend的话，就从头下文件了

nccxl · 2006-04-03

哦，原来如此，非常感谢。

nccxl · 2006-04-08

多人接受答案了。

DELPHI如何实现下载的断点续传功能(119分)

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

iamy

Unregistered / Unconfirmed

网中戏

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

余远源

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

waterspace

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

nccxl

Unregistered / Unconfirmed

Similar threads