我正在嘗試從電子郵件測(cè)試工具 mailhog 中提取有關(guān)進(jìn)入 API 的郵件數(shù)據(jù)。如果我使用調(diào)用來(lái)獲取電子郵件列表，例如 GET /api/v1/messages，我可以毫無(wú)問(wèn)題地將這些數(shù)據(jù)加載到一個(gè)結(jié)構(gòu)中，并打印出我需要的值。但是，如果我使用一個(gè)不同的端點(diǎn)，它本質(zhì)上是一個(gè)新的電子郵件流，我會(huì)有不同的行為。當(dāng)我運(yùn)行我的 go 應(yīng)用程序時(shí)，我沒(méi)有得到任何輸出。我是否需要像 while 循環(huán)一樣不斷地監(jiān)聽(tīng)端點(diǎn)以獲取輸出？我的最終目標(biāo)是在電子郵件進(jìn)入時(shí)從中提取一些信息，然后將它們傳遞給不同的功能。這是我嘗試訪問(wèn)流式傳輸端點(diǎn) https://github.com/mailhog/MailHog/blob/master/docs/APIv1.mdres, err := http.Get("http://localhost:8084/api/v1/events")if err != nil { panic(err.Error())}body, err := ioutil.ReadAll(res.Body)if err != nil { panic(err.Error())}var data Emailjson.Unmarshal(body, &data)fmt.Printf("Email: %v\n", data)如果我在具有相同端點(diǎn)的 mailhog 服務(wù)上執(zhí)行 curl 請(qǐng)求，我會(huì)在收到郵件時(shí)得到輸出。但是我似乎無(wú)法弄清楚為什么我的 go 應(yīng)用程序沒(méi)有得到任何輸出。該應(yīng)用程序確實(shí)保持運(yùn)行，只是我沒(méi)有得到任何輸出。如果這是一個(gè)非常簡(jiǎn)單的問(wèn)題，我是 Go 的新手，所以很抱歉
1 回答
縹緲止盈
TA貢獻(xiàn)2041條經(jīng)驗(yàn) 獲得超4個(gè)贊
ReadAll 從 r 讀取直到出現(xiàn)錯(cuò)誤或 EOF 并返回它讀取的數(shù)據(jù)。
當(dāng)您用來(lái)讀取常規(guī)端點(diǎn)的正文時(shí)，它會(huì)起作用，因?yàn)橛行ж?fù)載有一個(gè)EOF：服務(wù)器使用標(biāo)頭來(lái)Content-Length告訴正文響應(yīng)有多少字節(jié)，一旦客戶端讀取了那么多字節(jié)，它就會(huì)明白它已經(jīng)讀取了全身上下都可以停下來(lái)。
但是，您的“流”端點(diǎn)沒(méi)有使用，因?yàn)檎牡拇笮∥粗?，它?yīng)該在事件到來(lái)時(shí)寫(xiě)入事件，因此在這種情況下Content-Length您不能使用。ReadAll通常，在這種情況下，您應(yīng)該逐行閱讀，其中每行代表一個(gè)事件。bufio.Scanner正是這樣做的：
res, err := http.Get("http://localhost:8084/api/v1/events")
if err != nil {
panic(err.Error())
}
scanner := bufio.NewScanner(res.Body)
for e.scanner.Scan() {
if err := e.scanner.Err(); err != nil {
panic(err.Error())
}
event := e.scanner.Bytes()
var data Email
json.Unmarshal(event, &data)
fmt.Printf("Email: %v\n", data)
}
curl可以按預(yù)期處理響應(yīng)，因?yàn)樗鼤?huì)檢查端點(diǎn)是否會(huì)流式傳輸數(shù)據(jù)，因此它會(huì)相應(yīng)地做出反應(yīng)。添加對(duì)問(wèn)題的響應(yīng)可能會(huì)有所幫助curl。
- 1 回答
- 0 關(guān)注
- 123 瀏覽
添加回答
舉報(bào)
0/150
提交
取消