Gorilla websocket, как демонтировать двоичные данные в JSON? - PullRequest
Новая
       7

Gorilla websocket, как демонтировать двоичные данные в JSON?

0 голосов
/ 06 ноября 2018

Я следую примеру чата , предоставленному гориллой.

Я все еще могу разобрать отправленные данные 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 () не выводят никаких сообщений. Полностью потерянный здесь.

1 Ответ

0 голосов
/ 07 ноября 2018

Приложение читает два сообщения на каждой итерации в цикле и пытается разархивировать оба до 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
}
...