咨詢區

• boot4life

為了能夠復用 HttpClient 所打開的TCP鏈接，我不得不讓所有的request共享一個單例，但問題來了，如果我簡單的在每一次request之前修改 timeout 屬性的話，會存在下面兩個問題。

線程不安全。

并發時可能會錯用到其他 request 的超時配置。

請問我該如何正確的處理？

回答區

• Todd Menier

你說的這種場景理論上是不可以設置 Timeout 屬性，但不要忘了，你可以用 .NET 庫中提供的取消機制類 CancellationTokenSource，你可以在每一次 request 中帶入 token 即可，然后用 CancelAfter() 方法來實現 Timeout 的功能，參考如下代碼：

static?async?Task?Main(string[]?args){var?httpClient?=?new?HttpClient();var?cts?=?new?CancellationTokenSource();cts.CancelAfter(TimeSpan.FromSeconds(30));await?httpClient.GetAsync("http://www.google.com",?cts.Token);}

哦，對了， HttpClient 的默認超時時間是 100s，如果你在 CancelAfter 中設置了過大的超時時間，本質上來說并沒有效果，為了解決這個 Max 的問題，我建議你給 HttpClient 設置一個無限期的超時，參考代碼如下：

static?async?Task?Main(string[]?args){var?httpClient?=?new?HttpClient();httpClient.Timeout?=?System.Threading.Timeout.InfiniteTimeSpan;var?cts?=?new?CancellationTokenSource();cts.CancelAfter(TimeSpan.FromSeconds(30));await?httpClient.GetAsync("http://www.google.com",?cts.Token);}

• Brad Albright

樓上的大佬說的非常好，但在我的場景下是這么實現的，首先我有一個默認的 CancellationToken ，它可被用戶手工干預，另外還有一個 CancellationToken，它是為了模擬 timeout 的 CancelAfter ，然后通過 CancellationTokenSource.CreateLinkedTokenSource 來將兩者結合起來，就可以做到既可以被 timeout 結束也可以被用戶手工干預停止，下面是我的案例代碼：

public?async?static?Task<HttpResponseMessage>?SendRequest(CancellationToken?cancellationToken) {var?ctsForTimeout?=?new?CancellationTokenSource();ctsForTimeout.CancelAfter(TimeSpan.FromSeconds(5));var?cancellationTokenForTimeout?=?ctsForTimeout.Token;using?(var?linkedCts?=?CancellationTokenSource.CreateLinkedTokenSource(cancellationToken,?cancellationTokenForTimeout)){try{return?await?httpClient.GetAsync("http://asdfadsf",?linkedCts.Token);}catch{//just?for?illustration?purposesif?(cancellationTokenForTimeout.IsCancellationRequested){Console.WriteLine("timeout");}else?if?(cancellationToken.IsCancellationRequested){Console.WriteLine("other?cancellation?token?cancelled");}throw;}} }

點評區

說實話，用 CancellationToken 來替代 Timeout 機制確實是一個非常好的想法，如果大家細心的話，會發現 Framework 中很多涉及IO的操作都實現了這種 取消機制，值得大家好好研究學習，比如下面代碼：

public?Task<HttpResponseMessage>?DeleteAsync(Uri??requestUri,?CancellationToken?cancellationToken); public?Task<byte[]>?GetByteArrayAsync(string??requestUri,?CancellationToken?cancellationToken); public?Task<Stream>?GetStreamAsync(Uri??requestUri,?CancellationToken?cancellationToken); public?Task<string>?GetStringAsync(string??requestUri,?CancellationToken?cancellationToken); public?Task<HttpResponseMessage>?PutAsync(Uri??requestUri,?HttpContent?content,?CancellationToken?cancellationToken); public?Task<HttpResponseMessage>?SendAsync(HttpRequestMessage?request,?HttpCompletionOption?completionOption,?CancellationToken?cancellationToken);

總結

以上是生活随笔為你收集整理的如何在并发中给 HttpClient 设置不同的超时时间？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。