GoLang之使用Context控制请求超时的实现

起因

  之前接触了一个需求：提供一个接口，这个接口有一个超时时间，如果超时了返回超时异常；这个接口中调用其他的接口，如果调用超时了，所有请求全部结束。
  在这个接口中，我使用了go协程去调用其他接口，所以不仅涉及到请求的超时控制，而且还涉及到父协程对子协程的控制问题。在翻阅了一些资料之后，了解到了Context的基本知识。

Context

  Context是golang.org.pkg下的一个包，类型是接口类型。主要功能有

父协程控制所有的子协程

  Context可以通过context.Background()或者 context.TODO()创建一个空的context。两个区别在于TODO

context可以进行派生，创建出子context。context有四种不同的子context：
  （1）WithCancel：方法入参是一个context；返回值是一个带有新Done的父context的副本，以及cancel函数。当调用cancel函数时，通道将被关闭。关闭规则：会先关闭内部的接收通道；通道关闭了接收该通道的操作会立即返回（即done返回的通道），并且context会向它所有的子值传递信号，如果子context还有子context，那这个撤销信号就会一级一级传递下去。最后这个context会断开其与父context的连接。
  （2）WithDeadline和WithTimeout（本次问题解决就使用的是这个）：WithDeadline或者WithTimeout的功能极为相似。都是返回可以被撤销的Context子值。它们不但可以被手动撤销，还会依据在生成是给定的过期时间，自动地进行定时撤销。
  WithDeadline是设置一个时间点，时间对上了就到期。WithTimeout是设置一段时间，比如几秒，过个这段时间，就超时。其实底层的WithTimeout也是通过WithDeadline实现的。WithTimeout的调用就等于WithDeadline(parent, time.Now().Add(timeout))（其中parent是父级context）
  （3）WithValue:入参是父级parent，存储的键和存储的值。返回的是一个带有数据的Context。这个Context是不能被撤销的。撤销的信号在传递的时候会跳过这个Context。

协程间共享数据

  协程间共享数据主要使用的就是WithValue生成的子Context，这个Context存的值在其他的协程中也能读取到。可以用做数据的共享。

超时取消协程

  主要用到的是WithDeadline生成的子Context以及Go中HttpClient请求中的context字段（下文会有描述）

取消超时请求的模型

调度模型


  

其中，对于超时的判断，是根据Context中的Done管道判断的。如果超时了，则Done管道可以拿到东西。

超时之后取消请求

  使用http.NewRequest方法获取到的req，可以调用WithContext将定义好的WithTimeout类型的context放进去，之后调用&htto.Client{}.Do()方法即可。网上有一些博客中让手动调用transport中的CancelRequest方法，但是这个方法已经不被建议使用了。因为它不能取消Http/2的请求。

 

 现在在代码中有一个私有化的roundTrip方法，会调用CancelRequest调用的cancelRequest方法。而这个roundTrip在transport中会在外面包一层RoundTrip方法，之后交给Client中的send方法进行调用。（具体可以进行源码的查阅）。所以现在通过Client的Do方法，可以自动完成请求的超时控制。

结论

  该调度模型亲测之后，确实可以实现请求的超时控制。只要在最外层设置超时时间时30s，只要过了30s，所有协程中的请求都会结束，对应的协程也会相应的结束；加上Client.Do方法，将超时控制变的更加简洁，后续会写专门写一篇关于http中Client的博客，详细讲解一下Client实现超时控制的原理。

