網站首頁 編程語言 正文
1、遇到的問題
① 遠程主機強迫關閉了一個現有的連接
相信大家在使用 HttpClient 的時候遇到過 遠程主機強迫關閉了一個現有的連接 的錯誤,一般的解決方法就是下面這種
解決辦法:在請求方法中指定 ServicePoint 安全協議
System.Net.ServicePointManager.SecurityProtocol = System.Net.SecurityProtocolType.Tls11 | System.Net.SecurityProtocolType.Tls12;
② POST請求某種情況下請求會失敗的解決方案
工作中遇到寫正常的 http post 請求會失敗的問題,于是就在原有的基礎上改動了寫代碼使用HttpRequestMessage 指定 標頭、HTTP 謂詞和潛在數據,詳情見代碼第二個 post 請求方法。
2、使用HttpClient為什么建議使用單例
HttpClient 旨在被實例化一次并在應用程序的整個生命周期中重復使用。為每個請求實例化一個 HttpClient 類將耗盡重負載下可用的套接字數量。將導致 SocketException 錯誤。
3、基礎代碼實現
using System;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Reflection;
using System.Text;
namespace Clear.DataServices.HttpHelper
{
public class HttpClientService
{
private static HttpClientService _instance;
private static readonly object _lock = new object();
private static HttpClient _client;
public HttpClientService() { }
public static HttpClientService GetInstance()
{
if (_instance == null)
{
lock (_lock)
{
if (_instance == null)
{
_instance = new HttpClientService();
}
if (_client is null)
{
_client = new HttpClient();
}
}
}
return _instance;
}
/// <summary>
/// HttpClient Get請求
/// </summary>
/// <param name="url">請求地址</param>
/// <returns></returns>
public string HttpGet(string url)
{
try
{
if (_client.BaseAddress is null)
{
_client.BaseAddress = new Uri(url);
}
client.DefaultRequestHeaders.Accept.Clear();
HttpResponseMessage response = client.GetAsync(url).Result;
response.EnsureSuccessStatusCode();
string responseBody = response.Content.ReadAsStringAsync().Result;
return responseBody;
}
catch (Exception e)
{
object errorMessage = new
{
code = "-1",
message = e.Message
};
return JsonConvert.SerializeObject(errorMessage);
}
}
/// <summary>
/// HttpClient Post請求
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="content">HttpContent</param>
/// <returns></returns>
public string HttpPost(string url, string content, string token = null)
{
try
{
if (_client.BaseAddress is null)
{
_client.BaseAddress = new Uri(url);
}
// System.Net.ServicePointManager.SecurityProtocol = System.Net.SecurityProtocolType.Tls11 | System.Net.SecurityProtocolType.Tls12;
client.DefaultRequestHeaders.Accept.Clear();
client.DefaultRequestHeaders.Connection.Add("keep-alive");
if (!token.IsNullOrEmpty())
{
client.DefaultRequestHeaders.Add("Authorization-Token", token);
}
client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
HttpResponseMessage response = client.PostAsync(url, new StringContent(content, Encoding.UTF8, "application/json")).Result;
response.EnsureSuccessStatusCode();
string responseBody = response.Content.ReadAsStringAsync().Result;
return responseBody;
}
catch (Exception e)
{
object errorMessage = new
{
code = "-1",
message = e.Message
};
return JsonConvert.SerializeObject(errorMessage);
}
}
/// <summary>
/// HttpClient Post請求
/// </summary>
/// <remarks>
/// 用于非正常http請求
/// </remarks>
/// <param name="url"></param>
/// <param name="content"></param>
/// <returns></returns>
public string HttpPost(string url, string content)
{
try
{
using (var request = new HttpRequestMessage(new HttpMethod("Post"), url))
{
// System.Net.ServicePointManager.SecurityProtocol = System.Net.SecurityProtocolType.Tls11 | System.Net.SecurityProtocolType.Tls12;
request.Headers.TryAddWithoutValidation("Content-Type", "application/json");
request.Content = new StringContent(content);
request.Content.Headers.ContentType = MediaTypeHeaderValue.Parse("application/json");
var response = _client.SendAsync(request).Result;
return response.Content.ReadAsStringAsync().Result;
}
}
catch (Exception e)
{
object errorMessage = new
{
code = "-1",
message = e.Message
};
return JsonConvert.SerializeObject(errorMessage);
}
}
/// <summary>
/// Model對象轉換為uri網址參數形式
/// </summary>
/// <param name="obj">Model對象</param>
/// <param name="url">前部分網址</param>
/// <returns></returns>
public string GetUriParam(object obj, string url = "")
{
PropertyInfo[] propertis = obj.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public);
StringBuilder sb = new StringBuilder();
sb.Append(url);
sb.Append("?");
foreach (var p in propertis)
{
var v = p.GetValue(obj, null);
if (v == null) continue;
sb.Append(p.Name);
sb.Append("=");
sb.Append(Uri.EscapeDataString(v.ToString()));//將字符串轉換為它的轉義表示形式,HttpUtility.UrlEncode是小寫
sb.Append("&");
}
sb.Remove(sb.Length - 1, 1);
return sb.ToString();
}
}
}
原文鏈接:https://blog.csdn.net/qq_43562262/article/details/125042612
相關推薦
- 2022-10-13 解析django的csrf跨站請求偽造_python
- 2022-05-08 Python集合的增刪改查操作_python
- 2024-02-16 servlet中轉發和重定向的區別
- 2022-09-08 Go語言中并發的工作原理_Golang
- 2022-11-22 docker+Nginx部署前端項目的詳細過程記錄_docker
- 2022-04-04 react報錯‘react-scripts‘ 不是內部或外部命令,也不是可運行的程序
- 2022-11-03 C#事件中的兩個參數詳解(object?sender,EventArgs?e)_C#教程
- 2022-04-17 mac 使用zsh vscode和終端node默認版本不一致 (nvm node版本管理工具)
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支