Gorilla websocket 如何将二进制数据解组为 JSON？

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《Gorilla websocket 如何将二进制数据解组为 JSON？》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

我正在遵循 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() 方法不打印任何消息。完全迷失在这里。

解决方案

应用程序在循环的每次迭代中读取两条消息，并尝试将两条消息解组为 comment。仅阅读一条消息。

应用程序错误地调用 readjson 和 unmarshal，这些函数返回的错误解释了原因：应用程序正在尝试解组到非指针。

应用程序还将消息的原始字节发送到通道。这看起来可能是您正在复制的内容的剩余部分，所以我将在答案的其余部分中忽略它。

这是固定循环：

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？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！