我正在关注 chat example由 gorilla 提供。
我仍然可以解码发送的 json 数据。我应该在 readPump()
中执行此操作吗:
func (c *ChatClient) readPump() {
defer func() {
c.hub.unregisterChan <- c
c.conn.Close()
}()
c.conn.SetReadLimit(maxMessageSize)
c.conn.SetReadDeadline(time.Now().Add(pongWait))
c.conn.SetPongHandler(func(string) error { c.conn.SetReadDeadline(time.Now().Add(pongWait)); return nil })
for {
_, message, err := c.conn.ReadMessage()
// =================MY CODE START=============
var comment Comment
err = c.conn.ReadJSON(comment)
if err != nil {
LogErr("readjson()", err)
break
}
err = json.Unmarshal(message, comment)
if err != nil {
LogErr("readjson()", err)
break
}
// =================MY CODE END=============
if err != nil {
if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
LogErr("IsUnexpectedCloseError()", err)
}
break
}
message = bytes.TrimSpace(bytes.Replace(message, newline, space, -1))
c.hub.broadcastChan <- message
}
}
或者在writePump()
func (c *ChatClient) writePump() {
ticker := time.NewTicker(pingPeriod)
defer func() {
ticker.Stop()
c.conn.Close()
}()
for {
select {
case message, ok := <-c.send:
c.conn.SetWriteDeadline(time.Now().Add(writeWait))
// CLOSE
if !ok {
c.conn.WriteMessage(websocket.CloseMessage, []byte{})
return
}
w, err := c.conn.NextWriter(websocket.BinaryMessage)
if err != nil {
LogErr("c.conn.NextWriter", err)
return
}
w.Write(message)
// Add queued chat messages to the current websocket message.
n := len(c.send)
for i := 0; i < n; i++ {
w.Write(newline)
w.Write(<-c.send)
}
if err := w.Close(); err != nil {
LogErr("w.Close()", err)
return
}
case <-ticker.C:
c.conn.SetWriteDeadline(time.Now().Add(writeWait))
if err := c.conn.WriteMessage(websocket.PingMessage, nil); err != nil {
LogErr("c.conn.WriteMessage()", err)
return
}
}
}
}
LogErr() 方法不打印任何消息。完全迷失在这里。
最佳答案
应用程序在循环的每次迭代中读取两条消息,并尝试将两条消息解码为注释
。仅阅读一条消息。
应用程序错误地调用了 ReadJSON
和 Unmarshal
,这些函数返回的错误解释了原因:应用程序正在尝试解码到非指针。
应用程序还将消息的原始字节发送到 channel 。这看起来可能是您正在复制的内容的剩余部分,所以我将在答案的其余部分中忽略它。
这是固定循环:
for {
var comment Comment
err = c.conn.ReadJSON(&comment)
if err != nil {
if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
LogErr("IsUnexpectedCloseError()", err)
}
break
}
// Do something with comment
}
关于Gorilla websocket 如何将二进制数据解码为 JSON?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53179657/