到此这篇关于GoLang之使用Context控制请求超时的实现的文章就介绍到这了,更多相关GoLang Context控制请求超时 内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Go如何实现HTTP请求限流示例

    在开发高并发系统时有三把利器用来保护系统:缓存.降级和限流!为了保证在业务高峰期,线上系统也能保证一定的弹性和稳定性,最有效的方案就是进行服务降级了,而限流就是降级系统最常采用的方案之一. 这里为大家推荐一个开源库 https://github.com/didip/tollbooth 但是,如果您想要一些简单的.轻量级的或者只是想要学习的东西,实现自己的中间件来处理速率限制并不困难.今天我们就来聊聊如何实现自己的一个限流中间件 首先我们需要安装一个提供了 Token bucket (令牌桶算法)

  • Go语言开发发送Get和Post请求的示例

    在使用Go语言进行开发的时候,有的时候可能要发送get或者post请求,下面我对post和get请求做一下简单的介绍:关于 HTTP 协议 HTTP(即超文本传输协议)是现代网络中最常见和常用的协议之一,设计它的目的是保证客户机和服务器之间的通信. HTTP 的工作方式是客户机与服务器之间的 "请求-应答" 协议. 客户端可以是 Web 浏览器,服务器端可以是计算机上的某些网络应用程序. 通常情况下,由浏览器向服务器发起 HTTP 请求,服务器向浏览器返回响应.响应包含了请求的状态信息

  • 详解golang中发送http请求的几种常见情况

    方式一 使用http.Newrequest 先生成http.client -> 再生成 http.request -> 之后提交请求:client.Do(request) -> 处理返回结果,每一步的过程都可以设置一些具体的参数,下面是一个最朴素最基本的例子: //question ???将stdout重定向为response信息??? package main import ( "fmt" "io" "net/http" &q

  • Go语言Web编程实现Get和Post请求发送与解析的方法详解

    本文实例讲述了Go语言Web编程实现Get和Post请求发送与解析的方法.分享给大家供大家参考,具体如下: 这是一篇入门文章,通过一个简单的例子介绍Golang的Web编程主要用到的技术. 文章结构包括: 1. Client-Get 请求 2. Client-Post 请求 3. Server 处理 Get 和 Post 数据 在数据的封装中,我们部分采用了json,因而本文也涉及到Golang中json的编码和解码. 一.Client-Get 复制代码 代码如下: package main i

  • go语言简单的处理http请求的函数实例

    本文实例讲述了go语言简单的处理http请求的函数.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: func someHandler(w http.ResponseWriter, r *http.Request) {     // read form value     value := r.FormValue("value")     if r.Method == "POST" {         // receive posted data   

  • go语言在请求http时加入自定义http header的方法

    本文实例讲述了go语言在请求http时加入自定义http header的方法.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: client := &http.Client{] req, err := http.NewRequest("POST", "http://example.com", bytes.NewReader(postData)) req.Header.Add("User-Agent", "myCli

  • Go语言中利用http发起Get和Post请求的方法示例

    Go语言中利用http发起Get和Post请求的方法示例

    关于 HTTP 协议 HTTP(即超文本传输协议)是现代网络中最常见和常用的协议之一,设计它的目的是保证客户机和服务器之间的通信. HTTP 的工作方式是客户机与服务器之间的 "请求-应答" 协议. 客户端可以是 Web 浏览器,服务器端可以是计算机上的某些网络应用程序. 通常情况下,由浏览器向服务器发起 HTTP 请求,服务器向浏览器返回响应.响应包含了请求的状态信息以及可能被请求的内容. Go 语言中要请求网页时,使用net/http包实现.官方已经提供了详细的说明,但是比较粗略,

  • GoLang之使用Context控制请求超时的实现

    起因   之前接触了一个需求:提供一个接口,这个接口有一个超时时间,如果超时了返回超时异常:这个接口中调用其他的接口,如果调用超时了,所有请求全部结束.   在这个接口中,我使用了go协程去调用其他接口,所以不仅涉及到请求的超时控制,而且还涉及到父协程对子协程的控制问题.在翻阅了一些资料之后,了解到了Context的基本知识. Context   Context是golang.org.pkg下的一个包,类型是接口类型.主要功能有 父协程控制所有的子协程   Context可以通过context.

  • PHP http请求超时问题解决方案

    一,http请求超时时间 可能出现的场景: 1,curl进程运行了一个世纪还木结束,curl的时候设置了超时时间 --connect-timeout 1000 2,operation timed out after 1000 milliseconds with 0 bytes received 3,connect() timed out! wget对超时时间, 是有分阶段的, 比如说请求的超时, 传输的超时,同样HTTP请求有两个超时时间:一个是连接超时时间,另一个是数据传输的最大允许时间,出现

  • Go中groutine通信与context控制实例详解

    Go中groutine通信与context控制实例详解

    目录 需求背景: Groutine的并发控制: Context: 看看代码: 总结 需求背景: 项目中需要定期执行任务A来做一些辅助的工作,A的执行需要在超时时间内完成,如果本次执行超时了,那就不对本次的执行结果进行处理(即放弃这次执行).同时A又依赖B,C两个子任务的执行结果.B, C之间相互独立,可以并行的执行.但无论B,C哪一个执行失败或超时都会导致本次任务执行失败. Groutine的并发控制: go中对于groutine的并发控制有三种解决方案: 通过channel控制. 父grout

  • iOS判断网络请求超时的方法

    本文介绍了iOS判断网络请求超时的方法,代码具体如下: + (AFHTTPRequestOperation *)requestOperationWithUrl:(NSString *)url requetMethod:(NSString *)method paramData:(NSDictionary *)aParamData constructingBodyWithBlock:(void (^)(id <AFMultipartFormData> formData))block success

  • SQL Server 磁盘请求超时的833错误原因及解决方法

    SQL Server 磁盘请求超时的833错误原因及解决方法

    最近遇到一个SQL Server服务器响应极度缓慢,并且出现客户端请求报错的情况,在数据库中的errorlog中出现磁盘请求超过15s才完成的error消息. 对于此类问题,到底是存储系统或者磁盘的故障,还是SQL Server 自己的问题,亦或是应用程序引发的呢?又要如何解决? 本文将对引起此问题的某一方面的因素进行简单的分析,但是无法涵盖所有潜在的可能性,因此遇到类似问题还要做具体的分析. SQL Server中的磁盘请求超时 该错误的英文版的错误信息如下: SQL Server has e

  • SQLServer2000 报1053错误(服务没有及时响应或控制请求)的解决方法

    今天启动SQLServer2000时报1053错误 错误如下所示: 发生错误 1053-(服务没有及时响应或控制请求.),此时正在 MSSQLServer 服务上执行该服务操作. 我立即上网查找相关信息,看见有人说是更改windows用户密码后便出现此类问题,但说得都不是很明白,所以自己想总结一下. 打开管理工具中的"服务",找到MSSQLSERVER,右键属性,在登录下面选择此帐户,然后点浏览,在高级里面点立即查找,选择您登录的用户,最后输入此用户的密码. 大功告成!可以继续用SQL

  • IIS无法启动提示“服务没有及时响应启动或控制请求”的解决方法[图解]

    IIS无法启动提示“服务没有及时响应启动或控制请求”的解决方法[图解]

    于是,从控制面板的中打开"管理工具"-"服务",检查发现和IIS相关的服务"World wide web publishing service"没有启动,试图启动该该服务时,弹出"错误:127 找不到指定的程序"的错误提示.尝试了很多中方法,包括查看80端口是否被其它程序占用,并启动IIS相关的服务等,都解决不了问题,折腾老半天最后发现竟然是微软自家的补丁导致的. 解决方法很简单:卸载删除跟IIS相关的几个漏洞安全更新补丁即可

  • 运行iis提示服务没有及时响应启动或控制请求的解决方法

    服务没有及时响应启动或控制请求的解决方法小结 先重启,重启还是不行就是服务被禁用了,依次开启 eventlog服务,"WorldWideWebPublishing"服务,然后iis一般就可以正常了.如果还是不行,可以参考下面的方法,逐一尝试. 1.系统环境:Windowsxp+sp2,II5.0 故障现象:上午把IIS服务停止以后,程序长时间没响应,通过任务管理器关闭,启动时提示"服务没有及时响应启动或控制请求",重启计算机未能解决. 解决办法:在Internet信

  • 处理(php-cgi.exe - FastCGI 进程超过了配置的请求超时时限)的问题

    [详细错误]:HTTP 错误 500.0 - Internal Server ErrorC:\Program Files\PHP\php-cgi.exe - FastCGI 进程超过了配置的请求超时时限[环境]:php + IIS7.5解决办法:方法一:C:\Windows\System32\inetsrv\config\applicationHost.config 进行编辑,将activityTimeout设置调大,默认为600(10分钟),最大支持3600(1小时),单位秒~ 方法二:开始-

  • ASP.NET页面请求超时时间设置多种方法

    ASP.NET页面请求超时时间设置多种方法

    ASP.NET 页面请求超时时间(页面后台程序执行时间)默认值为110秒(在 .NET Framework 1.0 版和 1.1 版中,默认值为 90 秒) 即: Server.ScriptTimeout = 110(HttpServerUtility.ScriptTimeout = 110) System.Web.Configuration.HttpRuntimeSection().ExecutionTimeout.ToString() =00:01:50(110 秒) 方法一:设置 Serv

随机推荐