我正在使用 context.Context 取消 http 请求
我发现虽然我得到了“上下文取消”，但底层套接字连接仍然可用，几秒钟后我可以得到响应。是这样设计的，一旦提出请求就可以读取响应吗？
这是代码
func SendRequest(ctx context.Context, url string) {
req, err := http.NewRequest("GET", url, nil)
if err != nil {
fmt.Println(err)
}
req = req.WithContext(ctx)
res, err := client.Do(req)
select {
case <-ctx.Done():
fmt.Printf("%s Canceled\n", url)
//client.Transport.(*http.Transport).CancelRequest(req)
//client.Transport.(*http.Transport).CloseIdleConnections()
}
if res != nil {
defer res.Body.Close()
}
if err != nil {
fmt.Printf("Failed: %v\n", err)
} else {
io.Copy(ioutil.Discard, res.Body)
fmt.Printf("return status: %d\n", url, res.StatusCode)
}
}
我请求的 URL 会在几秒后返回，所以我仍然可以读取响应主体，并且在进程退出后连接关闭。
这里是重现问题的简单代码
func client() {
ctx, cancel := context.WithCancel(context.Background())
client := http.DefaultClient
request, _ := http.NewRequest("GET", "http://127.0.0.1:9090", nil)
req := request.WithContext(ctx)
go func() {
client.Do(req)
}()
time.Sleep(time.Duration(1) * time.Second)
cancel()
<-time.After(time.Duration(10) * time.Second)
}
func sayhelloName(w http.ResponseWriter, r *http.Request) {
time.Sleep(time.Duration(10) * time.Second)
fmt.Fprintf(w, "Hello world!")
}
func server() {
http.HandleFunc("/", sayhelloName)
err := http.ListenAndServe(":9090", nil)
if err != nil {
log.Fatal("ListenAndServe: ", err)
}
}
恰好 10 秒后连接关闭
最佳答案
当上下文被取消时，您不需要自己做任何事情来取消请求。这已经由标准 http 包处理 as documented .
您只需要:
func SendRequest(ctx context.Context, url string) {
req, err := http.NewRequest("GET", url, nil)
if err != nil {
panic(err)
}
req = req.WithContext(ctx)
res, err := client.Do(req)
if err != nil {
panic(err)
}
defer res.Body.Close()
io.Copy(ioutil.Discard, res.Body)
fmt.Printf("return status: %d\n", url, res.StatusCode)
}
您的 TCP 转储确认一切正常，正如我上面所描述的那样。
分解:
您的出站请求确实在一秒钟后被取消，因为您的 TCP 转储确认:
6 2017-12-04 06:10:21.864955 0.0993000 40 TCP 17503 → 9090 [FIN, ACK] Seq=96 Ack=1 Win=8192 Len=0
7 2017-12-04 06:10:21.864955 0.0000000 40 TCP 9090 → 17503 [ACK] Seq=1 Ack=97 Win-7936 Len=0
第 6 行的 FIN 表示 HTTP 客户端告诉服务器“我已经结束与你的对话”。第 7 行的 ACK 表示服务器响应了请求，并关闭了连接。
但是，您的 HTTP 处理程序会忽略已取消的请求，并尝试以任何方式响应，生成第 8 行:
8 2017-12-04 06:10:30.868955 9.004000 169 HTTP HTTP/1.1 200 OK (text/plain)
但是随后服务器收到连接无效的消息:
9 2017-12-04 06:10:30.868955 0.000000 40 TCP 17503 → 8080 [RST, ACK] Seq=97 Ack=130 Win=0 Len=0
RST 表示连接已重置，当前无效。这是因为连接提前 9 秒终止。
所以你看，你的请求被立即取消了，正如它应该的那样。
您可以添加到代码中的唯一改进是让服务器中的 HTTP 处理程序实际检测并遵守此类取消，方法是在传入请求被取消时提前退出。
关于go - request.context 不会关闭连接，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47591342/
设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline，但已经有几个月没有使用它了。现在，在Ruby1.9.2上全新安装时，它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗？ 最佳答案
我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作)，这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以
我在我的Rails项目中使用Pow和powifygem。现在我尝试升级我的ruby版本(从1.9.3到2.0.0，我使用RVM)当我切换ruby版本、安装所有gem依赖项时，我通过运行railss并访问localhost:3000确保该应用程序正常运行以前，我通过使用pow访问http://my_app.dev来浏览我的应用程序。升级后，由于错误Bundler::RubyVersionMismatch:YourRubyversionis1.9.3,butyourGemfilespecified2.0.0，此url不起作用我尝试过的:重新创建pow应用程序重启pow服务器更新战俘
我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例，但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗？ 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)，我们在StackOverflow上找到一个类
下面的代码在我第一次运行它时就可以正常工作:require'rubygems'require'spreadsheet'book=Spreadsheet.open'/Users/me/myruby/Mywks.xls'sheet=book.worksheet0row=sheet.row(1)putsrow[1]book.write'/Users/me/myruby/Mywks.xls'当我再次运行它时，我会收到更多消息，例如:/Library/Ruby/Gems/1.8/gems/spreadsheet-0.6.5.9/lib/spreadsheet/excel/reader.rb:11
1.错误信息：Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:requestcanceledwhilewaitingforconnection(Client.Timeoutexceededwhileawaitingheaders)或者：Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:TLShandshaketimeout2.报错原因：docker使用的镜像网址默认为国外，下载容易超时，需要修改成国内镜像地址（首先阿里
require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器，我做错了什么？ 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame
一段时间以来，我一直在使用open_uri下拉ftp路径作为数据源，但突然发现我几乎连续不断地收到“530抱歉，允许的最大客户端数(95)已经连接。”我不确定我的代码是否有问题，或者是否是其他人在访问服务器，不幸的是，我无法真正确定谁有问题。本质上，我正在读取FTPURI:defself.read_uri(uri)beginuri=open(uri).readuri=="Error"?nil:urirescueOpenURI::HTTPErrornilendend我猜我需要在这里添加一些额外的错误处理代码...我想确保我采取一切预防措施来关闭所有连接，这样我的连接就不是问题所在，但是我
我遇到了一个非常奇怪的问题，我很难解决。在我看来，我有一个与data-remote="true"和data-method="delete"的链接。当我单击该链接时，我可以看到对我的Rails服务器的DELETE请求。返回的JS代码会更改此链接的属性，其中包括href和data-method。再次单击此链接后，我的服务器收到了对新href的请求，但使用的是旧的data-method，即使我已将其从DELETE到POST(它仍然发送一个DELETE请求)。但是，如果我刷新页面，HTML与"new"HTML相同(随返回的JS发生变化)，但它实际上发送了正确的请求类型。这就是这个问题令我困惑的
考虑一下:现在这些情况:#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2我需要用其他字符串输出URL。我如何保证＆符号不会被转义？由于我无法控制的原因，我无法发送&。求助!把我的头发拉到这里:\编辑:为了澄清，我实际上有一个像这样的数组:@images=[{:id=>"fooid",:url=>"http://