麻烦同时响应多个请求
|
我正在尝试将node.js HTTP服务器转换为Go。这是我想发生的事情：
我有一个间歇性生成的资源（例如每秒大约生成一次），并且我希望对此资源的所有请求都可以等到下一次生成。这样，客户端可以轮询并确保仅获取最新资源。我正在使用web.go来消除运行HTTP服务器的许多复杂性。
这是我的代码的简短版本：
package main
import (
\"time\"
\"web\"
\"fmt\"
vector \"container/vector\"
)
var listeners vector.Vector;
func resource (ctx *web.Context) {
c := make(chan int)
listeners.Push(c)
go func() {
<-c
go func() {
ctx.WriteString(\"Cool\")
fmt.Println(\"Wrote something\")
}()
}()
}
func resourceLoop() {
time.Sleep(5 * 1000 * 1000000) // sleep for 5 seconds
for ; listeners.Len() > 0 ; {
c := listeners.Pop().(chan int)
c <- 1
}
go resourceLoop()
}
func main() {
web.Get(\"/resource\", resource)
go resourceLoop()
web.Run(\"localhost:4000\")
}
4
Cool
HTTP/1.1 200 OK
Content-Type: text/html; charset=utf-8
Date: Sat, 16 Apr 2011 00:37:58 GMT
Server: web.go
Transfer-Encoding: chunked
0
没有找到相关结果
已邀请:
1 个回复
田眯衅
func resource (ctx *web.Context, val string) string { c := make(chan int) listeners.Push(c) <-c return \"Cool\" }