');
document.write('
');
document.write('
namespace DownloadApi.
Net');
document.write('
{');
document.write('
#region [ Using Directives ]');
document.write('
');
document.write('
using System;
');
document.write('
using System.
Collections.
Generic;
');
document.write('
using System.
Text;
');
document.write('
using System.
ComponentModel;
');
document.write('
using System.
Net;
');
document.write('
using System.
IO;
');
document.write('
');
document.write('
#endregion');
document.write('
');
document.write('
');
document.write('
public class DownloadClient
');
document.write('
{');
document.write('
#region [ Events ]');
document.write('
');
document.write('
public event EventHandler Complete;
');
document.write('
public event EventHandler Cancelled;
');
document.write('
public event EventHandler<ProgressChangedEventArgs> ProgressChanged;
');
document.write('
public class ProgressChangedEventArgs : EventArgs
');
document.write('
{');
document.write('
#region [ Properties ]');
document.write('
');
document.write('
private Int32 _Progress;
');
document.write('
public Int32 Progress
');
document.write('
{');
document.write(' get
{ return _Progress;
}');
document.write(' set
{ _Progress = value;
}');
document.write('
}');
document.write('
');
document.write('
#endregion');
document.write('
');
document.write('
');
document.write('
#region [ Constructor ]');
document.write('
');
document.write('
public ProgressChangedEventArgs
(Int32 progress
)');
document.write('
{');
document.write('
this.
Progress = progress;
');
document.write('
}');
document.write('
');
document.write('
#endregion');
document.write('
}');
document.write('
');
document.write('
#endregion');
document.write('
');
document.write('
');
document.write('
#region [ Field ]');
document.write('
');
document.write('
private BackgroundWorker _backgroundWorker =
null;
');
document.write('
');
document.write('
#endregion');
document.write('
');
document.write('
');
document.write('
#region [ Constructor ]');
document.write('
');
document.write('
public DownloadClient
() { }');
document.write('
');
document.write('
#endregion');
document.write('
');
document.write('
');
document.write('
#region [ Methods ]');
document.write('
');
document.write('
public void Start
(String url,
String path, Int32 startPoint
)');
document.write('
{');
document.write(' List<Object> arguments =
new List<Object>
();
');
document.write(' arguments.
Add(url
);
');
document.write(' arguments.
Add(path
);
');
document.write(' arguments.
Add(startPoint
);
');
document.write(' _backgroundWorker = CreateWorker
();
');
document.write(' _backgroundWorker.
RunWorkerAsync(arguments
);
');
document.write('
}');
document.write('
');
document.write('
public void Cancel
()');
document.write('
{');
document.write(' _backgroundWorker.
CancelAsync();
');
document.write('
}');
document.write('
');
document.write('
private void DoWork
(Object sender, DoWorkEventArgs e
)');
document.write('
{');
document.write(' List<Object> arguments =
(List<Object>
)e.
Argument;
');
document.write(' HttpWebRequest req =
null;
');
document.write(' HttpWebResponse res =
null;
');
document.write(' Stream resStream =
null;
');
document.write(' Stream localStream =
null;
');
document.write('
');
document.write('
try');
document.write('
{');
document.write(' req =
(HttpWebRequest
)WebRequest.
Create((String)arguments
[0]);
');
document.write(' req.
ContentType =
"Application";
');
document.write(' req.
AddRange((Int32
)arguments
[1]);
');
document.write(' req.
Credentials = CredentialCache.
DefaultCredentials;
');
document.write(' res =
(HttpWebResponse
)req.
GetResponse();
');
document.write('
');
document.write(' Int64 fileSize = res.
ContentLength;
');
document.write('
');
document.write(' resStream = res.
GetResponseStream();
');
document.write('
');
document.write('
if ((Int32
)arguments
[2] ==
0)');
document.write(' localStream =
new FileStream
((String)arguments
[1], FileMode.
Create, FileAccess.
Write, FileShare.
None);
');
document.write('
else');
document.write(' localStream =
new FileStream
((String)arguments
[1], FileMode.
Append, FileAccess.
Write, FileShare.
None);
');
document.write('
');
document.write('
int bytesSize =
0;
');
document.write('
');
document.write('
byte[] downBuffer =
new byte[2048];
');
document.write('
');
document.write('
while ((bytesSize = resStream.
Read(downBuffer,
0, downBuffer.
Length)) >
0)');
document.write('
{');
document.write(' localStream.
Write(downBuffer,
0, bytesSize
);
');
document.write('
');
document.write(' _backgroundWorker.
ReportProgress(Convert.
ToInt32((localStream.
Length *
100) / fileSize +
(Int32
)arguments
[2]));
');
document.write('
');
document.write('
if (_backgroundWorker.
CancellationPending)');
document.write('
{');
document.write(' e.
Cancel =
true;
');
document.write('
break;
');
document.write('
}');
document.write('
}');
document.write('
}');
document.write('
catch { throw;
}');
document.write('
finally');
document.write('
{');
document.write('
if (null != req
)');
document.write(' req =
null;
');
document.write('
if (null != res
)');
document.write(' res.
Close();
');
document.write('
if (null != resStream
)');
document.write(' resStream.
Close();
');
document.write('
if (null != localStream
)');
document.write(' localStream.
Close();
');
document.write('
}');
document.write('
}');
document.write('
');
document.write('
private void WorkerProgressChanged
(Object sender,
System.
ComponentModel.
ProgressChangedEventArgs e
)');
document.write('
{');
document.write(' OnProgressChanged
(e.
ProgressPercentage);
');
document.write('
}');
document.write('
');
document.write('
private void WorkerCompleted
(Object sender, RunWorkerCompletedEventArgs e
)');
document.write('
{');
document.write('
if (null != e.
Error)');
document.write('
throw new Exception
("Operation cancelled!", e.
Error);
');
document.write('
if (e.
Cancelled)');
document.write(' OnCancelled
();
');
document.write('
else');
document.write(' OnComplete
();
');
document.write('
}');
document.write('
');
document.write('
#endregion');
document.write('
');
document.write('
');
document.write('
#region [ Helper Methods ]');
document.write('
');
document.write('
private void OnProgressChanged
(Int32 progress
)');
document.write('
{');
document.write(' EventHandler<ProgressChangedEventArgs> copy = ProgressChanged;
');
document.write('
if (null != copy
)');
document.write(' copy
(this,
new ProgressChangedEventArgs
(progress
));
');
document.write('
}');
document.write('
');
document.write('
private void OnComplete
()');
document.write('
{');
document.write(' EventHandler copy = Complete;
');
document.write('
if (null != copy
)');
document.write(' copy
(this, EventArgs.
Empty);
');
document.write('
}');
document.write('
');
document.write('
private void OnCancelled
()');
document.write('
{');
document.write(' EventHandler copy = Cancelled;
');
document.write('
if (null != copy
)');
document.write(' copy
(this, EventArgs.
Empty);
');
document.write('
}');
document.write('
');
document.write('
public BackgroundWorker CreateWorker
()');
document.write('
{');
document.write(' BackgroundWorker bg =
new BackgroundWorker
();
');
document.write(' bg.
WorkerReportsProgress =
true;
');
document.write(' bg.
WorkerSupportsCancellation =
true;
');
document.write(' bg.
DoWork += DoWork;
');
document.write(' bg.
ProgressChanged += WorkerProgressChanged;
');
document.write(' bg.
RunWorkerCompleted += WorkerCompleted;
');
document.write('
return bg;
');
document.write('
}');
document.write('
');
document.write('
#endregion');
document.write('
}');
document.write('
}');
document.write('
');
document.write('