最近悟出来一个道理，在这儿分享给大家：学历代表你的过去，能力代表你的现在，学习代表你的将来。
十年河东十年河西，莫欺少年穷。
本文旨在发布代码，供自己参考，也供大家参考，谢谢。
正题：
HttpWebClient的四种请求方式：Get、Post、Put、Delete
系列代码如下：
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Reflection;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using System.ComponentModel;
using System.Web; namespace WebApiTest
{
/// <summary>
/// 系列代码整理：陈卧龙 18137070152 QQ 1429677330
/// </summary>
public class RestServiceProxy
{
#region static List<T> Get<T>(string endpoint)类型请求
/// <summary>
/// HttpClientGet请求
/// </summary>
/// <typeparam name="T">泛型</typeparam>
/// <param name="endpoint">URL</param>
/// <returns></returns>
public static List<T> Get<T>(string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress);//带上请求标题头
var response = httpClient.GetAsync(endpoint).Result;
return JsonConvert.DeserializeObject<List<T>>(response.Content.ReadAsStringAsync().Result);
}
}
#endregion #region static T Get<T>(int id, string endpoint)类型请求
public static T Get<T>(int id, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress);
//httpClient.DefaultRequestHeaders.Add("marketcode", GlobalClientConfig.MarketCode);//新宇多带的标题头
//httpClient.DefaultRequestHeaders.Add("languagecode", GlobalClientConfig.LanguageResource);
var response = httpClient.GetAsync(endpoint + id).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} return JsonConvert.DeserializeObject<T>(response.Content.ReadAsStringAsync().Result);
}
}
public static T Get<T>(string id, string endpoint)
{
T obj;
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var response = httpClient.GetAsync(endpoint + id).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
obj = JsonConvert.DeserializeObject<T>(result);
return obj;
}
}
#endregion #region Get请求、传递一个对象,返回对象或对象集static T1 Get<T1, T2>(T2 data, string endpoint)
/// <summary>
/// general get restful service data
/// </summary>
/// <typeparam name="T1">return data type 返回值类型</typeparam>
/// <typeparam name="T2">input data type 参数类型</typeparam>
/// <param name="data">search condition</param>
/// <param name="endpoint">service url 请求URI</param>
/// <returns></returns>
public static T1 Get<T1, T2>(T2 data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var _endpoint = endpoint; var requestMessage = GetObjectPropertyValue(data);
if (!string.IsNullOrEmpty(requestMessage))
{
_endpoint += "?" + requestMessage.Remove(, );
}
var response = httpClient.GetAsync(_endpoint).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
return JsonHelper.JsonDeserialize<T1>(result);
}
} public static List<T1> GetList<T1, T2>(T2 data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var _endpoint = endpoint;
var requestMessage = GetObjectPropertyValue(data);
if (!string.IsNullOrEmpty(requestMessage))
{
_endpoint += "?" + requestMessage.Remove(, );
}
var response = httpClient.GetAsync(_endpoint).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
}
string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<List<T1>>(result);
}
}
#endregion #region Get请求 不/传递Id 返回对象集合
public static List<T1> GetList<T1>(string id, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var response = httpClient.GetAsync(endpoint + id).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<List<T1>>(result);
}
} public static List<T1> GetList<T1>(string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var response = httpClient.GetAsync(endpoint).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<List<T1>>(result);
}
}
#endregion #region Post请求 static string Post<T>(T data, string endpoint)及 static TRetrun Post<TRetrun, TPost>(TPost data, string endpoint)
public static string Post<T>(T data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var requestMessage = JsonHelper.JsonSerializer<T>(data);
HttpContent contentPost = new StringContent(requestMessage, Encoding.UTF8, "application/json");
var response = httpClient.PostAsync(endpoint, contentPost).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<string>(result); }
} public static TRetrun Post<TRetrun, TPost>(TPost data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var requestMessage = JsonConvert.SerializeObject(data, new IsoDateTimeConverter());
HttpContent contentPost = new StringContent(requestMessage, Encoding.UTF8, "application/json");
var response = httpClient.PostAsync(endpoint, contentPost).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<TRetrun>(result);
}
}
#endregion #region PostByDictionay 字典处理POST
public static Dictionary<string, object> PostByDictionay<T>(T data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var requestMessage = JsonHelper.JsonSerializer<T>(data);
HttpContent contentPost = new StringContent(requestMessage, Encoding.UTF8, "application/json");
var response = httpClient.PostAsync(endpoint, contentPost).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<Dictionary<string, object>>(result);
}
} /// <summary>
/// 注册设备MAC同步服务器，无需验证
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="data"></param>
/// <param name="endpoint"></param>
/// <returns></returns>
public static string PostDevice<T>(T data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var requestMessage = JsonHelper.JsonSerializer<T>(data);
HttpContent contentPost = new StringContent(requestMessage, Encoding.UTF8, "application/json");
var response = httpClient.PostAsync(endpoint, contentPost).Result;
string result = response.Content.ReadAsStringAsync().Result;
return JsonConvert.DeserializeObject<string>(result);
}
}
#endregion #region 其他i请求
public static string GetObjectPropertyValue<T>(T t)
{
StringBuilder sb = new StringBuilder();
Type type = typeof(T);
PropertyInfo[] properties = type.GetProperties();
foreach (PropertyInfo property in properties)
{
if (property != null && t != null)
{
object o = property.GetValue(t, null);
if (o != null)
{
sb.Append("&" + property.Name + "=" + o); ;
}
}
}
return sb.ToString();
} public static T GetOne<T>(string endpoint)
{
T obj;
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var response = httpClient.GetAsync(endpoint).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
obj = JsonConvert.DeserializeObject<T>(result);
return obj;
}
} public static T CheckWhetherInternet<T>(string endpoint)
{
T obj;
using (var httpClient = new HttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var response = httpClient.GetAsync(endpoint).Result;
if (response.StatusCode != HttpStatusCode.OK)
{
if (response.StatusCode == HttpStatusCode.Unauthorized)
{
throw new UnauthorizedAccessException();
}
else
{
throw new Exception("Invoke Server Service Error");
}
} string result = response.Content.ReadAsStringAsync().Result;
obj = JsonConvert.DeserializeObject<T>(result);
return obj;
}
}
#endregion #region Delete 请求
public static string Delete<T>(T data, string endpoint)
{
using (var httpClient = NewHttpClient())
{
httpClient.DefaultRequestHeaders.Add("mac", GlobalClientConfig.MacAddress); var _endpoint = endpoint;
var requestMessage = GetObjectPropertyValue(data);
if (!string.IsNullOrEmpty(requestMessage))
{
_endpoint += "?" + requestMessage.Remove(, );
}
var result = httpClient.DeleteAsync(_endpoint).Result;
//return result.Content.ReadAsStringAsync().Result; string res = result.Content.ReadAsStringAsync().Result;
return res;
}
} public static string Delete(string id, string endpoint)
{
using (var httpClient = NewHttpClient())
{
var result = httpClient.DeleteAsync(endpoint + id).Result; return result.Content.ReadAsStringAsync().Result;
}
}
#endregion #region 初始化HttpClient
protected static HttpClient NewHttpClient()
{ var handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip };
ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, sslPolicyErrors) => true;
return new HttpClient(handler); }
#endregion #region 发起Json数据包请求
/// <summary>
/// 请求格式JSON数据格式
/// </summary>
/// <param name="posturl"></param>
/// <param name="postData"></param>
/// <returns></returns>
public static string GetUri(string posturl, string postData)
{ using (var http = new HttpClient())
{
var content = new StringContent(postData, Encoding.UTF8, "application/json");
//await异步等待回应
var response = http.PostAsync(posturl, content).Result; }
return null;
}
#endregion #region 这是HttpWebRequest请求方式
public static string GetPage(string posturl, string postData)
{
//WX_SendNews news = new WX_SendNews();
//posturl： news.Posturl;
//postData：news.PostData;
System.IO.Stream outstream = null;
Stream instream = null;
StreamReader sr = null;
HttpWebResponse response = null;
HttpWebRequest request = null;
Encoding encoding = Encoding.UTF8;
byte[] data = encoding.GetBytes(postData);
// 准备请求...
try
{
// 设置参数
request = WebRequest.Create(posturl) as HttpWebRequest;
CookieContainer cookieContainer = new CookieContainer();
request.CookieContainer = cookieContainer;
request.AllowAutoRedirect = true;
request.Method = "POST";
request.ContentType = "application/x-www-form-urlencoded";
request.ContentLength = data.Length;
outstream = request.GetRequestStream();
outstream.Write(data, , data.Length);
outstream.Close();
//发送请求并获取相应回应数据
response = request.GetResponse() as HttpWebResponse;
//直到request.GetResponse()程序才开始向目标网页发送Post请求
instream = response.GetResponseStream();
sr = new StreamReader(instream, encoding);
//返回结果网页（html）代码
string content = sr.ReadToEnd();
string err = string.Empty; return content;
}
catch (Exception ex)
{
string err = ex.Message;
return string.Empty;
}
}
#endregion
}
}
@陈卧龙的博客