我试图在收到请求后立即发送页面响应，然后处理一些东西，但我发现响应并没有“首先”发出，即使它在代码序列中是第一个。在现实生活中我有一个用于上传保存到数据库中的 Excel 工作表的页面，这需要时间(50,0000 多行)并希望更新用户进度。这是一个简化的例子； (取决于你有多少 RAM，你可能需要添加几个零来反算才能看到结果)
package main
import (
"fmt"
"net/http"
)
func writeAndCount(w http.ResponseWriter, r *http.Request) {
w.Write([]byte("Starting to count"))
for i := 0; i < 1000000; i++ {
if i%1000 == 0 {
fmt.Println(i)
}
}
w.Write([]byte("Finished counting"))
}
func main() {
http.HandleFunc("/", writeAndCount)
http.ListenAndServe(":8080", nil)
}
最佳答案
HTTP protocol的原始概念是一个简单的请求-响应服务器-客户端计算模型。没有流媒体或“连续”客户端更新支持。如果需要某种信息，首先联系服务器的始终是客户端。
此外，由于大多数网络服务器会缓存响应，直到它完全准备好(或达到某个限制——通常是缓冲区大小)，您写入(发送)到客户端的数据不会立即传输。
“开发”了几种技术来绕过这个“限制”，以便服务器能够通知客户端有关更改或进度的信息，例如 HTTP 长轮询、HTTP 流、HTTP/2 服务器推送或 Websockets。您可以在这个答案中阅读更多关于这些的信息:Is there a real server push over http?
所以要实现你想要的，你必须绕过 HTTP 协议(protocol)的原始“边界”。
如果你想定期发送数据，或者流式传输数据到客户端，你必须告诉服务器。最简单的方法是检查 http.ResponseWriter交给你的工具 http.Flusher接口(interface)(使用 type assertion )，如果是，则调用其 Flusher.Flush() 方法会将任何缓冲数据发送到客户端。
使用 http.Flusher 只是解决方案的一半。由于这是 HTTP 协议(protocol)的非标准用法，通常还需要客户端支持才能正确处理。
首先，您必须通过设置 ContentType=text/event-stream 响应 header 让客户端了解响应的“流”性质。
接下来，为避免客户端缓存响应，请务必同时设置 Cache-Control=no-cache。
最后，为了让客户端知道您可能不会将响应作为单个单元发送(而是作为定期更新或作为流)，以便客户端应该保持连接并等待进一步的数据，设置Connection=keep-alive 响应 header 。
如上设置响应 header 后，您就可以开始漫长的工作了，每当您想向客户端更新进度时，写入一些数据并调用 Flusher.Flush()。
让我们看一个“正确”做所有事情的简单例子:
func longHandler(w http.ResponseWriter, r *http.Request) {
flusher, ok := w.(http.Flusher)
if !ok {
http.Error(w, "Server does not support Flusher!",
http.StatusInternalServerError)
return
}
w.Header().Set("Content-Type", "text/event-stream")
w.Header().Set("Cache-Control", "no-cache")
w.Header().Set("Connection", "keep-alive")
start := time.Now()
for rows, max := 0, 50*1000; rows < max; {
time.Sleep(time.Second) // Simulating work...
rows += 10 * 1000
fmt.Fprintf(w, "Rows done: %d (%d%%), elapsed: %v\n",
rows, rows*100/max, time.Since(start).Truncate(time.Millisecond))
flusher.Flush()
}
}
func main() {
http.HandleFunc("/long", longHandler)
panic(http.ListenAndServe("localhost:8080", nil))
}
现在，如果您在浏览器中打开 http://localhost:8080/long，您将看到每秒“增长”的输出:
Rows done: 10000 (20%), elapsed: 1s
Rows done: 20000 (40%), elapsed: 2s
Rows done: 30000 (60%), elapsed: 3s
Rows done: 40000 (80%), elapsed: 4.001s
Rows done: 50000 (100%), elapsed: 5.001s
另请注意，在使用 SSE 时，您应该将更新“打包”到 SSE 框架中，也就是说，您应该以 “data:” 前缀开始它们，并以 2 个换行符结束每个框架:"\n\n"。
阅读更多关于 Server-sent events on Wikipedia 的信息.
参见 Golang SSE server example with client codes using it .
在 Server-Sent Events - One Way Messaging 上查看 w3school.com 的教程.
关于http - 为什么 Golang http.ResponseWriter 执行被延迟？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/48267616/
类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc
我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？ 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co
我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时，我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb，在下面的代码片段中:moduleNetclass
我正在使用的第三方API的文档状态:"[O]urAPIonlyacceptspaddedBase64encodedstrings."什么是“填充的Base64编码字符串”以及如何在Ruby中生成它们。下面的代码是我第一次尝试创建转换为Base64的JSON格式数据。xa=Base64.encode64(a.to_json) 最佳答案 他们说的padding其实就是Base64本身的一部分。它是末尾的“=”和“==”。Base64将3个字节的数据包编码为4个编码字符。所以如果你的输入数据有长度n和n%3=1=>"=="末尾用于填充n%
我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i
为什么4.1%2返回0.0999999999999996？但是4.2%2==0.2。 最佳答案 参见此处:WhatEveryProgrammerShouldKnowAboutFloating-PointArithmetic实数是无限的。计算机使用的位数有限(今天是32位、64位)。因此计算机进行的浮点运算不能代表所有的实数。0.1是这些数字之一。请注意，这不是与Ruby相关的问题，而是与所有编程语言相关的问题，因为它来自计算机表示实数的方式。 关于ruby-为什么4.1%2使用Ruby返
是的，我知道最好使用webmock，但我想知道如何在RSpec中模拟此方法:defmethod_to_testurl=URI.parseurireq=Net::HTTP::Post.newurl.pathres=Net::HTTP.start(url.host,url.port)do|http|http.requestreq,foo:1endresend这是RSpec:let(:uri){'http://example.com'}specify'HTTPcall'dohttp=mock:httpNet::HTTP.stub!(:start).and_yieldhttphttp.shou
它不等于主线程的binding，这个toplevel作用域是什么？此作用域与主线程中的binding有何不同？>ruby-e'putsTOPLEVEL_BINDING===binding'false 最佳答案 事实是，TOPLEVEL_BINDING始终引用Binding的预定义全局实例，而Kernel#binding创建的新实例>Binding每次封装当前执行上下文。在顶层，它们都包含相同的绑定(bind)，但它们不是同一个对象，您无法使用==或===测试它们的绑定(bind)相等性。putsTOPLEVEL_BINDINGput
我可以得到Infinity和NaNn=9.0/0#=>Infinityn.class#=>Floatm=0/0.0#=>NaNm.class#=>Float但是当我想直接访问Infinity或NaN时:Infinity#=>uninitializedconstantInfinity(NameError)NaN#=>uninitializedconstantNaN(NameError)什么是Infinity和NaN？它们是对象、关键字还是其他东西？ 最佳答案 您看到打印为Infinity和NaN的只是Float类的两个特殊实例的字符串
如果您尝试在Ruby中的nil对象上调用方法，则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而，有一个tryRails中的方法，如果它被发送到一个nil对象，它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常？ 最佳答案 像Ruby中的所有其他对象