惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

Threat Intelligence Blog | Flashpoint
Threat Intelligence Blog | Flashpoint
WordPress大学
WordPress大学
N
Netflix TechBlog - Medium
宝玉的分享
宝玉的分享
V
Visual Studio Blog
S
Securelist
P
Palo Alto Networks Blog
A
Arctic Wolf
T
Tor Project blog
P
Proofpoint News Feed
I
InfoQ
博
博客园 - 三生石上(FineUI控件)
T
Threat Research - Cisco Blogs
G
GRAHAM CLULEY
M
MIT News - Artificial intelligence
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
Microsoft Security Blog
Microsoft Security Blog
MongoDB | Blog
MongoDB | Blog
C
CXSECURITY Database RSS Feed - CXSecurity.com
Apple Machine Learning Research
Apple Machine Learning Research
S
Secure Thoughts
Cyberwarzone
Cyberwarzone
Blog — PlanetScale
Blog — PlanetScale
Simon Willison's Weblog
Simon Willison's Weblog
博
博客园 - 【当耐特】
大猫的无限游戏
大猫的无限游戏
腾
腾讯CDC
Latest news
Latest news
Project Zero
Project Zero
V
Vulnerabilities – Threatpost
Y
Y Combinator Blog
S
SegmentFault 最新的问题
Schneier on Security
Schneier on Security
C
CERT Recently Published Vulnerability Notes
W
WeLiveSecurity
罗
罗磊的独立博客
Stack Overflow Blog
Stack Overflow Blog
酷 壳 – CoolShell
酷 壳 – CoolShell
L
LINUX DO - 热门话题
N
News and Events Feed by Topic
PCI Perspectives
PCI Perspectives
C
Cisco Blogs
Application and Cybersecurity Blog
Application and Cybersecurity Blog
爱范儿
爱范儿
T
The Exploit Database - CXSecurity.com
The Last Watchdog
The Last Watchdog
人人都是产品经理
人人都是产品经理
GbyAI
GbyAI
Know Your Adversary
Know Your Adversary
U
Unit 42

博客园 - Enli

IOS 命令行安装备忘 IOS开发备忘 MAC 编制计划任务 弹出式窗口管理单元备忘 Wininet请求包装类简稿 自备工具库 多屏开发的备忘 界面方面的备忘 rc资源文件的中英文应用备忘 Wininet下载类初稿 Dephi调用C#编写的WebService的一些问题与解决 （转） 关于Window的快捷方式，图标缓存的清理 Delphi 备忘五 Delphi 代码优化（转） [转载]Delphi的四舍五入函数 同名派生的应用（转） 关于delphi的程序在英文操作系统下乱码问题 - Enli - 博客园 TWebBrowser备忘 组件开发中的技巧(转)
http断点续传的单元
Enli · 2011-04-09 · via 博客园 - Enli

{******************************************************************************
    文件名称： uWnDownLoadHelper.pas
    文件功能： 断点续传下载线程单元
    作者    ： enli
--------------------------------------------------------------------------------}

unit uWnDownLoadHelper;interfaceuses
  IdHTTP, IdAuthentication, IdHeaderList, IniFiles, md5,
  SysUtils, IdAuthenticationSSPI, IdAuthenticationDigest, Classes, IdException,
  IdSocks, IdIOHandlerSocket, DateUtils, IdComponent, Forms,ucchttpClient;const
  S_TMP_POSTFIX = '.tmp';
  S_INI_POSTFIX = '.sni';type
  TWnDownloadProgress = procedure(APosition,ACount: Int64) of object;// 代理设置结构
  TWnProxySetting = packed record
    FIsProxyEnabled: Boolean;
    FSocksVersion: TSocksVersion;
    FProxyHost: string;
    FProxyPort: Word;
    FAuthUserName: string;
    FAuthPassword: string;
    FAuthDomain:string;
  end;
  PWnProxySetting = ^TWnProxySetting;

  TWnDownLoadThread 

= class(TThread)
  private
    FHttp: TCCHTTPClient;
    FProxy: TWnProxySetting;
    FTarget: string;
    FSaveFile: string;
    FTempFile: string;
    FProgress: TWnDownloadProgress;
    FCurrentFileSize,FFileSize : Int64;
    FSaveLocation: string;
    FOnLog: TDolog;
    FWarningMsg: string;
    FReLoad: Boolean;
    procedure SetProxy(const Value: PWnProxySetting);
    function GetProxy :PWnProxySetting;
    procedure SetHttpProxy;
    procedure SetTarget(const Value: string);
    procedure SetProgress(const Value: TWnDownloadProgress);
    procedure DoBeginWork(Sender: TObject;const APos,ACount: Int64);
    procedure DoWork(Sender: TObject;const AWork:Int64);
    procedure DoEndWork(Sender: TObject);
    procedure DoUpdateUI;
    procedure SetSaveLocation(const Value: string);
    procedure SaveIniFile;
    procedure DelIniFile;
    procedure DoLog(const AMsg:string);
    procedure DoSycLog;
    function GetTempFile:string;
    procedure SetOnLog(const Value: TDolog);
    procedure SetReLoad(const Value: Boolean);
  public
    procedure Execute; override;
    constructor Create;
    destructor Destroy; override;
    class procedure chunkedConvertToFile(const ASource,ADestination:string);
    property PProxy:PWnProxySetting read GetProxy write SetProxy;
    property Target:string read FTarget write SetTarget;
    property SaveLocation :string read FSaveLocation write SetSaveLocation;
    property Progress:TWnDownloadProgress read FProgress write SetProgress;
    property ReLoad:Boolean read FReLoad write SetReLoad;
    property OnLog: TDolog read FOnLog write SetOnLog;
  end;procedure DownLoadFile(const AUrl,ASaveFile:string;AProxy:PWnProxySetting;AProgress:TWnDownloadProgress;ALog:TDolog;AReLoad:Boolean);implementationprocedure DownLoadFile(const AUrl,ASaveFile:string;AProxy:PWnProxySetting;AProgress:TWnDownloadProgress;ALog:TDolog;AReLoad:Boolean);
