using Microsoft.AspNetCore.Http;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Net.Http;
|
using System.Net.Http.Headers;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace VueWebCoreApi.Quartz
|
{
|
public static class HttpManager
|
{
|
public static string GetUserIP(IHttpContextAccessor httpContextAccessor)
|
{
|
if (httpContextAccessor?.HttpContext == null)
|
return string.Empty;
|
|
var request = httpContextAccessor.HttpContext.Request;
|
string remoteIpAddress = httpContextAccessor.HttpContext.Connection.RemoteIpAddress?.ToString() ?? string.Empty;
|
|
if (request.Headers.ContainsKey("X-Real-IP"))
|
{
|
var realIp = request.Headers["X-Real-IP"].ToString();
|
if (!string.IsNullOrEmpty(realIp) && realIp != remoteIpAddress)
|
{
|
remoteIpAddress = realIp;
|
}
|
}
|
|
if (request.Headers.ContainsKey("X-Forwarded-For"))
|
{
|
var forwarded = request.Headers["X-Forwarded-For"].ToString();
|
if (!string.IsNullOrEmpty(forwarded) && forwarded != remoteIpAddress)
|
{
|
remoteIpAddress = forwarded;
|
}
|
}
|
|
return remoteIpAddress;
|
}
|
|
public static async Task<string> HttpSendAsyncString(this IHttpClientFactory httpClientFactory, HttpMethod method, string url, string parameters = null, Dictionary<string, string> headers = null)
|
{
|
if (httpClientFactory == null)
|
throw new ArgumentNullException(nameof(httpClientFactory));
|
if (method == null)
|
throw new ArgumentNullException(nameof(method));
|
if (string.IsNullOrEmpty(url))
|
throw new ArgumentNullException(nameof(url));
|
|
var client = httpClientFactory.CreateClient();
|
string finalUrl = url;
|
HttpContent content = new StringContent("");
|
|
try
|
{
|
// ====================== GET 请求：拼接参数到 URL ======================
|
if (method == HttpMethod.Get && !string.IsNullOrWhiteSpace(parameters))
|
{
|
finalUrl = url.Contains("?")
|
? $"{url}&{parameters}"
|
: $"{url}?{parameters}";
|
}
|
|
// ====================== POST 请求：参数放入 Body ======================
|
if (method == HttpMethod.Post && !string.IsNullOrWhiteSpace(parameters))
|
{
|
content = new StringContent(
|
parameters,
|
System.Text.Encoding.UTF8,
|
"application/x-www-form-urlencoded");
|
}
|
|
var request = new HttpRequestMessage(method, finalUrl) { Content = content };
|
|
// 追加请求头
|
if (headers != null)
|
{
|
foreach (var header in headers)
|
{
|
if (!request.Headers.TryAddWithoutValidation(header.Key, header.Value))
|
{
|
content.Headers.TryAddWithoutValidation(header.Key, header.Value);
|
}
|
}
|
}
|
|
using (var response = await client.SendAsync(request))
|
{
|
response.EnsureSuccessStatusCode();
|
return await response.Content.ReadAsStringAsync();
|
}
|
}
|
catch (Exception ex)
|
{
|
return $"请求失败：{ex.Message}";
|
}
|
}
|
|
public static async Task<HttpResult> HttpSendAsync(this IHttpClientFactory httpClientFactory,HttpMethod method,string url,string parameters = null,Dictionary<string, string> headers = null)
|
{
|
if (httpClientFactory == null)
|
throw new ArgumentNullException(nameof(httpClientFactory));
|
if (method == null)
|
throw new ArgumentNullException(nameof(method));
|
if (string.IsNullOrEmpty(url))
|
throw new ArgumentNullException(nameof(url));
|
|
var client = httpClientFactory.CreateClient();
|
string finalUrl = url;
|
HttpContent content = new StringContent("");
|
|
try
|
{
|
// GET 拼接参数
|
if (method == HttpMethod.Get && !string.IsNullOrWhiteSpace(parameters))
|
{
|
finalUrl = url.Contains("?") ? $"{url}&{parameters}" : $"{url}?{parameters}";
|
}
|
|
// POST 处理参数
|
if (method == HttpMethod.Post && !string.IsNullOrWhiteSpace(parameters))
|
{
|
content = new StringContent(parameters, Encoding.UTF8, "application/x-www-form-urlencoded");
|
}
|
|
var request = new HttpRequestMessage(method, finalUrl) { Content = content };
|
|
// 请求头
|
if (headers != null)
|
{
|
foreach (var header in headers)
|
{
|
if (!request.Headers.TryAddWithoutValidation(header.Key, header.Value))
|
{
|
content.Headers.TryAddWithoutValidation(header.Key, header.Value);
|
}
|
}
|
}
|
|
using (var response = await client.SendAsync(request))
|
{
|
// 读取返回内容
|
string responseContent = await response.Content.ReadAsStringAsync();
|
|
return new HttpResult
|
{
|
IsSuccess = response.IsSuccessStatusCode, // 是否成功
|
StatusCode = (int)response.StatusCode, // 状态码 200/404/500
|
Content = responseContent, // 返回内容
|
ErrorMsg = response.IsSuccessStatusCode ? "" : $"HTTP请求失败，状态码：{(int)response.StatusCode}"
|
};
|
}
|
}
|
catch (Exception ex)
|
{
|
// 网络异常、超时等
|
return new HttpResult
|
{
|
IsSuccess = false,
|
StatusCode = 0, // 网络异常状态码设为0
|
Content = "",
|
ErrorMsg = ex.Message
|
};
|
}
|
}
|
/// <summary>
|
/// HTTP 请求统一返回模型
|
/// </summary>
|
public class HttpResult
|
{
|
/// <summary>
|
/// 是否请求成功（200-299）
|
/// </summary>
|
public bool IsSuccess { get; set; }
|
|
/// <summary>
|
/// HTTP 状态码（数字：200,404,500）
|
/// </summary>
|
public int StatusCode { get; set; }
|
|
/// <summary>
|
/// 返回内容
|
/// </summary>
|
public string Content { get; set; }
|
|
/// <summary>
|
/// 错误信息
|
/// </summary>
|
public string ErrorMsg { get; set; }
|
}
|
}
|
}
|
