一個 http 請求類 ，支持文件上傳，從淘寶 top sdk 里面扣出來的，蠻好用的，做個記錄而已。
調用代碼：
Dictionary<string, string> textParas = new Dictionary<string, string>();
textParas.Add("username", "jersey");
textParas.Add("password", "000000");
Dictionary<string, FileItem> fileParas = new Dictionary<string, FileItem>();
fileParas.Add("file1", new FileItem("E:\\123.jpg"));
fileParas.Add("file2", new FileItem("E:\\123.jpg"));
WebUtils webUtils=new WebUtils();
webUtils.Timeout=50000;
webUtils.DoPost("http://www.baidu.com/api/index.php",textParas,fileParas,null);
類代碼：
using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.Net;
using System.Net.Security;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Web;
namespace tools
{
/// <summary>
/// 網絡工具類。
/// </summary>
public sealed class WebUtils
{
private int _timeout = 20000;
private int _readWriteTimeout = 60000;
private bool _ignoreSSLCheck = true;
private bool _disableWebProxy = false;
/// <summary>
/// 等待請求開始返回的超時時間
/// </summary>
public int Timeout
{
get { return this._timeout; }
set { this._timeout = value; }
}
/// <summary>
/// 等待讀取數據完成的超時時間
/// </summary>
public int ReadWriteTimeout
{
get { return this._readWriteTimeout; }
set { this._readWriteTimeout = value; }
}
/// <summary>
/// 是否忽略SSL檢查
/// </summary>
public bool IgnoreSSLCheck
{
get { return this._ignoreSSLCheck; }
set { this._ignoreSSLCheck = value; }
}
/// <summary>
/// 是否禁用本地代理
/// </summary>
public bool DisableWebProxy
{
get { return this._disableWebProxy; }
set { this._disableWebProxy = value; }
}
/// <summary>
/// 執行HTTP POST請求。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="textParams">請求文本參數</param>
/// <returns>HTTP響應</returns>
public string DoPost(string url, IDictionary<string, string> textParams)
{
return DoPost(url, textParams, null);
}
/// <summary>
/// 執行HTTP POST請求。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="textParams">請求文本參數</param>
/// <param name="headerParams">請求頭部參數</param>
/// <returns>HTTP響應</returns>
public string DoPost(string url, IDictionary<string, string> textParams, IDictionary<string, string> headerParams)
{
HttpWebRequest req = GetWebRequest(url, "POST", headerParams);
req.ContentType = "application/x-www-form-urlencoded;charset=utf-8";
byte[] postData = Encoding.UTF8.GetBytes(BuildQuery(textParams));
System.IO.Stream reqStream = req.GetRequestStream();
reqStream.Write(postData, 0, postData.Length);
reqStream.Close();
HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
Encoding encoding = GetResponseEncoding(rsp);
return GetResponseAsString(rsp, encoding);
}
/// <summary>
/// 執行HTTP GET請求。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="textParams">請求文本參數</param>
/// <returns>HTTP響應</returns>
public string DoGet(string url, IDictionary<string, string> textParams)
{
return DoGet(url, textParams, null);
}
/// <summary>
/// 執行HTTP GET請求。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="textParams">請求文本參數</param>
/// <param name="headerParams">請求頭部參數</param>
/// <returns>HTTP響應</returns>
public string DoGet(string url, IDictionary<string, string> textParams, IDictionary<string, string> headerParams)
{
if (textParams != null && textParams.Count > 0)
{
url = BuildRequestUrl(url, textParams);
}
HttpWebRequest req = GetWebRequest(url, "GET", headerParams);
req.ContentType = "application/x-www-form-urlencoded;charset=utf-8";
HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
Encoding encoding = GetResponseEncoding(rsp);
return GetResponseAsString(rsp, encoding);
}
/// <summary>
/// 執行帶文件上傳的HTTP POST請求。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="textParams">請求文本參數</param>
/// <param name="fileParams">請求文件參數</param>
/// <param name="headerParams">請求頭部參數</param>
/// <returns>HTTP響應</returns>
public string DoPost(string url, IDictionary<string, string> textParams, IDictionary<string, FileItem> fileParams, IDictionary<string, string> headerParams)
{
// 如果沒有文件參數，則走普通POST請求
if (fileParams == null || fileParams.Count == 0)
{
return DoPost(url, textParams, headerParams);
}
string boundary = DateTime.Now.Ticks.ToString("X"); // 隨機分隔線
HttpWebRequest req = GetWebRequest(url, "POST", headerParams);
req.ContentType = "multipart/form-data;charset=utf-8;boundary=" + boundary;
System.IO.Stream reqStream = req.GetRequestStream();
byte[] itemBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "\r\n");
byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");
// 組裝文本請求參數
string textTemplate = "Content-Disposition:form-data;name=\"{0}\"\r\nContent-Type:text/plain\r\n\r\n{1}";
foreach (KeyValuePair<string, string> kv in textParams)
{
string textEntry = string.Format(textTemplate, kv.Key, kv.Value);
byte[] itemBytes = Encoding.UTF8.GetBytes(textEntry);
reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
reqStream.Write(itemBytes, 0, itemBytes.Length);
}
// 組裝文件請求參數
string fileTemplate = "Content-Disposition:form-data;name=\"{0}\";filename=\"{1}\"\r\nContent-Type:{2}\r\n\r\n";
foreach (KeyValuePair<string, FileItem> kv in fileParams)
{
string key = kv.Key;
FileItem fileItem = kv.Value;
if (!fileItem.IsValid())
{
throw new ArgumentException("FileItem is invalid");
}
string fileEntry = string.Format(fileTemplate, key, fileItem.GetFileName(), fileItem.GetMimeType());
byte[] itemBytes = Encoding.UTF8.GetBytes(fileEntry);
reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
reqStream.Write(itemBytes, 0, itemBytes.Length);
fileItem.Write(reqStream);
}
reqStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
reqStream.Close();
HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
Encoding encoding = GetResponseEncoding(rsp);
return GetResponseAsString(rsp, encoding);
}
/// <summary>
/// 執行帶body體的POST請求。
/// </summary>
/// <param name="url">請求地址，含URL參數</param>
/// <param name="body">請求body體字節流</param>
/// <param name="contentType">body內容類型</param>
/// <param name="headerParams">請求頭部參數</param>
/// <returns>HTTP響應</returns>
public string DoPost(string url, byte[] body, string contentType, IDictionary<string, string> headerParams)
{
HttpWebRequest req = GetWebRequest(url, "POST", headerParams);
req.ContentType = contentType;
if (body != null)
{
System.IO.Stream reqStream = req.GetRequestStream();
reqStream.Write(body, 0, body.Length);
reqStream.Close();
}
HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
Encoding encoding = GetResponseEncoding(rsp);
return GetResponseAsString(rsp, encoding);
}
public HttpWebRequest GetWebRequest(string url, string method, IDictionary<string, string> headerParams)
{
HttpWebRequest req = null;
if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
{
if (this._ignoreSSLCheck)
{
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(TrustAllValidationCallback);
}
req = (HttpWebRequest)WebRequest.CreateDefault(new Uri(url));
}
else
{
req = (HttpWebRequest)WebRequest.Create(url);
}
if (this._disableWebProxy)
{
req.Proxy = null;
}
if (headerParams != null && headerParams.Count > 0)
{
foreach (string key in headerParams.Keys)
{
req.Headers.Add(key, headerParams[key]);
}
}
req.ServicePoint.Expect100Continue = false;
req.Method = method;
req.KeepAlive = true;
req.UserAgent = "top-sdk-net";
req.Accept = "text/xml,text/javascript";
req.Timeout = this._timeout;
req.ReadWriteTimeout = this._readWriteTimeout;
return req;
}
/// <summary>
/// 把響應流轉換為文本。
/// </summary>
/// <param name="rsp">響應流對象</param>
/// <param name="encoding">編碼方式</param>
/// <returns>響應文本</returns>
public string GetResponseAsString(HttpWebResponse rsp, Encoding encoding)
{
Stream stream = null;
StreamReader reader = null;
try
{
// 以字符流的方式讀取HTTP響應
stream = rsp.GetResponseStream();
if (Constants.CONTENT_ENCODING_GZIP.Equals(rsp.ContentEncoding, StringComparison.OrdinalIgnoreCase))
{
stream = new GZipStream(stream, CompressionMode.Decompress);
}
reader = new StreamReader(stream, encoding);
return reader.ReadToEnd();
}
finally
{
// 釋放資源
if (reader != null) reader.Close();
if (stream != null) stream.Close();
if (rsp != null) rsp.Close();
}
}
/// <summary>
/// 組裝含參數的請求URL。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="parameters">請求參數映射</param>
/// <returns>帶參數的請求URL</returns>
public static string BuildRequestUrl(string url, IDictionary<string, string> parameters)
{
if (parameters != null && parameters.Count > 0)
{
return BuildRequestUrl(url, BuildQuery(parameters));
}
return url;
}
/// <summary>
/// 組裝含參數的請求URL。
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="queries">一個或多個經過URL編碼后的請求參數串</param>
/// <returns>帶參數的請求URL</returns>
public static string BuildRequestUrl(string url, params string[] queries)
{
if (queries == null || queries.Length == 0)
{
return url;
}
StringBuilder newUrl = new StringBuilder(url);
bool hasQuery = url.Contains("?");
bool hasPrepend = url.EndsWith("?") || url.EndsWith("&");
foreach (string query in queries)
{
if (!string.IsNullOrEmpty(query))
{
if (!hasPrepend)
{
if (hasQuery)
{
newUrl.Append("&");
}
else
{
newUrl.Append("?");
hasQuery = true;
}
}
newUrl.Append(query);
hasPrepend = false;
}
}
return newUrl.ToString();
}
/// <summary>
/// 組裝普通文本請求參數。
/// </summary>
/// <param name="parameters">Key-Value形式請求參數字典</param>
/// <returns>URL編碼后的請求數據</returns>
public static string BuildQuery(IDictionary<string, string> parameters)
{
if (parameters == null || parameters.Count == 0)
{
return null;
}
StringBuilder query = new StringBuilder();
bool hasParam = false;
foreach (KeyValuePair<string, string> kv in parameters)
{
string name = kv.Key;
string value = kv.Value;
// 忽略參數名或參數值為空的參數
if (!string.IsNullOrEmpty(name) && !string.IsNullOrEmpty(value))
{
if (hasParam)
{
query.Append("&");
}
query.Append(name);
query.Append("=");
query.Append(HttpUtility.UrlEncode(value, Encoding.UTF8));
hasParam = true;
}
}
return query.ToString();
}
private Encoding GetResponseEncoding(HttpWebResponse rsp)
{
string charset = rsp.CharacterSet;
if (string.IsNullOrEmpty(charset))
{
charset = Constants.CHARSET_UTF8;
}
return Encoding.GetEncoding(charset);
}
private static bool TrustAllValidationCallback(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
{
return true; // 忽略SSL證書檢查
}
}
public class Constants
{
public const string CONTENT_ENCODING_GZIP = "gzip";
public const string CHARSET_UTF8 = "utf-8";
public const string CTYPE_DEFAULT = "application/octet-stream";
public const int READ_BUFFER_SIZE = 1024 * 4;
}
/// <summary>
/// 文件元數據。
/// 可以使用以下幾種構造方法：
/// 本地路徑：new FileItem("C:/temp.jpg");
/// 本地文件：new FileItem(new FileInfo("C:/temp.jpg"));
/// 字節數組：new FileItem("abc.jpg", bytes);
/// 輸入流：new FileItem("abc.jpg", stream);
/// </summary>
public class FileItem
{
private Contract contract;
/// <summary>
/// 基於本地文件的構造器。
/// </summary>
/// <param name="fileInfo">本地文件</param>
public FileItem(FileInfo fileInfo)
{
this.contract = new LocalContract(fileInfo);
}
/// <summary>
/// 基於本地文件全路徑的構造器。
/// </summary>
/// <param name="filePath">本地文件全路徑</param>
public FileItem(string filePath)
: this(new FileInfo(filePath))
{
}
/// <summary>
/// 基於文件名和字節數組的構造器。
/// </summary>
/// <param name="fileName">文件名稱（服務端持久化字節數組到磁盤時的文件名）</param>
/// <param name="content">文件字節數組</param>
public FileItem(string fileName, byte[] content)
: this(fileName, content, null)
{
}
/// <summary>
/// 基於文件名、字節數組和媒體類型的構造器。
/// </summary>
/// <param name="fileName">文件名（服務端持久化字節數組到磁盤時的文件名）</param>
/// <param name="content">文件字字節數組</param>
/// <param name="mimeType">媒體類型</param>
public FileItem(string fileName, byte[] content, string mimeType)
{
this.contract = new ByteArrayContract(fileName, content, mimeType);
}
/// <summary>
/// 基於文件名和輸入流的構造器。
/// </summary>
/// <param name="fileName">文件名稱（服務端持久化輸入流到磁盤時的文件名）</param>
/// <param name="content">文件輸入流</param>
public FileItem(string fileName, Stream stream)
: this(fileName, stream, null)
{
}
/// <summary>
/// 基於文件名、輸入流和媒體類型的構造器。
/// </summary>
/// <param name="fileName">文件名（服務端持久化輸入流到磁盤時的文件名）</param>
/// <param name="content">文件輸入流</param>
/// <param name="mimeType">媒體類型</param>
public FileItem(string fileName, Stream stream, string mimeType)
{
this.contract = new StreamContract(fileName, stream, mimeType);
}
public bool IsValid()
{
return this.contract.IsValid();
}
public long GetFileLength()
{
return this.contract.GetFileLength();
}
public string GetFileName()
{
return this.contract.GetFileName();
}
public string GetMimeType()
{
return this.contract.GetMimeType();
}
public void Write(Stream output)
{
this.contract.Write(output);
}
}
internal interface Contract
{
bool IsValid();
string GetFileName();
string GetMimeType();
long GetFileLength();
void Write(Stream output);
}
internal class LocalContract : Contract
{
private FileInfo fileInfo;
public LocalContract(FileInfo fileInfo)
{
this.fileInfo = fileInfo;
}
public long GetFileLength()
{
return this.fileInfo.Length;
}
public string GetFileName()
{
return this.fileInfo.Name;
}
public string GetMimeType()
{
return Constants.CTYPE_DEFAULT;
}
public bool IsValid()
{
return this.fileInfo != null && this.fileInfo.Exists;
}
public void Write(Stream output)
{
using (BufferedStream bfs = new BufferedStream(this.fileInfo.OpenRead()))
{
int n = 0;
byte[] buffer = new byte[Constants.READ_BUFFER_SIZE];
while ((n = bfs.Read(buffer, 0, buffer.Length)) > 0)
{
output.Write(buffer, 0, n);
}
}
}
}
internal class ByteArrayContract : Contract
{
private string fileName;
private byte[] content;
private string mimeType;
public ByteArrayContract(string fileName, byte[] content, string mimeType)
{
this.fileName = fileName;
this.content = content;
this.mimeType = mimeType;
}
public bool IsValid()
{
return this.content != null && this.fileName != null;
}
public long GetFileLength()
{
return this.content.Length;
}
public string GetFileName()
{
return this.fileName;
}
public string GetMimeType()
{
if (string.IsNullOrEmpty(this.mimeType))
{
return Constants.CTYPE_DEFAULT;
}
else
{
return this.mimeType;
}
}
public void Write(Stream output)
{
output.Write(this.content, 0, this.content.Length);
}
}
internal class StreamContract : Contract
{
private string fileName;
private Stream stream;
private string mimeType;
public StreamContract(string fileName, Stream stream, string mimeType)
{
this.fileName = fileName;
this.stream = stream;
this.mimeType = mimeType;
}
public long GetFileLength()
{
return 0L;
}
public string GetFileName()
{
return this.fileName;
}
public string GetMimeType()
{
if (string.IsNullOrEmpty(mimeType))
{
return Constants.CTYPE_DEFAULT;
}
else
{
return this.mimeType;
}
}
public bool IsValid()
{
return this.stream != null && this.fileName != null;
}
public void Write(Stream output)
{
using (this.stream)
{
int n = 0;
byte[] buffer = new byte[Constants.READ_BUFFER_SIZE];
while ((n = this.stream.Read(buffer, 0, buffer.Length)) > 0)
{
output.Write(buffer, 0, n);
}
}
}
}
}