HttpWebRequest HttpClient
2018-06-17 22:46:50来源:未知 阅读 ()
HttpWebRequest HttpClient 简单封装使用,支持https
HttpWebRequest
1 using System; 2 using System.Collections.Generic; 3 using System.IO; 4 using System.IO.Compression; 5 using System.Linq; 6 using System.Net; 7 using System.Net.Security; 8 using System.Security.Cryptography.X509Certificates; 9 using System.Text; 10 using TT.Utilities.Extends; 11 12 namespace TT.Utilities.Web 13 { 14 public class HttpRequest 15 { 16 public static HttpWebRequest CreateHttpWebRequest(string url) 17 { 18 HttpWebRequest request; 19 //如果是发送HTTPS请求 20 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase)) 21 { 22 //ServicePointManager.DefaultConnectionLimit = 1000; 23 ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult); 24 request = WebRequest.Create(url) as HttpWebRequest; 25 request.ProtocolVersion = HttpVersion.Version11; 26 } 27 else 28 { 29 request = WebRequest.Create(url) as HttpWebRequest; 30 } 31 request.Proxy = null; 32 request.Headers.Add(HttpRequestHeader.AcceptEncoding, "gzip,deflate"); 33 return request; 34 } 35 36 /// <summary> 37 /// 38 /// </summary> 39 /// <param name="url">url</param> 40 /// <param name="dic">参数</param> 41 /// <param name="headerDic">请求头参数</param> 42 /// <returns></returns> 43 public static string DoPost(string url, Dictionary<string, string> dic, Dictionary<string, string> headerDic) 44 { 45 HttpWebRequest request = CreateHttpWebRequest(url); 46 request.Method = "POST"; 47 request.Accept = "*/*"; 48 request.ContentType = HttpContentTypes.GetContentType(HttpContentTypes.HttpContentTypeEnum.JSON); 49 if (headerDic != null && headerDic.Count > 0) 50 { 51 foreach (var item in headerDic) 52 { 53 request.Headers.Add(item.Key, item.Value); 54 } 55 } 56 if (dic != null && dic.Count > 0) 57 { 58 var jsonStr = Newtonsoft.Json.JsonConvert.SerializeObject(dic); 59 byte[] buffer = Encoding.UTF8.GetBytes(jsonStr); 60 request.ContentLength = buffer.Length; 61 try 62 { 63 request.GetRequestStream().Write(buffer, 0, buffer.Length); 64 } 65 catch (WebException ex) 66 { 67 throw ex; 68 } 69 } 70 else 71 { 72 request.ContentLength = 0; 73 } 74 return HttpResponse(request); 75 } 76 77 public static string DoPost(string url, Dictionary<string, string> dic) 78 { 79 return DoPost(url, dic, null); 80 } 81 82 static object olock = new object(); 83 public static string HttpResponse(HttpWebRequest request) 84 { 85 try 86 { 87 //lock (olock) 88 //{ 89 using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) 90 { 91 var contentEncodeing = response.ContentEncoding.ToLower(); 92 93 if (!contentEncodeing.Contains("gzip") && !contentEncodeing.Contains("deflate")) 94 { 95 using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8)) 96 { 97 return reader.ReadToEnd(); 98 } 99 } 100 else 101 { 102 #region gzip,deflate 压缩解压 103 if (contentEncodeing.Contains("gzip")) 104 { 105 using (GZipStream stream = new GZipStream(response.GetResponseStream(), CompressionMode.Decompress)) 106 { 107 using (StreamReader reader = new StreamReader(stream)) 108 { 109 return reader.ReadToEnd(); 110 } 111 } 112 } 113 else //if (contentEncodeing.Contains("deflate")) 114 { 115 using (DeflateStream stream = new DeflateStream(response.GetResponseStream(), CompressionMode.Decompress)) 116 { 117 using (StreamReader reader = new StreamReader(stream)) 118 { 119 return reader.ReadToEnd(); 120 } 121 } 122 } 123 #endregion gzip,deflate 压缩解压 124 } 125 } 126 //} 127 } 128 catch (WebException ex) 129 { 130 throw ex; 131 } 132 } 133 134 public static string DoGet(string url, Dictionary<string, string> dic) 135 { 136 try 137 { 138 var argStr = dic == null ? "" : dic.ToSortUrlParamString(); 139 argStr = string.IsNullOrEmpty(argStr) ? "" : ("?" + argStr); 140 HttpWebRequest request = CreateHttpWebRequest(url + argStr); 141 request.Method = "GET"; 142 request.ContentType = "application/json"; 143 using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) 144 { 145 using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8)) 146 { 147 return reader.ReadToEnd(); 148 } 149 } 150 } 151 catch (Exception ex) 152 { 153 throw ex; 154 } 155 } 156 157 public static string DoGet(string url, Dictionary<string, string> dic, Dictionary<string, string> headerDic) 158 { 159 try 160 { 161 var argStr = dic == null ? "" : dic.ToSortUrlParamString(); 162 argStr = string.IsNullOrEmpty(argStr) ? "" : ("?" + argStr); 163 HttpWebRequest request = CreateHttpWebRequest(url + argStr); 164 request.Method = "GET"; 165 request.ContentType = "application/json"; 166 foreach (var item in headerDic) 167 { 168 request.Headers.Add(item.Key, item.Value); 169 } 170 using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) 171 { 172 using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8)) 173 { 174 return reader.ReadToEnd(); 175 } 176 } 177 } 178 catch (Exception ex) 179 { 180 throw ex; 181 } 182 } 183 184 private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) 185 { 186 return true; //总是接受 187 } 188 } 189 }
加入request timeout
1 using System; 2 using System.Collections.Generic; 3 using System.IO; 4 using System.IO.Compression; 5 using System.Linq; 6 using System.Net; 7 using System.Net.Security; 8 using System.Security.Cryptography.X509Certificates; 9 using System.Text; 10 using TT.Utilities.Extends; 11 12 namespace TT.Utilities.Web 13 { 14 public class HttpRequest 15 { 16 public static HttpWebRequest CreateHttpWebRequest(string url, int timeoutSecond = 90) 17 { 18 HttpWebRequest request; 19 //如果是发送HTTPS请求 20 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase)) 21 { 22 //ServicePointManager.DefaultConnectionLimit = 1000; 23 ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult); 24 request = WebRequest.Create(url) as HttpWebRequest; 25 request.ProtocolVersion = HttpVersion.Version11; 26 } 27 else 28 { 29 request = WebRequest.Create(url) as HttpWebRequest; 30 } 31 request.Proxy = null; 32 request.Headers.Add(HttpRequestHeader.AcceptEncoding, "gzip,deflate"); 33 request.Timeout = timeoutSecond * 1000; 34 return request; 35 } 36 37 /// <summary> 38 /// 39 /// </summary> 40 /// <param name="url">url</param> 41 /// <param name="dic">参数</param> 42 /// <param name="headerDic">请求头参数</param> 43 /// <returns></returns> 44 public static string DoPost(string url, Dictionary<string, string> dic, Dictionary<string, string> headerDic, int timeoutSecond = 90) 45 { 46 HttpWebRequest request = CreateHttpWebRequest(url, timeoutSecond); 47 request.Method = "POST"; 48 request.Accept = "*/*"; 49 request.ContentType = HttpContentTypes.GetContentType(HttpContentTypes.HttpContentTypeEnum.JSON); 50 if (headerDic != null && headerDic.Count > 0) 51 { 52 foreach (var item in headerDic) 53 { 54 request.Headers.Add(item.Key, item.Value); 55 } 56 } 57 if (dic != null && dic.Count > 0) 58 { 59 var jsonStr = Newtonsoft.Json.JsonConvert.SerializeObject(dic); 60 byte[] buffer = Encoding.UTF8.GetBytes(jsonStr); 61 request.ContentLength = buffer.Length; 62 try 63 { 64 request.GetRequestStream().Write(buffer, 0, buffer.Length); 65 } 66 catch (WebException ex) 67 { 68 throw ex; 69 } 70 } 71 else 72 { 73 request.ContentLength = 0; 74 } 75 return HttpResponse(request); 76 } 77 78 public static string DoPost(string url, Dictionary<string, string> dic, int timeoutSecond = 90) 79 { 80 return DoPost(url, dic, null, timeoutSecond); 81 } 82 83 static object olock = new object(); 84 public static string HttpResponse(HttpWebRequest request) 85 { 86 try 87 { 88 //lock (olock) 89 //{ 90 using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) 91 { 92 var contentEncodeing = response.ContentEncoding.ToLower(); 93 94 if (!contentEncodeing.Contains("gzip") && !contentEncodeing.Contains("deflate")) 95 { 96 using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8)) 97 { 98 return reader.ReadToEnd(); 99 } 100 } 101 else 102 { 103 #region gzip,deflate 压缩解压 104 if (contentEncodeing.Contains("gzip")) 105 { 106 using (GZipStream stream = new GZipStream(response.GetResponseStream(), CompressionMode.Decompress)) 107 { 108 using (StreamReader reader = new StreamReader(stream)) 109 { 110 return reader.ReadToEnd(); 111 } 112 } 113 } 114 else //if (contentEncodeing.Contains("deflate")) 115 { 116 using (DeflateStream stream = new DeflateStream(response.GetResponseStream(), CompressionMode.Decompress)) 117 { 118 using (StreamReader reader = new StreamReader(stream)) 119 { 120 return reader.ReadToEnd(); 121 } 122 } 123 } 124 #endregion gzip,deflate 压缩解压 125 } 126 } 127 //} 128 } 129 catch (WebException ex) 130 { 131 throw ex; 132 } 133 } 134 135 public static string DoGet(string url, Dictionary<string, string> dic, int timeoutSecond = 90) 136 { 137 try 138 { 139 var argStr = dic == null ? "" : dic.ToSortUrlParamString(); 140 argStr = string.IsNullOrEmpty(argStr) ? "" : ("?" + argStr); 141 HttpWebRequest request = CreateHttpWebRequest(url + argStr, timeoutSecond); 142 request.Method = "GET"; 143 request.ContentType = "application/json"; 144 using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) 145 { 146 using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8)) 147 { 148 return reader.ReadToEnd(); 149 } 150 } 151 } 152 catch (Exception ex) 153 { 154 throw ex; 155 } 156 } 157 158 public static string DoGet(string url, Dictionary<string, string> dic, Dictionary<string, string> headerDic, int timeoutSecond = 90) 159 { 160 try 161 { 162 var argStr = dic == null ? "" : dic.ToSortUrlParamString(); 163 argStr = string.IsNullOrEmpty(argStr) ? "" : ("?" + argStr); 164 HttpWebRequest request = CreateHttpWebRequest(url + argStr, timeoutSecond); 165 request.Method = "GET"; 166 request.ContentType = "application/json"; 167 foreach (var item in headerDic) 168 { 169 request.Headers.Add(item.Key, item.Value); 170 } 171 using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) 172 { 173 using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8)) 174 { 175 return reader.ReadToEnd(); 176 } 177 } 178 } 179 catch (Exception ex) 180 { 181 throw ex; 182 } 183 } 184 185 private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) 186 { 187 return true; //总是接受 188 } 189 } 190 }
HttpClient
1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 5 using System.Net; 6 using System.Net.Http; 7 using System.Net.Http.Headers; 8 using TT.Utilities.Extends; 9 using System.Net.Security; 10 using System.Security.Cryptography.X509Certificates; 11 12 namespace TT.Utilities.Web 13 { 14 public class HttpClientUti 15 { 16 /// <summary> 17 /// post 提交json格式参数 18 /// </summary> 19 /// <param name="url">url</param> 20 /// <param name="postJson">json字符串</param> 21 /// <returns></returns> 22 public static string DoPost(string url, string postJson) 23 { 24 HttpContent content = new StringContent(postJson); 25 content.Headers.ContentType = new MediaTypeHeaderValue(HttpContentTypes.GetContentType(HttpContentTypes.HttpContentTypeEnum.JSON)); 26 return DoPost(url, content); 27 } 28 29 /// <summary> 30 /// post 提交json格式参数 31 /// </summary> 32 /// <param name="url">url</param> 33 /// <param name="argDic">参数字典</param> 34 /// <param name="headerDic">请求头字典</param> 35 /// <returns></returns> 36 public static string DoPost(string url, Dictionary<string, string> argDic, Dictionary<string, string> headerDic) 37 { 38 argDic.ToSortUrlParamString(); 39 var jsonStr = Newtonsoft.Json.JsonConvert.SerializeObject(argDic); 40 HttpContent content = new StringContent(jsonStr); 41 content.Headers.ContentType = new MediaTypeHeaderValue(HttpContentTypes.GetContentType(HttpContentTypes.HttpContentTypeEnum.JSON)); 42 if (headerDic != null) 43 { 44 foreach (var item in headerDic) 45 { 46 content.Headers.Add(item.Key, item.Value); 47 } 48 } 49 return DoPost(url, content); 50 } 51 52 /// <summary> 53 /// HttpClient POST 提交 54 /// </summary> 55 /// <param name="url">url</param> 56 /// <param name="content">HttpContent</param> 57 /// <returns></returns> 58 public static string DoPost(string url, HttpContent content) 59 { 60 try 61 { 62 var handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip }; 63 using (var http = new HttpClient(handler)) 64 { 65 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase)) 66 { 67 ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult); 68 } 69 70 var response = http.PostAsync(url, content).Result; 71 //确保HTTP成功状态值 72 response.EnsureSuccessStatusCode(); 73 //await异步读取最后的JSON(注意此时gzip已经被自动解压缩了,因为上面的AutomaticDecompression = DecompressionMethods.GZip) 74 var reJson = response.Content.ReadAsStringAsync().Result; 75 return reJson; 76 } 77 } 78 catch (Exception ex) 79 { 80 throw ex; 81 } 82 } 83 84 /// <summary> 85 /// HttpClient实现Get请求 86 /// </summary> 87 public static string DoGet(string url) 88 { 89 try 90 { 91 var handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip }; 92 using (var http = new HttpClient(handler)) 93 { 94 var response = http.GetAsync(url).Result; 95 response.EnsureSuccessStatusCode(); 96 return response.Content.ReadAsStringAsync().Result; 97 } 98 } 99 catch (Exception ex) 100 { 101 return ex.Message + "," + ex.Source + "," + ex.StackTrace; 102 } 103 } 104 105 /// <summary> 106 /// HttpClient实现Get请求 107 /// <param name="arg">参数字典</param> 108 /// </summary> 109 public static string DoGet(string url, IDictionary<string, string> arg) 110 { 111 var handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip }; 112 string argStr = "?"; 113 foreach (var item in arg) 114 { 115 argStr += item.Key + "=" + item.Value + "&"; 116 } 117 argStr = argStr.TrimEnd('&'); 118 url = url + argStr; 119 return DoGet(url); 120 } 121 122 /// <summary> 123 /// HttpClient Get 提交 124 /// </summary> 125 /// <param name="url"></param> 126 /// <param name="arg"></param> 127 /// <param name="headerDic"></param> 128 /// <returns></returns> 129 public static string DoGet(string url, IDictionary<string, string> arg, IDictionary<string, string> headerDic) 130 { 131 try 132 { 133 var handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip }; 134 if (arg != null && arg.Count > 0) 135 { 136 string argStr = "?"; 137 foreach (var item in arg) 138 { 139 argStr += item.Key + "=" + item.Value + "&"; 140 } 141 argStr = argStr.TrimEnd('&'); 142 url = url + argStr; 143 } 144 using (var http = new HttpClient(handler)) 145 { 146 if (headerDic != null) 147 { 148 foreach (var item in headerDic) 149 { 150 http.DefaultRequestHeaders.Add(item.Key, item.Value); 151 } 152 } 153 //await异步等待回应 154 var response = http.GetStringAsync(url).Result; 155 return response; 156 } 157 } 158 catch (Exception ex) 159 { 160 throw ex; 161 } 162 } 163 164 private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) 165 { 166 return true; //总是接受 167 } 168 } 169 }
单例模式 HttpClient
1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 5 using System.Net; 6 using System.Net.Http; 7 using System.Net.Http.Headers; 8 using TT.Utilities.Extends; 9 using System.Security.Cryptography.X509Certificates; 10 using System.Net.Security; 11 12 namespace TT.Utilities.Web 13 { 14 public class HttpClientSingleton 15 { 16 public static readonly HttpClient http = null; 17 static HttpClientSingleton() 18 { 19 var handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip }; 20 ServicePointManager.ServerCertificateValidationCallback = CheckValidationResult; 21 http = new HttpClient(handler); 22 } 23 24 /// <summary> 25 /// post 提交json格式参数 26 /// </summary> 27 /// <param name="url">url</param> 28 /// <param name="postJson">json字符串</param> 29 /// <returns></returns> 30 public static string DoPost(string url, string postJson) 31 { 32 HttpContent content = new StringContent(postJson); 33 content.Headers.ContentType = new MediaTypeHeaderValue(HttpContentTypes.GetContentType(HttpContentTypes.HttpContentTypeEnum.JSON)); 34 return DoPost(url, content); 35 } 36 37 /// <summary> 38 /// post 提交json格式参数 39 /// </summary> 40 /// <param name="url">url</param> 41 /// <param name="argDic">参数字典</param> 42 /// <param name="headerDic">请求头字典</param> 43 /// <returns></returns> 44 public static string DoPost(string url, Dictionary<string, string> argDic, Dictionary<string, string> headerDic) 45 { 46 argDic.ToSortUrlParamString(); 47 var jsonStr = Newtonsoft.Json.JsonConvert.SerializeObject(argDic); 48 HttpContent content = new StringContent(jsonStr); 49 content.Headers.ContentType = new MediaTypeHeaderValue(HttpContentTypes.GetContentType(HttpContentTypes.HttpContentTypeEnum.JSON)); 50 if (headerDic != null) 51 { 52 foreach (var item in headerDic) 53 { 54 content.Headers.Add(item.Key, item.Value); 55 } 56 } 57 return DoPost(url, content); 58 } 59 60 /// <summary> 61 /// HttpClient POST 提交 62 /// </summary> 63 /// <param name="url">url</param> 64 /// <param name="content">HttpContent</param> 65 /// <returns></returns> 66 public static string DoPost(string url, HttpContent content) 67 { 68 try 69 { 70 var response = http.PostAsync(url, content).Result; 71 //确保HTTP成功状态值 72 response.EnsureSuccessStatusCode(); 73 //await异步读取最后的JSON(注意此时gzip已经被自动解压缩了,因为上面的AutomaticDecompression = DecompressionMethods.GZip) 74 var reJson = response.Content.ReadAsStringAsync().Result; 75 return reJson; 76 } 77 catch (Exception ex) 78 { 79 throw ex; 80 } 81 } 82 83 /// <summary> 84 /// HttpClient实现Get请求 85 /// </summary> 86 public static string DoGet(string url) 87 { 88 try 89 { 90 var response = http.GetAsync(url).Result; 91 response.EnsureSuccessStatusCode(); 92 return response.Content.ReadAsStringAsync().Result; 93 } 94 catch (Exception ex) 95 { 96 return ex.Message + "," + ex.Source + "," + ex.StackTrace; 97 } 98 } 99 100 /// <summary> 101 /// HttpClient实现Get请求 102 /// <param name="arg">参数字典</param> 103 /// </summary> 104 public static string DoGet(string url, IDictionary<string, string> arg) 105 { 106 string argStr = "?"; 107 foreach (var item in arg) 108 { 109 argStr += item.Key + "=" + item.Value + "&"; 110 } 111 argStr = argStr.TrimEnd('&'); 112 url = url + argStr; 113 return DoGet(url); 114 } 115 116 /// <summary> 117 /// HttpClient Get 提交 118 /// </summary> 119 /// <param name="url"></param> 120 /// <param name="arg"></param> 121 /// <param name="headerDic"></param> 122 /// <returns></returns> 123 public static string DoGet(string url, IDictionary<string, string> arg, IDictionary<string, string> headerDic) 124 { 125 try 126 { 127 if (arg != null && arg.Count > 0) 128 { 129 string argStr = "?"; 130 foreach (var item in arg) 131 { 132 argStr += item.Key + "=" + item.Value + "&"; 133 } 134 argStr = argStr.TrimEnd('&'); 135 url = url + argStr; 136 } 137 138 if (headerDic != null) 139 { 140 foreach (var item in headerDic) 141 { 142 http.DefaultRequestHeaders.Add(item.Key, item.Value); 143 } 144 } 145 //await异步等待回应 146 var response = http.GetStringAsync(url).Result; 147 return response; 148 149 } 150 catch (Exception ex) 151 { 152 throw ex; 153 } 154 } 155 156 private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) 157 { 158 return true; //总是接受 159 } 160 } 161 }
public class HttpContentTypes { public enum HttpContentTypeEnum { JSON, FORM } public static string GetContentType(HttpContentTypeEnum type) { string typeStr = ""; switch (type) { case HttpContentTypeEnum.JSON: typeStr = "application/json"; break; case HttpContentTypeEnum.FORM: typeStr = "application/x-www-form-urlencoded"; break; } return typeStr; } }
注意HttpClient的使用,推荐HttpWebRequest。
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
上一篇:C#基础语法(二)
下一篇:任意输入判断是否为回文数
- python 之 前端开发(HTTP协议、head标签、img标签、a标签、 2019-08-13
- Python Http-server 使用 2019-07-24
- HTTP: Request中的post和get区别 2019-07-24
- RobotFramework + HTTP接口自动化实现 2019-07-24
- 解决pyhton aiohttp ssl:None [[SSL: CERTIFICATE_VERIFY_FA 2019-07-24
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash