Golang Websocket 自定义 JSON 消息

Question

我正在尝试 send/receive 自定义 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)
    }

Answer 1

去掉msg前的“&”。 msg 已经是一个指针。这可能会产生问题。
你的问题不是很清楚。如果 msg.Type 定义了 msg.Msg 是什么，那么我建议您使用实际消息类型创建频道，解析 msg.Msg，然后通过频道发送它。

Golang Websocket 自定义 JSON 消息

Golang Websocket Custom JSON Messages

go

gorilla