时间戳

首页 > 解决方案 > Golang Websocket 自定义 JSON 消息

go - Golang Websocket 自定义 JSON 消息

问题描述

我正在尝试发送/接收自定义 JSON 消息。JSON结构发生变化的情况有3种，因此我有3种不同的结构。我必须访问作为 RawMessage 发送的房间字符串。我的问题是频道广播应该是什么类型？

type Message struct {
    Type int64 `json:"type"`
    Msg  json.RawMessage
}

Broadcast chan interface{} // ??? RawMessage or maybe interface

          case m := <-r.Broadcast:
            // What type should chan Broadcast be?
            // If m is of type json.RawMessage should I deal with unmarshalling here?
            connections := r.Clients[m.Room] // 
            for c := range connections {
                select {
                case c.send <- m:
                default:
                    close(c.send)
                    delete(connections, c)
                    if len(connections) == 0 {
                        delete(r.Clients, m.Room)
                    }
                }
            }

for {
        msg := &Message{}
        err := c.conn.ReadJSON(&msg)
        // _, msg, err := c.conn.ReadMessage()
        if err != nil {
            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
                log.Printf("error: %v", err)
            }
            break
        }

        if msg.Type == 0 {
            newVideo := &NewVideo{}
            if err = json.Unmarshal(msg.Msg, &newVideo); err != nil {
                fmt.Println(err)
            }
            Roomb.Broadcast <- msg.Msg // ??? should i send the RawMessage
            online[msg.Room] = msg
        } else if msg.Type == 1 {
            if _, ok := online[msg.Room]; ok {
                online[msg.Room].Start = float64(time.Now().Unix() - online[msg.Room].Timestamp)
                c.send <- online[msg.Room]
            }
        } else if msg.Type == 2 {
            Roomb.Broadcast <- msg.Msg // ??? should i send the RawMessage
        }
        fmt.Println(msg)
    }

标签： gogorilla

解决方案

  1. 去掉前面的“&” msg。msg已经是一个指针。这可能会产生问题。

  2. 你的问题不是很清楚。如果msg.Type定义了msg.Msg是什么，那么我建议您使用实际消息类型输入通道，解析msg.Msg，然后通过通道发送它。

推荐阅读