在客户端读取未缓冲的服务器发送事件
Read not buffered Server-Sent Event on client
我需要在我的 golang 应用程序中读取 sse,但不是实时的,缓冲的事件 return。如我所见,这是因为标准的 golang 传输。如果不实施我自己的交通工具,我该如何解决这个问题?
此代码的灵感来自 cryptix 解决方案:
resp, _ := http.Get(sseURL)
events := make(chan Event)
wg:= sync.WaitGroup{}
wg.Add(1)
go func() {
event:= Event{}
reader := bufio.NewReader(resp.Body)
for {
line, err := reader.ReadBytes('\n')
if err != nil {
log.Println(os.Stderr, "error during resp.Body read:%s\n", err)
close(events)
}
json.Unmarshal(line,&event)
events<-event
}
wg.Done()
}()
go func(){
for ev:= range events {
log.Println(ev)
}
}()
wg.Wait()
我发现,由于透明压缩,数据由 nginx 缓冲。因此,要立即获取数据,我们必须像这样禁用压缩:
client := &http.Client{}
transport := &http.Transport{}
transport.DisableCompression = true
client.Transport = transport
req, err := http.NewRequest("GET", essURL, nil)
if err != nil {
log.Fatal(err);
}
resp, _ := client.Do(req)
reader := bufio.NewReader(resp.Body)
for {
line,_:=reader.ReadSlice('\n')
log.Println(string(line))
}
我需要在我的 golang 应用程序中读取 sse,但不是实时的,缓冲的事件 return。如我所见,这是因为标准的 golang 传输。如果不实施我自己的交通工具,我该如何解决这个问题? 此代码的灵感来自 cryptix 解决方案:
resp, _ := http.Get(sseURL)
events := make(chan Event)
wg:= sync.WaitGroup{}
wg.Add(1)
go func() {
event:= Event{}
reader := bufio.NewReader(resp.Body)
for {
line, err := reader.ReadBytes('\n')
if err != nil {
log.Println(os.Stderr, "error during resp.Body read:%s\n", err)
close(events)
}
json.Unmarshal(line,&event)
events<-event
}
wg.Done()
}()
go func(){
for ev:= range events {
log.Println(ev)
}
}()
wg.Wait()
我发现,由于透明压缩,数据由 nginx 缓冲。因此,要立即获取数据,我们必须像这样禁用压缩:
client := &http.Client{}
transport := &http.Transport{}
transport.DisableCompression = true
client.Transport = transport
req, err := http.NewRequest("GET", essURL, nil)
if err != nil {
log.Fatal(err);
}
resp, _ := client.Do(req)
reader := bufio.NewReader(resp.Body)
for {
line,_:=reader.ReadSlice('\n')
log.Println(string(line))
}