C#实现http协议支持上传下载文件的GET、POST请求

2022-07-20 23:10:19

C#实现http协议支持上传下载文件的GET、POST请求
using 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("http://www.baidu.com");//普通get请求

MessageBox.Show(client.RespHtml);//获取返回的网页源代码

client.DownloadFile("http://www.loopc.com/upload/163album.rar",@"C:/163album.rar");//下载文件

client.OpenRead("http://passport.baidu.com/?login","username=zhangsan&password=123456");//提交表单，此处是登录百度的示例

client.UploadFile("http://hiup.baidu.com/zhangsan/upload", @"file1=D:/1.mp3");//上传文件

client.UploadFile("http://hiup.baidu.com/zhangsan/upload", "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 + "--/r/n");

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 + "/r/n";

textField += "Content-Disposition: form-data; name=/"" + M.Groups[1].Value + "/"/r/n/r/n" + M.Groups[2].Value + "/r/n";

}

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.Groups[2].Value;

fileField = "--" + BOUNDARY + "/r/n";

fileField += "Content-Disposition: form-data; name=/"" + M.Groups[1].Value + "/"; filename=/"" + Path.GetFileName(filePath) + "/"/r/n";

fileField += "Content-Type: image/jpeg/r/n/r/n";

byte[] buffer = encoding.GetBytes(fileField);

postStream.Write(buffer, 0, buffer.Length);

//添加文件数据

FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read);

buffer = new byte[50000];

{

count = fs.Read(buffer, 0, buffer.Length);

postStream.Write(buffer, 0, count);

} while (count > 0);

fs.Close();

fs.Dispose();

fs = null;

buffer = encoding.GetBytes("/r/n");

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 byte[SEND_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();

{

//如果取消就推出

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.4322; .NET CLR 2.0.50727)");

string headers = request + "/r/n";

foreach (string key in requestHeaders)

{

headers += key + ":" + requestHeaders[key] + "/r/n";

}

//有Cookie就带上Cookie

if (cookie != "") { headers += "Cookie:" + cookie + "/r/n"; }

//空行，请求头结束

headers += "/r/n";

strRequestHeaders = headers;

requestHeaders.Clear();

return encoding.GetBytes(headers);

}

///<summary>

///获取服务器响应文本

///</summary>

///<returns>服务器响应文本</returns>

private string GetHtml()

{

MemoryStream ms = new MemoryStream();

SaveNetworkStream(ms);//将网络流保存到内存流

StreamReader sr = new StreamReader(ms, encoding);

respHtml = sr.ReadToEnd();

sr.Close(); ms.Close();

return respHtml;

}

///<summary>

///将网络流保存到指定流

///</summary>

///<param name="toStream">保存位置</param>

///<param name="needProgress">是否显示进度</param>

private void SaveNetworkStream(Stream toStream, bool showProgress)

{

//获取要保存的网络流

NetworkStream NetStream = clientSocket.GetStream();

byte[] buffer = new byte[RECEIVE_BUFFER_SIZE];

int count = 0, startIndex = 0;

MemoryStream ms = new MemoryStream();

for (int i = 0; i < 3; i++)

{

count = NetStream.Read(buffer, 0, 500);

ms.Write(buffer, 0, count);

}

if (ms.Length == 0) { NetStream.Close(); throw new Exception("远程服务器没有响应"); }

buffer = ms.GetBuffer();

count = (int)ms.Length;

GetResponseHeader(buffer, out startIndex);//分析响应，获取响应头和响应实体

count -= startIndex;

toStream.Write(buffer, startIndex, count);

DownloadEventArgs e = new DownloadEventArgs();

if (responseHeaders["Content-Length"] != null)

{ e.totalBytes = long.Parse(responseHeaders["Content-Length"]); }

else

{ e.totalBytes = -1; }

//启动计时器

System.Diagnostics.Stopwatch timer = new System.Diagnostics.Stopwatch();

timer.Start();

{

//如果取消就推出

if (isCanceled) { break; }

//显示下载进度

if (showProgress)

{

e.bytesReceived += count;

e.ReceiveProgress = (double)e.bytesReceived / (double)e.totalBytes;

byte[] tempBuffer = new byte[count];

Array.Copy(buffer, startIndex, tempBuffer, 0, count);

e.receivedBuffer = tempBuffer;

double t = (timer.ElapsedMilliseconds + 0.1)/1000;

e.receiveSpeed = (double)e.bytesReceived / t;

startIndex = 0;

if (DownloadProgressChanged != null) { DownloadProgressChanged(this, e); }

}

//读取网路数据到缓冲区

count = NetStream.Read(buffer, 0, buffer.Length);

//将缓存区数据保存到指定流

toStream.Write(buffer, 0, count);

} while (count > 0);

timer.Stop();//关闭计时器

if (responseHeaders["Content-Length"] != null)

{

toStream.SetLength(long.Parse(responseHeaders["Content-Length"]));

}

//else

//{

// toStream.SetLength(toStream.Length);

// responseHeaders.Add("Content-Length", toStream.Length.ToString());//添加响应标头

//}

toStream.Position = 0;

//关闭网络流和网络连接

NetStream.Close();

clientSocket.Close();

}

