package ws import "encoding/json" type Message struct { Type string `json:"type"` // 对应处理函数 / sync 同步函数,存入数据库 / msg 发送消息,不存入数据库 / login 登录校验某个客户是否存在 From string `json:"-"` // 发送方 ==> 自行处理, 无需发送 Dest int64 `json:"dest"` // 目标id / 0 代表所有 非0代表某一个 Tag string `json:"tag"` // 目标类型 customer代表客户 user代表用户 entry代表录入人员 RoomId string `json:"room_id"` // 房间id // activity_id Data map[string]interface{} `json:"data"` } func (m *Message) Encode() []byte { buf, _ := json.Marshal(m) return buf } func (m *Message) Decode(buf []byte) error { return json.Unmarshal(buf, m) }