.NETC #: Implement the HTTP web client tool class for support breakpoints to renew multi-thread download (C # DIY HTTPWEBCLIENT)

IF (EA == ExceptionActions.throw) {if (! (e is webexception) &&! ("Net_WebClient", E);} through;}}}

INTERNAL BYTE [] Responseasbytes (String Requesturl, WebResponse Response, long length, string filename) {string a = null; // attachmentname int P = 0; // The position pointer of the entire file INT NUM2 = 0; Try {a = response. Headers ["Content-Disposition"]; // attachment if (a! = Null) {a = a.substring (a.lastIndexof ("filename =") 9);} long Num1 = length; //Response.contentLENGTH Bool flag1 = false; if (Num1 == -1) {flag1 = true; Num1 = 0x10000; // 64k} byte [] buffer1 = new byte [(int) Num1];

INT P = 0; // This block of position pointer

String s = response.Headers ["content-range"]; if (s! = null) {s = s.replace ("bytes", "); s = s.substring (0, s.indexof) ")); P = convert.toint32 (s);} int Num3 = 0;

Stream S = response.getResponseSstream (); do {Num2 = S. Read (Buffer1, Num3, ((int) Num1) - Num3);

Num3 = Num2; IF (Flag1 && (Num3 == Num1)) {Num1 = 0x10000; Byte [] Buffer2 = New Byte [(int) Num1]; buffer.blockcopy (buffer1, 0, buffer2, 0, num3) Buffer1 = buffer2;}

// Lock (_SyncLockObject) // {// this._bytes = Num2; //} f (Num2> 0) {if (this.DataReceive! = Null) {byte [] buffer = new byte [Num2]; buffer .BlockCopy (buffer1, p, buffer, 0, buffer.Length); DownLoadState dls = new DownLoadState (RequestURL, Response.ResponseUri.AbsolutePath, FileName, a, P, num2, buffer); DownLoadEventArgs dlea = new DownLoadEventArgs (dls); // Trigger event this.ondatareceive (DLEA); //system.threading.thread.sleep(100);} P = Num2; // This block position pointer P = Num2; // The position pointer of the entire file} Else {Break;

} While (Num2! = 0);

S.close (); s = null; if (flag1) {byte [] buffer3 = new byte [Num3]; buffer1, 0, buffer3, 0, num 3); buffer1 = buffer3;} return buffer1;} catch (Exception e) {ExceptionActions ea = ExceptionActions.Throw; if (! this.ExceptionOccurrs = null) {DownLoadState x = new DownLoadState (RequestURL, Response.ResponseUri.AbsolutePath, FileName, a, P, num2); ExceptionEventArgs eea = new ExceptionEventArgs (E, X); Exceptionocurrs (this, EEA); EA = EEA.Exception;

IF (EA == ExceptionActions.throw) {if (! (e is webexception) &&! ("Net_WebClient", E);} throw;}}}}}}} Return NULL

Private void OnDataReceive (DownloadEventArgs E) {// Trigger data arrival event DataReceive (this, e);}

Public Byte [] UPLOADFILE (STRING Address, String FileName) {Return this.uploadFile (Address, "Post", FileName, "File");}

public string UploadFileEx (string address, string method, string fileName, string fieldName) {return Encoding.ASCII.GetString (UploadFile (address, method, fileName, fieldName));} public byte [] UploadFile (string address, string method, string FileName, String FieldName) {byte [] buffer4; filestream stream1 = null; try {filename = path.getFullPath (filename); string text1 = "----------------- - " DateTime.now.ticks.tostring (" x ");

String text2 = "Application / OcTet-stream";

stream1 = new FileStream (fileName, FileMode.Open, FileAccess.Read); WebRequest request1 = WebRequest.Create (this.GetUri (address)); request1.Credentials = this.m_credentials; request1.ContentType = "multipart / form-data; Boundary = " Text1;

Request1.method = method; string [] textArray1 = new string [7] {"-", text1, "/ r / ncontent-disposition: form-data; name = /" fieldname "/"; filename = / "" ", Path.getfilename (filename)," / "/" / r / nContent-type: ", text2," / r / n / r / n "}; string text3 = string.concat (TextArray1); byte [] Buffer1 = encoding.utf8.getbytes (text3); byte [] buffer2 = encoding.ascii.getbytes ("/ r / n" text1 "/ r / n"); long Num1 = 0x7fffffffffffffffff; Try {Num1 = Stream1.Length; Request1.contentLength = (Num1 Buffer1.Length) Buffer2.Length;} catch {} byte [] buffer3 = new byte [Math.min (0x2000, (int) Num1)]; use)]; use)]; using (stream stream2 = Request1.getRequestStream ()) {Int Num2; stream2.write (buffer1, 0, buffer1.Length); do {Num2 = stream1.read (buffer3, 0, buffer3.length); if (Num2! = 0) {stream2. Write (Buffer3, 0, Num2);}} while (Num2! = 0); stream2.write (buffer2, 0, buffer2.Length);} stream1.close (); stream1 = Null; WebResponse response1 = request1.GetResponse (); buffer4 = this.ResponseAsBytes (response1);} catch (Exception exception1) {if (stream1 = null!) {Stream1.Close (); stream1 = null;} if (! (exception1 is WebException) && (exception1 is SecurityException)) {// throw new WebException (SR.GetString ( "net_webclient"), exception1); throw new WebException ( "net_webclient", exception1);}! throw;} return buffer4; }

private byte [] ResponseAsBytes (WebResponse response) {int num2; long num1 = response.ContentLength; bool flag1 = false; if (num1 == -1) {flag1 = true; num1 = 0x10000;} byte [] buffer1 = new byte [(int) Num1]; stream stream1 = response.getResponseSstream (); int Num3 = 0; do {Num2 = stream1.read (buffer1, num3, ((int) Num1) - Num3); Num3 = Num2; IF Flag1 && (Num3 == Num1)) {Num1 = 0x10000; Byte [] Buffer2 = New Byte [(int) Num1]; Buffer.Blockcopy (Buffer1, 0, Buffer2, 0, Num3); buffer1 = buffer2;}}} While (Num2! = 0); stream1.close (); if (flag1) {byte [] buffer3 = new byte [Num3]; buffer1, 0, buffer3, 0, num3); buffer1 = buffer3;} Return buffer1;} private namevaluecollection m_requestparameters; private uri m_baseaddress; private icredentials m_credentials = credentialcache.defaultcredentials;

Public ictedentials credentials {get {returnim_credentials;} set {this.m_credentials = value;

public NameValueCollection QueryString {get {if (this.m_requestParameters == null) {this.m_requestParameters = new NameValueCollection ();} return this.m_requestParameters;} set {this.m_requestParameters = value;}}

Public string baseaddress {get {if (this.m_baseaddress! = null) {returnim_baseaddress.tostring ();} return string.empty;} set {i ((value == null) || (value.length == 0)) {this.m_baseAddress = null;} else {try {this.m_baseAddress = new Uri (value);} catch (Exception exception1) {throw new ArgumentException ( "value", exception1);}}}} private Uri getUri (string path) {URI URI1; Try {if (this.m_baseaddress! = null) {uri1 = new URI (this.m_baseaddress, path);} else {uri1 = new URI (PATH);} IF (this.m_requestparameters = = null) {return uri1;} StringBuilder builder1 = new StringBuilder (); string text1 = string.Empty; for (int num1 = 0; num1

}

}

///