var
  LThread: TWnDownLoadThread;
begin
  LThread := TWnDownLoadThread.Create;
  LThread.ReLoad := AReLoad;
  LThread.Target := AUrl;
  LThread.SaveLocation := ASaveFile;
  LThread.PProxy := AProxy;
  LThread.Progress :=AProgress;
  LThread.OnLog := ALog;
  LThread.Resume;
end;{ TWnDownLoadThread }class procedure TWnDownLoadThread.chunkedConvertToFile(const ASource,
  ADestination: string);
var
  LSStream,LDStream: TFileStream;
  LBuff: Byte;
  LFlag: Boolean;
  LTemp : string;
  I,LCount : Integer;
begin
  if not FileExists(ASource) then Exit;
  if FileExists(ADestination) then Exit;
  LSStream := TFileStream.Create(ASource,fmOpenRead    );
  LDStream := TFileStream.Create(ADestination,fmCreate);
  try
    LSStream.Seek(0,0);
    LFlag := True;
    I := 0;
    while LFlag do
    begin
      LSStream.Read(LBuff,SizeOf(Byte));
      Inc(I);
      if (LBuff = $0A) and (I>2) and (LTemp[I-1] = #$0D) then begin
        LCount := StrToIntDef('$'+trim(LTemp),1);
        if LCount = 1 then
        begin
          LCount := 0;
          Break;
          //raise 异常
        end;
        if LCount = 0 then
          LFlag := False
        else
        begin
          LDStream.CopyFrom(LSStream,LCount);
          I := 0;
          LTemp := '';
        end;
      end
      else
        LTemp := LTemp + Char(LBuff);
    end;finally
    FreeAndNil(LSStream);
    FreeAndNil(LDStream);
  end;end;constructor TWnDownLoadThread.Create;
begin
  inherited Create(True);
  FreeOnTerminate := True;
  FTarget := '';
  FSaveFile := '';
  //New(FProxy);
end;procedure TWnDownLoadThread.DelIniFile;
begin
  DeleteFile(FSaveLocation + FTempFile+S_INI_POSTFIX);
end;destructor TWnDownLoadThread.Destroy;
begin
  //Dispose(FProxy);
  inherited;
end;procedure TWnDownLoadThread.DoBeginWork(Sender: TObject;
  const APos,ACount: Int64);
begin
  FFileSize := ACount;
  FCurrentFileSize := APos ;
  SaveIniFile;
  Synchronize(DoUpdateUI);
end;procedure TWnDownLoadThread.DoEndWork(Sender: TObject);
begin
  FCurrentFileSize := FFileSize;
  Synchronize(DoUpdateUI);
end;procedure TWnDownLoadThread.DoLog(const AMsg: string);
begin
  if Assigned(FOnlog) then
  begin
    ///DoDownLoadLog(AMsg);
    FWarningMsg:= AMsg;
    Synchronize(DoSycLog);
  end;
end;procedure TWnDownLoadThread.DoSycLog;
begin
  FOnlog(FWarningMsg);
end;procedure TWnDownLoadThread.DoUpdateUI;
begin
  if Assigned(FProgress) then
    FProgress(FCurrentFileSize,FFileSize);
end;procedure TWnDownLoadThread.DoWork(Sender: TObject; const AWork: Int64);
begin
  FCurrentFileSize := FCurrentFileSize+ AWork;
  Synchronize(DoUpdateUI);
end;procedure TWnDownLoadThread.Execute;
var
  LDoc,
  LHost,
  LPath,
  LProto,
  LPort,
  LBookmark: string;
begin
  if Length(FTarget) = 0 then Exit;
  if Length(FSaveLocation) = 0 then Exit;
  FHttp := TCCHTTPClient.Create(nil);
  try
    FHttp.IOHandler := TIdIOHandlerSocket.Create(FHttp);
    FHttp.Socket.SocksInfo := TIdSocksInfo.Create(FHttp);
    FHttp.ProtocolVersion := uCCHTTPClient.pv1_1;    
    SetHttpProxy;
    FHttp.OnDownloadBegin :=  DoBeginWork;
    FHttp.OnDownload :=  DoWork;
    FHttp.OnDownloadEnd := DoEndWork;
    FHttp.OnLog := DoLog;

    FHttp.ParseURI(FTarget, LProto, LHost, LPath, LDoc, LPort, LBookmark);
    FSaveFile :

= LDoc;
    FTempFile := GetTempFile+'.'+LDoc;
    if FReLoad and FileExists(FSaveLocation + FTempFile+S_TMP_POSTFIX) then
      DeleteFile(FSaveLocation + FTempFile+S_TMP_POSTFIX);
    DoLog('下载开始请求');
    try
      FHttp.DownLoad(FTarget,FSaveLocation + FTempFile+S_TMP_POSTFIX);
    except
      on E:Exception do
        DoLog(e.Message);
    end;
    if FileExists(FSaveLocation + FTempFile+S_INI_POSTFIX) then
    beginif FileExists(FSaveLocation + LDoc) then
        DeleteFile(FSaveLocation + LDoc);
      if FHttp.Response.TransferEncoding = 'chunked' then
      begin
        chunkedConvertToFile(FSaveLocation + FTempFile+S_TMP_POSTFIX,FSaveLocation + LDoc);
        DeleteFile(FSaveLocation + FTempFile+S_TMP_POSTFIX);
      end
      else
        RenameFile(FSaveLocation + FTempFile+S_TMP_POSTFIX,FSaveLocation + LDoc);
      DelIniFile;
    end
    else
      DeleteFile(FSaveLocation + FTempFile+S_TMP_POSTFIX);
  finally
    FreeAndNil(FHttp);
    DoLog('下载结束');
  end;
end;function TWnDownLoadThread.GetProxy: PWnProxySetting;
begin
  Result := @FProxy
end;function TWnDownLoadThread.GetTempFile: string;
var
  Ltemp: string;
begin
  Ltemp := MD5Print(MD5String(FTarget));
  //Ltemp := copy(Ltemp, 2, length(Ltemp) - 2);
  Result := StringReplace(Ltemp,'-','.',[rfReplaceAll]    );
end;procedure TWnDownLoadThread.SaveIniFile;
var
  LIni:TIniFile;
begin
  LIni := TIniFile.Create(FSaveLocation + FTempFile+S_INI_POSTFIX);
  try
    LIni.WriteString('Setup','URL',FTarget);
    LIni.WriteString('Setup','SaveLocation',FSaveLocation);
    LIni.WriteString('Setup','SaveFile',FSaveFile);
    LIni.WriteString('Setup','TempFile',FTempFile);
    LIni.WriteString('Setup','FileSize',FloatToStr(FFileSize));
  finally
    LIni.Free;
  end;end;procedure TWnDownLoadThread.SetHttpProxy;
begin
  if not Assigned(FHttp) then Exit;
  with FProxy do
  if FIsProxyEnabled then
  begin
    FHttp.Socket.SocksInfo.Version := FSocksVersion;
    FHttp.Socket.SocksInfo.Host := FProxyHost;
    FHttp.Socket.SocksInfo.Port := FProxyPort;if FHttp.Socket.SocksInfo.Username <> '' then
      FHttp.Socket.SocksInfo.Authentication := saUsernamePassword
    else
      FHttp.Socket.SocksInfo.Authentication := saNoAuthentication;
    FHttp.AuthUsername := FAuthUserName;
    FHttp.AuthPassword := FAuthPassword;
    FHttp.AuthDomain   := FAuthDomain;
    FHttp.ProxyHost    := FProxyHost;
    FHttp.ProxyPort    := FProxyPort;
  end;
end;procedure TWnDownLoadThread.SetOnLog(const Value: TDolog);
begin
  FOnLog := Value;
end;procedure TWnDownLoadThread.SetProgress(const Value: TWnDownloadProgress);
begin
  FProgress := Value;
end;procedure TWnDownLoadThread.SetProxy(const Value: PWnProxySetting);
begin
    //New(FProxy);
    FProxy.FIsProxyEnabled :=Value^.FIsProxyEnabled;
    FProxy.FSocksVersion := Value^.FSocksVersion;
    FProxy.FProxyHost := Value^.FProxyHost;
    FProxy.FProxyPort := Value^.FProxyPort;
    FProxy.FAuthUserName := Value^.FAuthUserName;
    FProxy.FAuthPassword := Value^.FAuthPassword;
    FProxy.FAuthDomain   := Value^.FAuthDomain;
    FProxy.FProxyHost   := Value^.FProxyHost;
    FProxy.FProxyPort    := Value^.FProxyPort;end;procedure TWnDownLoadThread.SetReLoad(const Value: Boolean);
begin
  FReLoad := Value;
end;procedure TWnDownLoadThread.SetSaveLocation(const Value: string);
begin
  FSaveLocation := Value;
  if FSaveLocation[Length(FSaveLocation)] <> '\' then
    FSaveLocation := FSaveLocation +'\';
end;procedure TWnDownLoadThread.SetTarget(const Value: string);
begin
  if Length(Value) = 0 then Exit;
  if UpperCase(Copy(Value,1,7)) <> 'HTTP://' then Exit;
  FTarget := Value;
end;　　end.

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。