ahjesus HttpQuery

  1     /// <summary>  
  2     /// 有关HTTP请求的辅助类  
  3     /// </summary>  
  4     public class HttpQuery
  5     {
  6         private static readonly string DefaultUserAgent =
  7             "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)";
  8 
  9         public static void Get(string url, object data, Action<string> callback)
 10         {
 11             IDictionary<string, string> parameters = Getparameters(data);
 12 
 13             if (!(parameters == null || parameters.Count == 0))
 14             {
 15                 url += "?";
 16                 foreach (var item in parameters)
 17                 {
 18                     url += item.Key + "=" + item.Value + "&";
 19                 }
 20             }
 21             CreateGetHttpResponse(url, null, null, null, callback);
 22         }
 23 
 24         public static void Post(string url, object data, Action<string> callback)
 25         {
 26             IDictionary<string, string> parameters = Getparameters(data);
 27 
 28             CreatePostHttpResponse(url, parameters, null, null, Encoding.UTF8, null, callback);
 29         }
 30 
 31         public static void Post(string url, string data, Action<string> callback)
 32         {
 33             CreatePostHttpResponse(url, data, null, null, Encoding.UTF8, null, callback);
 34         }
 35 
 36         private static IDictionary<string, string> Getparameters(object data)
 37         {
 38             if (data == null)
 39             {
 40                 return new Dictionary<string, string>();
 41             }
 42             IDictionary<string, string> parameters = new Dictionary<string, string>();
 43 
 44             Type type = data.GetType();
 45             PropertyInfo[] props = type.GetProperties(BindingFlags.Public | BindingFlags.Instance);
 46             foreach (PropertyInfo p in props)
 47             {
 48                 parameters.Add(p.Name, p.GetValue(data).ToString());
 49             }
 50 
 51             return parameters;
 52         }
 53 
 54         /// <summary>  
 55         /// 创建GET方式的HTTP请求  
 56         /// </summary>  
 57         /// <param name="url">请求的URL</param>  
 58         /// <param name="timeout">请求的超时时间</param>  
 59         /// <param name="userAgent">请求的客户端浏览器信息，可以为空</param>  
 60         /// <param name="cookies">随同HTTP请求发送的Cookie信息，如果不需要身份验证可以为空</param>  
 61         /// <returns></returns>  
 62         private static HttpWebResponse CreateGetHttpResponse(string url, int? timeout, string userAgent,
 63             CookieCollection cookies, Action<string> callback, string encoding = "utf-8")
 64         {
 65             if (string.IsNullOrEmpty(url))
 66             {
 67                 return null;
 68                 //throw new ArgumentNullException("url");
 69             }
 70             try
 71             {
 72                 HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
 73                 request.Method = "GET";
 74                 request.UserAgent = DefaultUserAgent;
 75                 if (!string.IsNullOrEmpty(userAgent))
 76                 {
 77                     request.UserAgent = userAgent;
 78                 }
 79                 if (timeout.HasValue)
 80                 {
 81                     request.Timeout = timeout.Value;
 82                 }
 83                 if (cookies != null)
 84                 {
 85                     request.CookieContainer = new CookieContainer();
 86                     request.CookieContainer.Add(cookies);
 87                 }
 88 
 89                 HttpWebResponse httpWebResponse = request.GetResponse() as HttpWebResponse;
 90 
 91                 StreamReader reader = new StreamReader(httpWebResponse.GetResponseStream(),
 92                     System.Text.Encoding.GetEncoding(encoding));
 93 
 94                 string html = "";
 95                 //获取请求到的数据
 96                 html = reader.ReadToEnd();
 97                 //关闭
 98                 httpWebResponse.Close();
 99                 reader.Close();
100 
101                 Regex regex = new Regex("charset=(?<code>\\w+)\"");
102                 Match match = regex.Match(html);
103                 string code = match.Groups["code"].Value;
104                 if (!string.IsNullOrWhiteSpace(code) && code.ToLower() != encoding.ToLower())
105                 {
106                     return CreateGetHttpResponse(url, timeout, userAgent, cookies, callback, code);
107                 }
108                 else
109                 {
110                     callback(html);
111                     return httpWebResponse;
112                 }
113             }
114             catch
115             {
116                 callback(null);
117             }
118             return null;
119         }
120 
121         /// <summary>  
122         /// 创建POST方式的HTTP请求  
123         /// </summary>  
124         /// <param name="url">请求的URL</param>  
125         /// <param name="parameters">随同请求POST的参数名称及参数值字典</param>  
126         /// <param name="timeout">请求的超时时间</param>  
127         /// <param name="userAgent">请求的客户端浏览器信息，可以为空</param>  
128         /// <param name="requestEncoding">发送HTTP请求时所用的编码</param>  
129         /// <param name="cookies">随同HTTP请求发送的Cookie信息，如果不需要身份验证可以为空</param>  
130         /// <returns></returns>  
131         private static HttpWebResponse CreatePostHttpResponse(string url, IDictionary<string, string> parameters,
132             int? timeout, string userAgent, Encoding requestEncoding, CookieCollection cookies, Action<string> callback)
133         {
134             if (string.IsNullOrEmpty(url))
135             {
136                 throw new ArgumentNullException("url");
137             }
138             if (requestEncoding == null)
139             {
140                 throw new ArgumentNullException("requestEncoding");
141             }
142             HttpWebRequest request = null;
143             try
144             {
145                 //如果是发送HTTPS请求  
146                 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
147                 {
148                     ServicePointManager.ServerCertificateValidationCallback =
149                         new RemoteCertificateValidationCallback(CheckValidationResult);
150                     request = WebRequest.Create(url) as HttpWebRequest;
151                     request.ProtocolVersion = HttpVersion.Version10;
152                 }
153                 else
154                 {
155                     request = WebRequest.Create(url) as HttpWebRequest;
156                 }
157                 request.Method = "POST";
158                 request.ContentType = "application/x-www-form-urlencoded";
159 
160                 if (!string.IsNullOrEmpty(userAgent))
161                 {
162                     request.UserAgent = userAgent;
163                 }
164                 else
165                 {
166                     request.UserAgent = DefaultUserAgent;
167                 }
168 
169                 if (timeout.HasValue)
170                 {
171                     request.Timeout = timeout.Value;
172                 }
173                 if (cookies != null)
174                 {
175                     request.CookieContainer = new CookieContainer();
176                     request.CookieContainer.Add(cookies);
177                 }
178                 //如果需要POST数据  
179                 if (!(parameters == null || parameters.Count == 0))
180                 {
181                     StringBuilder buffer = new StringBuilder();
182                     int i = 0;
183                     foreach (string key in parameters.Keys)
184                     {
185                         if (i > 0)
186                         {
187                             buffer.AppendFormat("&{0}={1}", key, parameters[key]);
188                         }
189                         else
190                         {
191                             buffer.AppendFormat("{0}={1}", key, parameters[key]);
192                         }
193                         i++;
194                     }
195                     byte[] data = requestEncoding.GetBytes(buffer.ToString());
196                     using (Stream stream = request.GetRequestStream())
197                     {
198                         stream.Write(data, 0, data.Length);
199                     }
200                 }
201 
202                 HttpWebResponse httpWebResponse = request.GetResponse() as HttpWebResponse;
203 
204                 StreamReader reader = new StreamReader(httpWebResponse.GetResponseStream(),
205                     System.Text.Encoding.GetEncoding("utf-8"));
206 
207                 string html = "";
208                 //获取请求到的数据
209                 html = reader.ReadToEnd();
210 
211                 //关闭
212                 httpWebResponse.Close();
213                 reader.Close();
214 
215                 callback(html);
216 
217                 return httpWebResponse;
218             }
219             catch
220             {
221                 callback(null);
222             }
223             return null;
224         }
225 
226         private static HttpWebResponse CreatePostHttpResponse(string url, string parameters, int? timeout,
227             string userAgent, Encoding requestEncoding, CookieCollection cookies, Action<string> callback)
228         {
229             if (string.IsNullOrEmpty(url))
230             {
231                 return null;
232                 //throw new ArgumentNullException("url");
233             }
234             if (requestEncoding == null)
235             {
236                 throw new ArgumentNullException("requestEncoding");
237             }
238             HttpWebRequest request = null;
239             try
240             {
241                 //如果是发送HTTPS请求  
242                 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
243                 {
244                     ServicePointManager.ServerCertificateValidationCallback =
245                         new RemoteCertificateValidationCallback(CheckValidationResult);
246                     request = WebRequest.Create(url) as HttpWebRequest;
247                     request.ProtocolVersion = HttpVersion.Version10;
248                 }
249                 else
250                 {
251                     request = WebRequest.Create(url) as HttpWebRequest;
252                 }
253                 request.Method = "POST";
254                 request.ContentType = "application/x-www-form-urlencoded";
255 
256                 if (!string.IsNullOrEmpty(userAgent))
257                 {
258                     request.UserAgent = userAgent;
259                 }
260                 else
261                 {
262                     request.UserAgent = DefaultUserAgent;
263                 }
264 
265                 if (timeout.HasValue)
266                 {
267                     request.Timeout = timeout.Value;
268                 }
269                 if (cookies != null)
270                 {
271                     request.CookieContainer = new CookieContainer();
272                     request.CookieContainer.Add(cookies);
273                 }
274                 //如果需要POST数据  
275                 if (!string.IsNullOrEmpty(parameters))
276                 {
277                     using (var streamWriter = new StreamWriter(request.GetRequestStream()))
278                     {
279                         streamWriter.Write(parameters);
280                         streamWriter.Flush();
281                     }
282                 }
283 
284                 HttpWebResponse httpWebResponse = request.GetResponse() as HttpWebResponse;
285 
286                 StreamReader reader = new StreamReader(httpWebResponse.GetResponseStream(),
287                     System.Text.Encoding.GetEncoding("utf-8"));
288 
289                 string html = "";
290                 //获取请求到的数据
291                 html = reader.ReadToEnd();
292 
293                 //关闭
294                 httpWebResponse.Close();
295                 reader.Close();
296 
297                 callback(html);
298 
299                 return httpWebResponse;
300             }
301             catch
302             {
303                 callback(null);
304             }
305             return null;
306         }
307 
308         private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain,
309             SslPolicyErrors errors)
310         {
311             return true; //总是接受  
312         }
313 
314     }