在我的代碼中，我想執(zhí)行以下操作：從輸入接收數(shù)據(jù)event和message根據(jù)接收到的數(shù)據(jù)格式化event我想使用與 OOP 中的方法接近的東西，但看起來我搞砸了。我寫的是：// Define the structs that contains the channelstype sseData struct { event, message string}type DataPasser struct { data chan sseData logs chan string connection chan struct{} // To control maximum allowed clients connections}// DEfine the struct's reciever that do the formating based on the input datefunc (p *DataPasser) Format() { data := <-p.data switch { case len(data.event) > 0: p.logs <- fmt.Sprintf("event: %v\ndata: %v\n\n", data.event, data.message) case len(data.event) == 0: p.logs <- fmt.Sprintf("data: %v\n\n", data.message) }}然后我有以下內(nèi)容：func (p *DataPasser) HandleSignal(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "text/event-stream; charset=utf-8") w.Header().Set("Cache-Control", "no-cache") w.Header().Set("Connection", "keep-alive") setupCORS(&w, r) fmt.Println("Client connected from IP:", r.RemoteAddr) p.connection <- struct{}{} flusher, ok := w.(http.Flusher) if !ok { http.Error(w, "Internal error", 500) return } fmt.Fprint(w, "event: notification\ndata: Connection to WhatsApp server ...\n\n") flusher.Flush() // Connect to the WhatsApp client go Connect() // Prepare dataParser `p` to recieve data through its sseData channel go p.Format() for { select { case c := <-p.logs: fmt.Fprint(w, c) flusher.Flush() case <-r.Context().Done(): <-p.connection fmt.Println("Connection closed") return } }}
2 回答
FFIVE
TA貢獻(xiàn)1797條經(jīng)驗(yàn) 獲得超6個(gè)贊
當(dāng)您passer.data從go connect()例程向其發(fā)送數(shù)據(jù)時(shí)，例程go p.Format()不在監(jiān)聽。因?yàn)槟褂玫氖菬o緩沖通道parser.data但沒有接收器正在監(jiān)聽，所以您的代碼被卡住了。要么使用緩沖通道，parser.data要么確保您的例程監(jiān)聽來自數(shù)據(jù)通道的傳入消息已啟動，并在實(shí)際將數(shù)據(jù)發(fā)送到通道之前進(jìn)行監(jiān)聽。在你的情況下，我想在Format例程之前開始例程Connect就足夠了。
慕虎7371278
TA貢獻(xiàn)1802條經(jīng)驗(yàn) 獲得超4個(gè)贊
我通過寫解決了它：
// Connect to the WhatsApp client
go Connect()
for {
select {
case data := <-p.data:
fmt.Println("recieved")
switch {
case len(data.event) > 0:
fmt.Fprintf(w, "event: %v\ndata: %v\n\n", data.event, data.message)
case len(data.event) == 0:
fmt.Fprintf(w, "data: %v\n\n", data.message)
}
flusher.Flush()
case <-r.Context().Done():
<-p.connection
fmt.Println("Connection closed")
return
}
}
但我仍然對拆分操作和使用接收器感興趣，我不能接受這個(gè)作為答案，因?yàn)樗菃栴}的解決方案，但不是問題的答案。任何想法？
- 2 回答
- 0 關(guān)注
- 126 瀏覽
添加回答
舉報(bào)
0/150
提交
取消