我的编程空间,编程开发者的网络收藏夹
学习永远不晚

怎么在c#中设置HttpClient超时

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

怎么在c#中设置HttpClient超时

这篇文章将为大家详细讲解有关怎么在c#中设置HttpClient超时,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

问题

如果你经常用HttpClient去调用Restfull接口或传送文件,你可能会对HttpClient这个类处理Request(请求)超时的方式感到恼火,因为存在这两个问题:

  • timeout(超时)只能在HttpClient的class级别处理。也就是说,一旦设置好了,所有httpClient下的请求都会应用同样的超时设置,这显然不灵活,如果能够为每个request请求分别指定一个超时时间,将非常方便。

  • 当请求超时时,抛出的异常很不好辨认。你认为请求超时时,httpclient会抛出TimeoutException?,不,其实它会抛出一个TaskCanceledException,而单看这个异常,你一时还无法分辨是取消导致的还是真正超时导致的。

幸运的是,得益于HttpClient的灵活设计,可以非常容易的弥补此缺陷。
因此,我们将针对这两个问题做出解决方案。让我们回顾一下我们想要的:

  • 可以为每个request请求单独设置超时时间

  • 当超时发生时,catch的异常是TimeoutException而不是TaskCanceledException。

为每个request设置超时值

怎样将超时时间值和Request请求关联起来呢?HttpRequestMessage这个类有个Properties的属性,它是一个字典(Dictionary)类型的属性,我们可以放入我们任何自定义需要的内容到这个属性中。我们将使用这个属性存储请求(request)的超时时间,为了便于实现此功能,我们给HttpRequestMessage创建一个扩展方法:

public static class HttpRequestExtensions{  private static string TimeoutPropertyKey = "RequestTimeout";  public static void SetTimeout(    this HttpRequestMessage request,    TimeSpan? timeout)  {    if (request == null)      throw new ArgumentNullException(nameof(request));    request.Properties[TimeoutPropertyKey] = timeout;  }  public static TimeSpan? GetTimeout(this HttpRequestMessage request)  {    if (request == null)      throw new ArgumentNullException(nameof(request));    if (request.Properties.TryGetValue(        TimeoutPropertyKey,        out var value)      && value is TimeSpan timeout)      return timeout;    return null;  }}

这是一段很普通的代码,timout参数是可null的TimeSpan值,我们现在可以给请求设置超时值,但是目前还没有实际使用到这段代码。

Http Handler

HttpClient使用 管道体系( pipeline architecture) 结构:每个请求都通过一系列类型为HttpMessageHandler的Handler处理,并且以相反顺序逐级返回响应。有了这种机制,我们可以非常方便的加入我们自己的Handler来具体处理超时问题。如果您想了解更多,本文将对此进行更详细的说明。

我们的自己的超时Handler将继承DelegatingHandler,DelegatingHandler是一种设计为链式调用其他Handler的类(简单提一下:DelegatingHandler内部有个InnerHandler成员变量,我们可以在调用innerHandler.SendAsync()前后对request、CancellationToken和response做相应处理)。要实现我们的Handler,我们重写SendAsync方法。最小的实现如下所示:

class TimeoutHandler : DelegatingHandler{  protected async override Task<HttpResponseMessage> SendAsync(    HttpRequestMessage request,    CancellationToken cancellationToken)  {    return await base.SendAsync(request, cancellationToken);  }}

上述代码并没有任何用处,因为只是将实际处理丢给了base.SendAsync,目前还没有对TimeoutHandler进行任何加工处理,我们将逐步对其加强扩充,以达到我们的目的。

给Request加上超时处理

首先,让我们给TimeoutHandler添加一个TimeSpan类型的DefaultTimeout属性,这个默认超时时间是给没有特意设置超时时间的请求使用的:

public TimeSpan DefaultTimeout { get; set; } = TimeSpan.FromSeconds(100);

就像HttpClient.Timeout一样,我们也设置默认超时时间为100秒。

