pubnub 服务返回的消息常为包含多层嵌套、类型不统一的 json 数组（如 [[{...}], "msg-id", "channel"]），go 原生结构体无法直接反序列化此类非同质数组，需自定义 unmarshaljson 方法实现灵活解析。
PubNub 的默认消息格式并非标准对象（object），而是一个三元素数组：
- 首元素：消息体数组（可能含多个 { "text": "..." } 等对象）；
- 次元素：消息唯一 ID（字符串）；
- 末元素：所属频道名（字符串）。
由于 JSON 数组中混合了 []interface{}、string 等不同类型的值，直接绑定到结构体字段会触发 json: cannot unmarshal array into Go value of type ... 错误。因此，必须绕过默认解码逻辑，手动控制解析流程。
✅ 推荐方案：实现 UnmarshalJSON 方法
以下是一个健壮、可扩展的实现示例（含基础类型校验）：
package main
import (
"encoding/json"
"fmt"
"errors"
)
type TextMessage struct {
Text string `json:"text"`
}
type PubNubMessage struct {
Messages []TextMessage `json:"messages"` // 语义化字段名，便于后续使用
ID string `json:"id"`
Channel string `json:"channel"`
}
func (p *PubNubMessage) UnmarshalJSON(data []byte) error {
// 第一步：将整个 JSON 解析为顶层 interface{} 切片
var arr []interface{}
if err := json.Unmarshal(data, &arr); err != nil {
return fmt.Errorf("failed to unmarshal top-level array: %w", err)
}
if len(arr) != 3 {
return errors.New("expected exactly 3 elements in PubNub message array")
}
// 第二步：解析首元素 —— 消息体数组
messagesArr, ok := arr[0].([]interface{})
if !ok {
return errors.New("first element must be a JSON array of messages")
}
p.Messages = make([]TextMessage, 0, len(messagesArr))
for i, msgItem := range messagesArr {
msgMap, ok := msgItem.(map[string]interface{})
if !ok {
return fmt.Errorf("message at index %d is not a JSON object", i)
}
text, ok := msgMap["text"].(string)
if !ok {
return fmt.Errorf("message at index %d missing or invalid 'text' field", i)
}
p.Messages = append(p.Messages, TextMessage{Text: text})
}
// 第三步：解析第二、三元素（ID 和 channel）
id, ok := arr[1].(string)
if !ok {
return errors.New("second element (message ID) must be a string")
}
p.ID = id
channel, ok := arr[2].(string)
if !ok {
return errors.New("third element (channel name) must be a string")
}
p.Channel = channel
return nil
}
// 使用示例
func main() {
jsonStr := `[[{"text":"hey"},{"text":"ok"}],"1231212412423235","channelName"]`
var msg PubNubMessage
if err := json.Unmarshal([]byte(jsonStr), &msg); err != nil {
panic(err)
}
fmt.Printf("Parsed: %+v\n", msg)
// 输出：Parsed: {Messages:[{Text:"hey"} {Text:"ok"}] ID:"1231212412423235" Channel:"channelName"}
}⚠️ 注意事项与最佳实践
- 永远避免裸 .(type) 断言：生产代码中务必配合 ok 判断（如 v, ok := x.(string)），否则 panic 风险极高；
- 考虑泛型扩展性：若消息结构多样（如含 image_url、user_id 等），可将 TextMessage 替换为泛型结构或使用 json.RawMessage 延迟解析；
- 兼容未来变更：PubNub 可能升级消息格式（如增加时间戳字段），建议在 UnmarshalJSON 中预留容错逻辑（如忽略未知索引）或采用版本标识字段；
- 性能考量：该方法涉及多次类型断言和中间 interface{} 分配，高频场景下可改用 json.Decoder 流式解析或预编译 *json.RawMessage 缓存。
通过自定义 UnmarshalJSON，你不仅能精准适配 PubNub 的数组协议，也为处理其他非标准 JSON API 提供了通用范式——核心在于：当结构不可预测时，先“软解析”再“强校验”，而非强求一次性直译。
