最新Http 协议数据传输.doc
精品资料Http 协议数据传输.1using System;using System.Collections.Generic;using System.Text;using System.Net;using System.Net.Sockets;using System.Collections;using System.IO;using System.Text.RegularExpressions;using RE = System.Text.RegularExpressions.Regex;using System.Security.Cryptography.X509Certificates;/* *文件名：HttpProc.cs* *创建人：HeDaode* *日 期：2007.09.01* *描 述：实现HTTP协议中的GET、POST请求* *使 用：HttpProc.WebClient client = new HttpProc.WebClient(); client.Encoding = System.Text.Encoding.Default;/默认编码方式，根据需要设置其他类型 client.OpenRead("普通get请求 MessageBox.Show(client.RespHtml);/获取返回的网页源代码 client.DownloadFile("下载文件 client.OpenRead("提交表单，此处是登录百度的示例 client.UploadFile("", "file1=D:1.mp3");/上传文件 client.UploadFile("", "folder=myfolder&size=4003550","file1=D:1.mp3");/提交含文本域和文件域的表单*/namespace HttpProc /<summary> /上传事件委托 /</summary> /<param name="sender"></param> /<param name="e"></param> public delegate void WebClientUploadEvent(object sender, HttpProc.UploadEventArgs e); /<summary> /下载事件委托 /</summary> /<param name="sender"></param> /<param name="e"></param> public delegate void WebClientDownloadEvent(object sender, HttpProc.DownloadEventArgs e); /<summary> /上传事件参数 /</summary> public struct UploadEventArgs /<summary> /上传数据总大小 /</summary> public long totalBytes; /<summary> /已发数据大小 /</summary> public long bytesSent; /<summary> /发送进度(0-1) /</summary> public double sendProgress; /<summary> /发送速度Bytes/s /</summary> public double sendSpeed; /<summary> /下载事件参数 /</summary> public struct DownloadEventArgs /<summary> /下载数据总大小 /</summary> public long totalBytes; /<summary> /已接收数据大小 /</summary> public long bytesReceived; /<summary> /接收数据进度(0-1) /</summary> public double ReceiveProgress; /<summary> /当前缓冲区数据 /</summary> public byte receivedBuffer; /<summary> /接收速度Bytes/s /</summary> public double receiveSpeed; /<summary> /实现向WEB服务器发送和接收数据 /</summary> public class WebClient private WebHeaderCollection requestHeaders, responseHeaders; private TcpClient clientSocket; private MemoryStream postStream; private Encoding encoding = Encoding.Default; private const string BOUNDARY = "-HEDAODE-" private const int SEND_BUFFER_SIZE = 10245; private const int RECEIVE_BUFFER_SIZE = 10245; private string cookie = "" private string respHtml = "" private string strRequestHeaders = "" private string strResponseHeaders = "" private int statusCode = 0; private bool isCanceled = false; public event WebClientUploadEvent UploadProgressChanged; public event WebClientDownloadEvent DownloadProgressChanged; /<summary> /初始化WebClient类 /</summary> public WebClient() responseHeaders = new WebHeaderCollection(); requestHeaders = new WebHeaderCollection(); /<summary> /读取指定URL的文本 /</summary> /<param name="URL">请求的地址</param> /<returns>服务器响应文本</returns> public string OpenRead(string URL) requestHeaders.Add("Connection", "close"); SendRequestData(URL, "GET"); return GetHtml(); /解决证书过期无法访问的问题 class CertPolicy : ICertificatePolicy public bool CheckValidationResult(ServicePoint srvpt, X509Certificate cert, WebRequest req, int certprb) return true; /<summary> /采用https协议访问网络 /</summary> /<param name="URL">url地址</param> /<param name="strPostdata">发送的数据</param> /<returns></returns> public string OpenReadWithHttps(string URL,string strPostdata) ServicePointManager.CertificatePolicy = new CertPolicy(); HttpWebRequest request = (HttpWebRequest)WebRequest.Create(URL); request.CookieContainer = new CookieContainer(); request.Method = "POST" request.Accept = "*/*" request.ContentType="application/x-www-form-urlencoded" byte buffer = this.encoding.GetBytes(strPostdata); request.ContentLength = buffer.Length; request.GetRequestStream().Write(buffer, 0, buffer.Length); HttpWebResponse response = (HttpWebResponse)request.GetResponse(); StreamReader reader = new StreamReader(response.GetResponseStream(), encoding); this.respHtml = reader.ReadToEnd(); foreach (System.Net.Cookie ck in response.Cookies) this.cookie += ck.Name + "=" + ck.Value + "" reader.Close(); return respHtml; /<summary> /读取指定URL的文本 /</summary> /<param name="URL">请求的地址</param> /<param name="postData">向服务器发送的文本数据</param> /<returns>服务器响应文本</returns> public string OpenRead(string URL, string postData) byte sendBytes = encoding.GetBytes(postData); postStream = new MemoryStream(); postStream.Write(sendBytes, 0, sendBytes.Length); requestHeaders.Add("Content-Length", postStream.Length.ToString(); requestHeaders.Add("Content-Type", "application/x-www-form-urlencoded"); requestHeaders.Add("Connection", "close"); SendRequestData(URL, "POST"); return GetHtml(); /<summary> /读取指定URL的流 /</summary> /<param name="URL">请求的地址</param> /<param name="postData">向服务器发送的数据</param> /<returns>服务器响应流</returns> public Stream GetStream(string URL, string postData) byte sendBytes = encoding.GetBytes(postData); postStream = new MemoryStream(); postStream.Write(sendBytes, 0, sendBytes.Length); requestHeaders.Add("Content-Length", postStream.Length.ToString(); requestHeaders.Add("Content-Type", "application/x-www-form-urlencoded"); requestHeaders.Add("Connection", "close"); SendRequestData(URL, "POST"); MemoryStream ms = new MemoryStream(); SaveNetworkStream(ms); return ms; /<summary> /上传文件到服务器 /</summary> /<param name="URL">请求的地址</param> /<param name="fileField">文件域(格式如:file1=C:test.mp3&file2=C:test.jpg)</param> /<returns>服务器响应文本</returns> public string UploadFile(string URL, string fileField) return UploadFile(URL, "", fileField); /<summary> /上传文件和数据到服务器 /</summary> /<param name="URL">请求地址</param> /<param name="textField">文本域(格式为:name1=value1&name2=value2)</param> /<param name="fileField">文件域(格式如:file1=C:test.mp3&file2=C:test.jpg)</param> /<returns>服务器响应文本</returns> public string UploadFile(string URL, string textField, string fileField) postStream = new MemoryStream(); if (textField != "" && fileField != "") WriteTextField(textField); WriteFileField(fileField); else if (fileField != "") WriteFileField(fileField); else if (textField != "") WriteTextField(textField); else throw new Exception("文本域和文件域不能同时为空。"); /写入结束标记 byte buffer = encoding.GetBytes("-" + BOUNDARY + "-rn"); postStream.Write(buffer, 0, buffer.Length); /添加请求标头 requestHeaders.Add("Content-Length", postStream.Length.ToString(); requestHeaders.Add("Content-Type", "multipart/form-data; boundary=" + BOUNDARY); requestHeaders.Add("Connection", "Keep-Alive"); /发送请求数据 SendRequestData(URL, "POST", true); /返回响应文本 return GetHtml(); /<summary> /分析文本域，添加到请求流 /</summary> /<param name="textField">文本域</param> private void WriteTextField(string textField) string strArr = RE.Split(textField, "&"); textField = "" foreach (string var in strArr) Match M = RE.Match(var, "(=+)=(.+)"); textField += "-" + BOUNDARY + "rn" textField += "Content-Disposition: form-data; name="" + M.Groups1.Value + ""rnrn" + M.Groups2.Value + "rn" byte buffer = encoding.GetBytes(textField); postStream.Write(buffer, 0, buffer.Length); /<summary> /分析文件域，添加到请求流 /</summary> /<param name="fileField">文件域</param> private void WriteFileField(string fileField) string filePath = "" int count = 0; string strArr = RE.Split(fileField, "&"); foreach (string var in strArr) Match M = RE.Match(var, "(=+)=(.+)"); filePath = M.Groups2.Value; fileField = "-" + BOUNDARY + "rn" fileField += "Content-Disposition: form-data; name="" + M.Groups1.Value + "" filename="" + Path.GetFileName(filePath) + ""rn" fileField += "Content-Type: image/jpegrnrn" byte buffer = encoding.GetBytes(fileField); postStream.Write(buffer, 0, buffer.Length); /添加文件数据 FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read); buffer = new byte50000; do count = fs.Read(buffer, 0, buffer.Length); postStream.Write(buffer, 0, count); while (count > 0); fs.Close(); fs.Dispose(); fs = null; buffer = encoding.GetBytes("rn"); postStream.Write(buffer, 0, buffer.Length); /<summary> /从指定URL下载数据流 /</summary> /<param name="URL">请求地址</param> /<returns>数据流</returns> public Stream DownloadData(string URL) requestHeaders.Add("Connection", "close"); SendRequestData(URL, "GET"); MemoryStream ms = new MemoryStream(); SaveNetworkStream(ms, true); return ms; /<summary> /从指定URL下载文件 /</summary> /<param name="URL">文件URL地址</param> /<param name="fileName">文件保存路径,含文件名(如:C:test.jpg)</param> public void DownloadFile(string URL, string fileName) requestHeaders.Add("Connection", "close"); SendRequestData(URL, "GET"); FileStream fs = new FileStream(fileName, FileMode.Create); SaveNetworkStream(fs, true); fs.Close(); fs = null; /<summary> /向服务器发送请求 /</summary> /<param name="URL">请求地址</param> /<param name="method">POST或GET</param> /<param name="showProgress">是否显示上传进度</param> private void SendRequestData(string URL, string method, bool showProgress) clientSocket = new TcpClient(); Uri URI = new Uri(URL); clientSocket.Connect(URI.Host, URI.Port); requestHeaders.Add("Host", URI.Host); byte request = GetRequestHeaders(method + " " + URI.PathAndQuery + " HTTP/1.1"); clientSocket.Client.Send(request); /若有实体内容就发送它 if (postStream != null) byte buffer = new byteSEND_BUFFER_SIZE; int count = 0; Stream sm = clientSocket.GetStream(); postStream.Position = 0; UploadEventArgs e = new UploadEventArgs(); e.totalBytes = postStream.Length; System.Diagnostics.Stopwatch timer = new System.Diagnostics.Stopwatch();/计时器 timer.Start(); do /如果取消就推出 if (isCanceled) break; /读取要发送的数据 count = postStream.Read(buffer, 0, buffer.Length); /发送到服务器 sm.Write(buffer, 0, count); /是否显示进度 if (showProgress) /触发事件 e.bytesSent += count; e.sendProgress = (double)e.bytesSent / (double)e.totalBytes; double t = timer.ElapsedMilliseconds / 1000; t = t <= 0 ? 1 : t; e.sendSpeed = (double)e.bytesSent / t; if (UploadProgressChanged != null) UploadProgressChanged(this, e); while (count > 0); timer.Stop(); postStream.Close(); /postStream.Dispose(); postStream = null; /end if /<summary> /向服务器发送请求 /</summary> /<param name="URL">请求URL地址</param> /<param name="method">POST或GET</param> private void SendRequestData(string URL, string method) SendRequestData(URL, method, false); /<summary> /获取请求头字节数组 /</summary> /<param name="request">POST或GET请求</param> /<returns>请求头字节数组</returns> private byte GetRequestHeaders(string request) requestHeaders.Add("Accept", "*/*"); requestHeaders.Add("Accept-Language", "zh-cn"); requestHeaders.Add("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1
