Http 协议数据传输.doc

《Http 协议数据传输.doc》由会员分享，可在线阅读，更多相关《Http 协议数据传输.doc（19页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、如有侵权，请联系网站删除，仅供学习与交流Http 协议数据传输【精品文档】第 19 页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.Cr

2、yptography.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);/获取返回的网页源代码

3、 client.DownloadFile(下载文件 client.OpenRead(提交表单，此处是登录百度的示例 client.UploadFile(, file1=D:1.mp3);/上传文件 client.UploadFile(, folder=myfolder&size=4003550,file1=D:1.mp3);/提交含文本域和文件域的表单*/namespace HttpProc / /上传事件委托 / / / public delegate void WebClientUploadEvent(object sender, HttpProc.UploadEventArgs e);

4、/ /下载事件委托 / / / public delegate void WebClientDownloadEvent(object sender, HttpProc.DownloadEventArgs e); / /上传事件参数 / public struct UploadEventArgs / /上传数据总大小 / public long totalBytes; / /已发数据大小 / public long bytesSent; / /发送进度(0-1) / public double sendProgress; / /发送速度Bytes/s / public double sendSp

5、eed; / /下载事件参数 / public struct DownloadEventArgs / /下载数据总大小 / public long totalBytes; / /已接收数据大小 / public long bytesReceived; / /接收数据进度(0-1) / public double ReceiveProgress; / /当前缓冲区数据 / public byte receivedBuffer; / /接收速度Bytes/s / public double receiveSpeed; / /实现向WEB服务器发送和接收数据 / public class WebCl

6、ient 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_SIZ

7、E = 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 Downlo

8、adProgressChanged; / /初始化WebClient类 / public WebClient() responseHeaders = new WebHeaderCollection(); requestHeaders = new WebHeaderCollection(); / /读取指定URL的文本 / /请求的地址 /服务器响应文本 public string OpenRead(string URL) requestHeaders.Add(Connection, close); SendRequestData(URL, GET); return GetHtml(); /解决

9、证书过期无法访问的问题 class CertPolicy : ICertificatePolicy public bool CheckValidationResult(ServicePoint srvpt, X509Certificate cert, WebRequest req, int certprb) return true; / /采用https协议访问网络 / /url地址 /发送的数据 / public string OpenReadWithHttps(string URL,string strPostdata) ServicePointManager.CertificatePol

10、icy = 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.Con

11、tentLength = 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

12、 in response.Cookies) this.cookie += ck.Name + = + ck.Value + ; reader.Close(); return respHtml; / /读取指定URL的文本 / /请求的地址 /向服务器发送的文本数据 /服务器响应文本 public string OpenRead(string URL, string postData) byte sendBytes = encoding.GetBytes(postData); postStream = new MemoryStream(); postStream.Write(sendBytes,

13、 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(); / /读取指定URL的流 / /请求的地址 /向服务器发送的数据 /服务器响应流 public Stream Get

14、Stream(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); r

15、equestHeaders.Add(Connection, close); SendRequestData(URL, POST); MemoryStream ms = new MemoryStream(); SaveNetworkStream(ms); return ms; / /上传文件到服务器 / /请求的地址 /文件域(格式如:file1=C:test.mp3&file2=C:test.jpg) /服务器响应文本 public string UploadFile(string URL, string fileField) return UploadFile(URL, , fileFiel

16、d); / /上传文件和数据到服务器 / /请求地址 /文本域(格式为:name1=value1&name2=value2) /文件域(格式如:file1=C:test.mp3&file2=C:test.jpg) /服务器响应文本 public string UploadFile(string URL, string textField, string fileField) postStream = new MemoryStream(); if (textField != & fileField != ) WriteTextField(textField); WriteFileField(fi

17、leField); 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

18、, postStream.Length.ToString(); requestHeaders.Add(Content-Type, multipart/form-data; boundary= + BOUNDARY); requestHeaders.Add(Connection, Keep-Alive); /发送请求数据 SendRequestData(URL, POST, true); /返回响应文本 return GetHtml(); / /分析文本域，添加到请求流 / /文本域 private void WriteTextField(string textField) string str

19、Arr = 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.Wri

20、te(buffer, 0, buffer.Length); / /分析文件域，添加到请求流 / /文件域 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; f

21、ileField += 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, Fil

22、eMode.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); / /从指定URL下载数据流 / /请求地址 /数据流 public

23、 Stream DownloadData(string URL) requestHeaders.Add(Connection, close); SendRequestData(URL, GET); MemoryStream ms = new MemoryStream(); SaveNetworkStream(ms, true); return ms; / /从指定URL下载文件 / /文件URL地址 /文件保存路径,含文件名(如:C:test.jpg) public void DownloadFile(string URL, string fileName) requestHeaders.Ad

24、d(Connection, close); SendRequestData(URL, GET); FileStream fs = new FileStream(fileName, FileMode.Create); SaveNetworkStream(fs, true); fs.Close(); fs = null; / /向服务器发送请求 / /请求地址 /POST或GET /是否显示上传进度 private void SendRequestData(string URL, string method, bool showProgress) clientSocket = new TcpCli

25、ent(); 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 co

26、unt = 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 = postSt

27、ream.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); timer.Stop(); postStream.Close(); /postStream.Dispose();

28、postStream = null; /end if / /向服务器发送请求 / /请求URL地址 /POST或GET private void SendRequestData(string URL, string method) SendRequestData(URL, method, false); / /获取请求头字节数组 / /POST或GET请求 /请求头字节数组 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.432