咨詢區(qū)

• boot4life

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

線程不安全。

并發(fā)時(shí)可能會(huì)錯(cuò)用到其他 request 的超時(shí)配置。

請(qǐng)問我該如何正確的處理？

回答區(qū)

• Todd Menier

你說的這種場景理論上是不可以設(shè)置 Timeout 屬性，但不要忘了，你可以用 .NET 庫中提供的取消機(jī)制類 CancellationTokenSource，你可以在每一次 request 中帶入 token 即可，然后用 CancelAfter() 方法來實(shí)現(xiàn) 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);}

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

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

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

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;}} }

點(diǎn)評(píng)區(qū)

說實(shí)話，用 CancellationToken 來替代 Timeout 機(jī)制確實(shí)是一個(gè)非常好的想法，如果大家細(xì)心的話，會(huì)發(fā)現(xiàn) Framework 中很多涉及IO的操作都實(shí)現(xiàn)了這種 取消機(jī)制，值得大家好好研究學(xué)習(xí)，比如下面代碼：

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);

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。