hdws/ws/message.go

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)
}