为了实现我们的超时处理,我们需要从request中获取超时时间(如果request中没有设置,则应用DefaultTimeout的值)。接着,我们创建一个在指定时间(超时时间)后将会被取消的CancellationToken,并把这个CancellationToken传入到链的下一个Handler。这样之后,如果指定超时时间内没有获取到response响应,我们刚刚创建的CancellationToken就会被取消(cancel)。

我们创建一个CancellationTokenSource,这个类可以创建和控制CancellationToken。它将根据超时时间来创建:

private CancellationTokenSource GetCancellationTokenSource(  HttpRequestMessage request,  CancellationToken cancellationToken){  var timeout = request.GetTimeout() ?? DefaultTimeout;  if (timeout == Timeout.InfiniteTimeSpan)  {    // No need to create a CTS if there's no timeout    //不需要创建CTS,因为不处理超时(下面会讲到)    return null;  }  else  {    var cts = CancellationTokenSource      .CreateLinkedTokenSource(cancellationToken);    cts.CancelAfter(timeout);    return cts;  }}

这里主要关注两个点:

  • 如果request超时值为Timeout.InfiniteTimeSpan,程序并不会创建CancellationTokenSource,它将不会被取消,因此节省了无用的分配。也就是说在这种情况下,我们将不会处理超时。

  • 以上相反,我们创建了一个在指定timeout后被自动取消的CancellationTokenSource(因为调用了CancelAfter)。请注意,这个CTS连接了传入参数的cancellationToken,这个cancellationToken其实来自SendAsync方法的实参。这样做之后,当真正的超时发生,或者参数的cancellationToken自身被取消,CTS都会被取消。如果想要获取跟多CancellationToken的内容,请访问这篇文章

最后,我们修改下SendAsync方法,应用刚刚创建的CancellationTokenSource。

protected async override Task<HttpResponseMessage> SendAsync(  HttpRequestMessage request,  CancellationToken cancellationToken){  using (var cts = GetCancellationTokenSource(request, cancellationToken))  {    return await base.SendAsync(      request,      cts?.Token ?? cancellationToken);  }}

我们创建了CTS后,把CTS的token传入到base.SendAsync中,注意,我们使用cts?.Token是因为GetCancellationTokenSource返回的cts可能为null,如果cts为null,则直接使用参数自己的cancellationToken,我们就不做任何超时处理。

通过这一步,我们有了自己的超时Handler,可以为每个请求指定不同的超时时间。但是,当超时发生时,我们仍然只能捕获到TaskCanceledException异常,这个问题很容易修复它。

抛出正确的异常

我们需要捕获TaskCanceledException(或者它的基类OperationCanceledException),然后检测cancellationToken参数是否是被取消的:

  • 如果是,说明这个cancel是调用者自身导致的,对此直接将异常上抛不处理

  • 如果不是,这意味着是因为我们的超时导致的cancel,因此,我们将抛出一个TimeoutException

这是最终的SendAsync方法:

protected async override Task<HttpResponseMessage> SendAsync(  HttpRequestMessage request,  CancellationToken cancellationToken){  using (var cts = GetCancellationTokenSource(request, cancellationToken))  {    try    {      return await base.SendAsync(        request,        cts?.Token ?? cancellationToken);    }    catch(OperationCanceledException)      when (!cancellationToken.IsCancellationRequested)    {      throw new TimeoutException();    }  }}

我们使用了一个exception filter,通过这种方式,我们只cactch我们符合我们情况需要的异常,然后做相应处理。

至此,我们的超时Handler已经完成了,接下来看看怎么使用它

使用Handler

当创建一个HttpClient时,可以指定一个自己的Handler作为管道(pipeline)的第一个Handler。如果没有指定,默认使用的是HttpClientHandler,这个handler直接发送请求到网络上。为了使用我们自己的TimeoutHandler,我们需要先创建它,然后将timeoutHandler指定为httpClient的handler。在timeoutHandler中,指定InnerHandler为我们自己创建的HttpClientHandler,这样实际的网络请求就委托到了HttpClientHandler中。

var handler = new TimeoutHandler{  InnerHandler = new HttpClientHandler()};using (var client = new HttpClient(handler)){  client.Timeout = Timeout.InfiniteTimeSpan;  ...}

通过将httpclient的timeout设置为InfiniteTimeSpan来禁用默认的超时设置,如果不这样做,默认超时会干扰我们自己的超时

现在,我们尝试发送一个设定了5秒超时的请求到需要很久才能响应的服务器

var request = new HttpRequestMessage(HttpMethod.Get, "http://foo/");request.SetTimeout(TimeSpan.FromSeconds(5));var response = await client.SendAsync(request);

如果服务器在5秒内响应数据,我们将会捕获到一个TimeoutException,而不是TaskCanceledException,因此事情似乎按预期进行。

为了检测cancellation是否正确运行,我们传入一个在2秒(比超时实际小)后会被取消的CancellationToken:

var request = new HttpRequestMessage(HttpMethod.Get, "http://foo/");request.SetTimeout(TimeSpan.FromSeconds(5));var cts = new CancellationTokenSource(TimeSpan.FromSeconds(2));var response = await client.SendAsync(request, cts.Token);

这时,我们可以捕获到TaskCanceledException,这正是我们期望的。

关于怎么在c#中设置HttpClient超时就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

怎么在c#中设置HttpClient超时

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

怎么在c#中设置HttpClient超时

这篇文章将为大家详细讲解有关怎么在c#中设置HttpClient超时,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。问题如果你经常用HttpClient去调用Restfull接口或传送文件,你
2023-06-14

怎么在golang中使用GRPC设置client超时时间

这篇文章给大家介绍怎么在golang中使用GRPC设置client超时时间,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。什么是golanggolang 是Google开发的一种静态强类型、编译型、并发型,并具有垃圾回收
2023-06-14

php.ini怎么设置超时时间

设置超时时间的方法:1、进入PHP安装目录,找到并打开配置文件“php.ini”;2、在配置文件中,搜索“max_execution_time”项,将该项的值修改为需要的时间值即可。
2021-08-07

Jenkins中怎么设置构建超时时间

在Jenkins中设置构建超时时间可以通过以下步骤实现:打开Jenkins的管理界面,在左侧导航栏中选择"系统管理"。在系统管理页面中,找到"系统设置"选项,点击进入。在系统设置页面中,向下滚动找到"超时策略"选项。在超时策略选项中,可以设
Jenkins中怎么设置构建超时时间
2024-03-04

redis怎么设置hash超时时间

Redis中的hash类型是没有超时时间的,但是可以通过设置hash中每个field的值为一个带有超时时间的字符串或者其他数据类型来实现类似的效果。具体实现的步骤如下:1. 使用HSET命令将field和value添加到hash中,valu
2023-09-01

C# 中怎么设置Excel表格超链接

本篇文章为大家展示了C# 中怎么设置Excel表格超链接,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。需要使用的工具:Free Spire.XLS for .NET 8.3 (社区版)Visual
2023-06-03

weblogic事务超时怎么设置

在WebLogic中,您可以通过以下步骤来设置事务超时时间:打开WebLogic管理控制台。导航到您的WebLogic域。在域设置中,选择“事务”选项卡。在事务选项卡中,找到“事务超时”部分。在“事务超时”部分,您可以选择设置全局事
2023-10-27

golang超时退出怎么设置

在Go语言中,可以使用context包来设置超时退出。下面是一个示例:package mainimport ("context""fmt""time")func main() {// 创建一个父级的contextctx := conte
golang超时退出怎么设置
2024-02-29

怎么设置session永不超时

要设置Session永不超时,可以通过以下几种方法:1. 在服务器端设置Session超时时间为较大的值或者设置为0,表示永不超时。在Java中,可以通过在web.xml配置文件中设置session-timeout的值为0或者较大的值来实现
2023-08-18

MyBatis中怎么设置SQL语句的超时时间

在MyBatis中,可以通过在, , , 等标签中添加timeout属性来设置SQL语句的超时时间,单位为秒。例如: