开发手册 欢迎您!
软件开发者资料库

ASP.NET Core 使用HttpClient PostAsync POST Json数据

本文主要介绍在ASP.NET Core中,通过HttpClient PostAsync发送POST请求,POST Json数据的方法。

1、添加Microsoft.AspNet.WebApi.Client Nuget包引用

通过Nuget安装

Install-Package Microsoft.AspNet.WebApi.Client -Version 5.2.7

2、使用HttpClient的PostAsync方法发送Json数据请求

public class JsonContent : StringContent{    public JsonContent(object obj) :        base(JsonConvert.SerializeObject(obj), Encoding.UTF8, "application/json")    { }}//发送请求new HttpClient().PostAsync("http://...", new JsonContent(new { x = 1, y = 2 }));

3、demo示例代码

1)PostAsync方法

static readonly HttpClient Client = new HttpClient();
public async Task PostAsync(string url, object data) where T : class, new()
{
try
{
string content = JsonConvert.SerializeObject(data);
var buffer = Encoding.UTF8.GetBytes(content);
var byteContent = new ByteArrayContent(buffer);
byteContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
var response = await Client.PostAsync(url, byteContent).ConfigureAwait(false);
string result = await response.Content.ReadAsStringAsync();
if (response.StatusCode != HttpStatusCode.OK)
{
logger.Error($"GetAsync End, url:{url}, HttpStatusCode:{response.StatusCode}, result:{result}");
return new T();
}
logger.Info($"GetAsync End, url:{url}, result:{result}");
return JsonConvert.DeserializeObject(result);
}
catch (WebException ex)
{
if (ex.Response != null)
{
string responseContent = new StreamReader(ex.Response.GetResponseStream()).ReadToEnd();
throw new System.Exception($"response :{responseContent}", ex);
}
throw;
}
}

2)GetAsync方法

static readonly HttpClient Client = new HttpClient();
public async Task GetAsync(string url, object data)
{
try
{
string requestUrl = $"{url}?{GetQueryString(data)}";
logger.Info($"GetAsync Start, requestUrl:{requestUrl}");
var response = await Client.GetAsync(requestUrl).ConfigureAwait(false);
string result = await response.Content.ReadAsStringAsync();
logger.Info($"GetAsync End, requestUrl:{requestUrl}, HttpStatusCode:{response.StatusCode}, result:{result}");
return result;
}
catch (WebException ex)
{
if (ex.Response != null)
{
string responseContent = new StreamReader(ex.Response.GetResponseStream()).ReadToEnd();
throw new Exception($"Response :{responseContent}", ex);
}
throw;
}
}
private static string GetQueryString(object obj)
{
var properties = from p in obj.GetType().GetProperties()
where p.GetValue(obj, null) != null
select p.Name + "=" + HttpUtility.UrlEncode(p.GetValue(obj, null).ToString());
return String.Join("&", properties.ToArray());
}