HttpHelper工具类
Posted dangzhenjiuhao
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了HttpHelper工具类相关的知识,希望对你有一定的参考价值。
- /// <summary>
- /// 类说明:HttpHelper类,用来实现Http访问,Post或者Get方式的,直接访问,带Cookie的,带证书的等方式,可以设置代理
- /// 重要提示:请不要自行修改本类,如果因为你自己修改后将无法升级到新版本。如果确实有什么问题请到官方网站提建议,
- /// 我们一定会及时修改
- /// 编码日期:2011-09-20
- /// 编 码 人:苏飞
- /// 联系方式:361983679
- /// 官方网址:http://www.sufeinet.com/thread-3-1-1.html
- /// 修改日期:2015-03-25
- /// 版 本 号:1.4.7
- /// </summary>
- using System;
- using System.Collections.Generic;
- using System.Text;
- using System.Net;
- using System.IO;
- using System.Text.RegularExpressions;
- using System.IO.Compression;
- using System.Security.Cryptography.X509Certificates;
- using System.Net.Security;
- namespace DotNet.Utilities
- {
- /// <summary>
- /// Http连接操作帮助类
- /// </summary>
- public class HttpHelper
- {
- #region 预定义方变量
- //默认的编码
- private Encoding encoding = Encoding.Default;
- //Post数据编码
- private Encoding postencoding = Encoding.Default;
- //HttpWebRequest对象用来发起请求
- private HttpWebRequest request = null;
- //获取影响流的数据对象
- private HttpWebResponse response = null;
- #endregion
- #region Public
- /// <summary>
- /// 根据相传入的数据,得到相应页面数据
- /// </summary>
- /// <param name="item">参数类对象</param>
- /// <returns>返回HttpResult类型</returns>
- public HttpResult GetHtml(HttpItem item)
- {
- //返回参数
- HttpResult result = new HttpResult();
- try
- {
- //准备参数
- SetRequest(item);
- }
- catch (Exception ex)
- {
- result.Cookie = string.Empty;
- result.Header = null;
- result.Html = ex.Message;
- result.StatusDescription = "配置参数时出错:" + ex.Message;
- //配置参数时出错
- return result;
- }
- try
- {
- //请求数据
- using (response = (HttpWebResponse)request.GetResponse())
- {
- GetData(item, result);
- }
- }
- catch (WebException ex)
- {
- if (ex.Response != null)
- {
- using (response = (HttpWebResponse)ex.Response)
- {
- GetData(item, result);
- }
- }
- else
- {
- result.Html = ex.Message;
- }
- }
- catch (Exception ex)
- {
- result.Html = ex.Message;
- }
- if (item.IsToLower) result.Html = result.Html.ToLower();
- return result;
- }
- #endregion
- #region GetData
- /// <summary>
- /// 获取数据的并解析的方法
- /// </summary>
- /// <param name="item"></param>
- /// <param name="result"></param>
- private void GetData(HttpItem item, HttpResult result)
- {
- #region base
- //获取StatusCode
- result.StatusCode = response.StatusCode;
- //获取StatusDescription
- result.StatusDescription = response.StatusDescription;
- //获取Headers
- result.Header = response.Headers;
- //获取CookieCollection
- if (response.Cookies != null) result.CookieCollection = response.Cookies;
- //获取set-cookie
- if (response.Headers["set-cookie"] != null) result.Cookie = response.Headers["set-cookie"];
- #endregion
- #region byte
- //处理网页Byte
- byte[] ResponseByte = GetByte();
- #endregion
- #region Html
- if (ResponseByte != null & ResponseByte.Length > 0)
- {
- //设置编码
- SetEncoding(item, result, ResponseByte);
- //得到返回的HTML
- result.Html = encoding.GetString(ResponseByte);
- }
- else
- {
- //没有返回任何Html代码
- result.Html = string.Empty;
- }
- #endregion
- }
- /// <summary>
- /// 设置编码
- /// </summary>
- /// <param name="item">HttpItem</param>
- /// <param name="result">HttpResult</param>
- /// <param name="ResponseByte">byte[]</param>
- private void SetEncoding(HttpItem item, HttpResult result, byte[] ResponseByte)
- {
- //是否返回Byte类型数据
- if (item.ResultType == ResultType.Byte) result.ResultByte = ResponseByte;
- //从这里开始我们要无视编码了
- if (encoding == null)
- {
- Match meta = Regex.Match(Encoding.Default.GetString(ResponseByte), "<meta[^<]*charset=([^<]*)[\"‘]", RegexOptions.IgnoreCase);
- string c = string.Empty;
- if (meta != null && meta.Groups.Count > 0)
- {
- c = meta.Groups[1].Value.ToLower().Trim();
- }
- if (c.Length > 2)
- {
- try
- {
- encoding = Encoding.GetEncoding(c.Replace("\"", string.Empty).Replace("‘", "").Replace(";", "").Replace("iso-8859-1", "gbk").Trim());
- }
- catch
- {
- if (string.IsNullOrEmpty(response.CharacterSet))
- {
- encoding = Encoding.UTF8;
- }
- else
- {
- encoding = Encoding.GetEncoding(response.CharacterSet);
- }
- }
- }
- else
- {
- if (string.IsNullOrEmpty(response.CharacterSet))
- {
- encoding = Encoding.UTF8;
- }
- else
- {
- encoding = Encoding.GetEncoding(response.CharacterSet);
- }
- }
- }
- }
- /// <summary>
- /// 提取网页Byte
- /// </summary>
- /// <returns></returns>
- private byte[] GetByte()
- {
- byte[] ResponseByte = null;
- MemoryStream _stream = new MemoryStream();
- //GZIIP处理
- if (response.ContentEncoding != null && response.ContentEncoding.Equals("gzip", StringComparison.InvariantCultureIgnoreCase))
- {
- //开始读取流并设置编码方式
- _stream = GetMemoryStream(new GZipStream(response.GetResponseStream(), CompressionMode.Decompress));
- }
- else
- {
- //开始读取流并设置编码方式
- _stream = GetMemoryStream(response.GetResponseStream());
- }
- //获取Byte
- ResponseByte = _stream.ToArray();
- _stream.Close();
- return ResponseByte;
- }
- /// <summary>
- /// 4.0以下.net版本取数据使用
- /// </summary>
- /// <param name="streamResponse">流</param>
- private MemoryStream GetMemoryStream(Stream streamResponse)
- {
- MemoryStream _stream = new MemoryStream();
- int Length = 256;
- Byte[] buffer = new Byte[Length];
- int bytesRead = streamResponse.Read(buffer, 0, Length);
- while (bytesRead > 0)
- {
- _stream.Write(buffer, 0, bytesRead);
- bytesRead = streamResponse.Read(buffer, 0, Length);
- }
- return _stream;
- }
- #endregion
- #region SetRequest
- /// <summary>
- /// 为请求准备参数
- /// </summary>
- ///<param name="item">参数列表</param>
- private void SetRequest(HttpItem item)
- {
- // 验证证书
- SetCer(item);
- //设置Header参数
- if (item.Header != null && item.Header.Count > 0) foreach (string key in item.Header.AllKeys)
- {
- request.Headers.Add(key, item.Header[key]);
- }
- // 设置代理
- SetProxy(item);
- if (item.ProtocolVersion != null) request.ProtocolVersion = item.ProtocolVersion;
- request.ServicePoint.Expect100Continue = item.Expect100Continue;
- //请求方式Get或者Post
- request.Method = item.Method;
- request.Timeout = item.Timeout;
- request.KeepAlive = item.KeepAlive;
- request.ReadWriteTimeout = item.ReadWriteTimeout;
- if (item.IfModifiedSince != null) request.IfModifiedSince = Convert.ToDateTime(item.IfModifiedSince);
- //Accept
- request.Accept = item.Accept;
- //ContentType返回类型
- request.ContentType = item.ContentType;
- //UserAgent客户端的访问类型,包括浏览器版本和操作系统信息
- request.UserAgent = item.UserAgent;
- // 编码
- encoding = item.Encoding;
- //设置安全凭证
- request.Credentials = item.ICredentials;
- //设置Cookie
- SetCookie(item);
- //来源地址
- request.Referer = item.Referer;
- //是否执行跳转功能
- request.AllowAutoRedirect = item.Allowautoredirect;
- if (item.MaximumAutomaticRedirections > 0)
- {
- request.MaximumAutomaticRedirections = item.MaximumAutomaticRedirections;
- }
- //设置Post数据
- SetPostData(item);
- //设置最大连接
- if (item.Connectionlimit > 0) request.ServicePoint.ConnectionLimit = item.Connectionlimit;
- }
- /// <summary>
- /// 设置证书
- /// </summary>
- /// <param name="item"></param>
- private void SetCer(HttpItem item)
- {
- if (!string.IsNullOrEmpty(item.CerPath))
- {
- //这一句一定要写在创建连接的前面。使用回调的方法进行证书验证。
- ServicePointManager.ServerCertificateValidationCallback = new System.Net.Security.RemoteCertificateValidationCallback(CheckValidationResult);
- //初始化对像,并设置请求的URL地址
- request = (HttpWebRequest)WebRequest.Create(item.URL);
- SetCerList(item);
- //将证书添加到请求里
- request.ClientCertificates.Add(new X509Certificate(item.CerPath));
- }
- else
- {
- //初始化对像,并设置请求的URL地址
- request = (HttpWebRequest)WebRequest.Create(item.URL);
- SetCerList(item);
- }
- }
- /// <summary>
- /// 设置多个证书
- /// </summary>
- /// <param name="item"></param>
- private void SetCerList(HttpItem item)
- {
- if (item.ClentCertificates != null && item.ClentCertificates.Count > 0)
- {
- foreach (X509Certificate c in item.ClentCertificates)
- {
- request.ClientCertificates.Add(c);
- }
- }
- }
- /// <summary>
- /// 设置Cookie
- /// </summary>
- /// <param name="item">Http参数</param>
- private void SetCookie(HttpItem item)
- {
- if (!string.IsNullOrEmpty(item.Cookie)) request.Headers[HttpRequestHeader.Cookie] = item.Cookie;
- //设置CookieCollection
- if (item.ResultCookieType == ResultCookieType.CookieCollection)
- {
- request.CookieContainer = new CookieContainer();
- if (item.CookieCollection != null && item.CookieCollection.Count > 0)
- request.CookieContainer.Add(item.CookieCollection);
- }
- }
- /// <summary>
- /// 设置Post数据
- /// </summary>
- /// <param name="item">Http参数</param>
- private void SetPostData(HttpItem item)
- {
- //验证在得到结果时是否有传入数据
- if (!request.Method.Trim().ToLower().Contains("get"))
- {
- if (item.PostEncoding != null)
- {
- postencoding = item.PostEncoding;
- }
- byte[] buffer = null;
- //写入Byte类型
- if (item.PostDataType == PostDataType.Byte && item.PostdataByte != null && item.PostdataByte.Length > 0)
- {
- //验证在得到结果时是否有传入数据
- buffer = item.PostdataByte;
- }//写入文件
- else if (item.PostDataType == PostDataType.FilePath && !string.IsNullOrEmpty(item.Postdata))
- {
- StreamReader r = new StreamReader(item.Postdata, postencoding);
- buffer = postencoding.GetBytes(r.ReadToEnd());
- r.Close();
- } //写入字符串
- else if (!string.IsNullOrEmpty(item.Postdata))
- {
- buffer = postencoding.GetBytes(item.Postdata);
- }
- if (buffer != null)
- {
- request.ContentLength = buffer.Length;
- request.GetRequestStream().Write(buffer, 0, buffer.Length);
- }
- }
- }
- /// <summary>
- /// 设置代理
- /// </summary>
- /// <param name="item">参数对象</param>
- private void SetProxy(HttpItem item)
- {
- bool isIeProxy = false;
- if (!string.IsNullOrEmpty(item.ProxyIp))
- {
- isIeProxy = item.ProxyIp.ToLower().Contains("ieproxy");
- }
- if (!string.IsNullOrEmpty(item.ProxyIp) && !isIeProxy)
- {
- //设置代理服务器
- if (item.ProxyIp.Contains(":"))
- {
- string[] plist = item.ProxyIp.Split(‘:‘);
- WebProxy myProxy = new WebProxy(plist[0].Trim(), Convert.ToInt32(plist[1].Trim()));
- //建议连接
- myProxy.Credentials = new NetworkCredential(item.ProxyUserName, item.ProxyPwd);
- //给当前请求对象
- request.Proxy = myProxy;
- }
- else
- {
- WebProxy myProxy = new WebProxy(item.ProxyIp, false);
- //建议连接
- myProxy.Credentials = new NetworkCredential(item.ProxyUserName, item.ProxyPwd);
- //给当前请求对象
- request.Proxy = myProxy;
- }
- }
- else if (isIeProxy)
- {
- //设置为IE代理
- }
- else
- {
- request.Proxy = item.WebProxy;
- }
- }
- #endregion
- #region private main
- /// <summary>
- /// 回调验证证书问题
- /// </summary>
- /// <param name="sender">流对象</param>
- /// <param name="certificate">证书</param>
- /// <param name="chain">X509Chain</param>
- /// <param name="errors">SslPolicyErrors</param>
- /// <returns>bool</returns>
- private bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) { return true; }
- #endregion
- }
- /// <summary>
以上是关于HttpHelper工具类的主要内容,如果未能解决你的问题,请参考以下文章