///<summary>

///将网络流保存到指定流

///</summary>

///<param name="toStream">保存位置</param>

private void SaveNetworkStream(Stream toStream)

{

SaveNetworkStream(toStream, false);

}

///<summary>

///分析响应流，去掉响应头

///</summary>

///<param name="buffer"></param>

private void GetResponseHeader(byte[] buffer, out int startIndex)

{

responseHeaders.Clear();

string html = encoding.GetString(buffer);

StringReader sr = new StringReader(html);

int start = html.IndexOf("/r/n/r/n") + 4;//找到空行位置

strResponseHeaders = html.Substring(0, start);//获取响应头文本

//获取响应状态码

if (sr.Peek() > -1)

{

//读第一行字符串

string line = sr.ReadLine();

//分析此行字符串,获取服务器响应状态码

Match M = RE.Match(line, @"/d/d/d");

if (M.Success)

{

statusCode = int.Parse(M.Value);

}

//获取响应头

while (sr.Peek() > -1)

{

//读一行字符串

string line = sr.ReadLine();

//若非空行

if (line != "")

{

//分析此行字符串，获取响应标头

Match M = RE.Match(line, "([^:]+):(.+)");

if (M.Success)

{

try

{ //添加响应标头到集合

responseHeaders.Add(M.Groups[1].Value.Trim(), M.Groups[2].Value.Trim());

}

catch

{ }

//获取Cookie

if (M.Groups[1].Value == "Set-Cookie")

{

M = RE.Match(M.Groups[2].Value, "[^=]+=[^;]+");

cookie += M.Value.Trim() + ";";

}

//若是空行，代表响应头结束响应实体开始。（响应头和响应实体间用一空行隔开）

else

{

//如果响应头中没有实体大小标头，尝试读响应实体第一行获取实体大小

if (responseHeaders["Content-Length"] == null && sr.Peek() > -1)

{

//读响应实体第一行

line = sr.ReadLine();

//分析此行看是否包含实体大小

Match M = RE.Match(line, "~[0-9a-fA-F]{1,15}");

if (M.Success)

{

//将16进制的实体大小字符串转换为10进制

int length = int.Parse(M.Value, System.Globalization.NumberStyles.AllowHexSpecifier);

responseHeaders.Add("Content-Length", length.ToString());//添加响应标头

strResponseHeaders += M.Value + "/r/n";

}

break;//跳出循环

}//End If

}//End While

sr.Close();

//实体开始索引

startIndex = encoding.GetBytes(strResponseHeaders).Length;

}

///<summary>

///取消上传或下载,要继续开始请调用Start方法

///</summary>

public void Cancel()

{

isCanceled = true;

}

///<summary>

///启动上传或下载，要取消请调用Cancel方法

///</summary>

public void Start()

{

isCanceled = false;

}

//*************************************************************

//以下为属性

//*************************************************************

///<summary>

///获取或设置请求头

///</summary>

public WebHeaderCollection RequestHeaders

{

set { requestHeaders = value; }

get { return requestHeaders; }

}

///<summary>

///获取响应头集合

///</summary>

public WebHeaderCollection ResponseHeaders

{

get { return responseHeaders; }

}

///<summary>

///获取请求头文本

///</summary>

public string StrRequestHeaders

{

get { return strRequestHeaders; }

}

///<summary>

///获取响应头文本

///</summary>

public string StrResponseHeaders

{

get { return strResponseHeaders; }

}

///<summary>

///获取或设置Cookie

///</summary>

public string Cookie

{

set { cookie = value; }

get { return cookie; }

}

///<summary>

///获取或设置编码方式(默认为系统默认编码方式)

///</summary>

public Encoding Encoding

{

set { encoding = value; }

get { return encoding; }

}

///<summary>

///获取服务器响应文本

///</summary>

public string RespHtml

{

get { return respHtml; }

}

///<summary>

///获取服务器响应状态码

///</summary>

public int StatusCode

{

get { return statusCode; }

}

C#实现http协议支持上传下载文件的GET、POST请求

码农公寓

相关文章