我需要在我的 golang 應用程序中讀取 sse，但不是實時的，事件返回緩沖。正如我所看到的，這是因為標準的 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()
1 回答
繁星coding
TA貢獻1797條經驗 獲得超4個贊
我發現，由于透明壓縮，數據由 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))
}
- 1 回答
- 0 關注
- 168 瀏覽
添加回答
舉報
0/150
提交
取消