Method SendMessage

gate/server.go:278–296

SendMessage 发送消息

(ctx context.Context, req *meta.GateSendMessageRequest)

// SendMessage 发送消息
func (g *Gate) SendMessage(ctx context.Context, req *meta.GateSendMessageRequest) (*meta.GateSendMessageResponse, error) {
	s, err := g.getSession(ctx)
	if err != nil {
		return &meta.GateSendMessageResponse{Header: &meta.ResponseHeader{Code: util.ErrorGetSession, Msg: err.Error()}}, nil
	}

	if req.Msg.ID, err = g.master.NewID(); err != nil {
		return &meta.GateSendMessageResponse{Header: &meta.ResponseHeader{Code: -1, Msg: err.Error()}}, nil
	}

	//防止乱写
	req.Msg.From = s.getID()

	if err = g.store.newMessage(req.Msg); err != nil {
		return &meta.GateSendMessageResponse{Header: &meta.ResponseHeader{Code: util.ErrorNewMessage, Msg: err.Error()}}, nil
	}

	return &meta.GateSendMessageResponse{Id: req.Msg.ID}, nil
}

// Ready 连接成功后立刻调用Ready, 开启推送
func (g *Gate) Ready(msg *meta.Message, stream meta.Gate_ReadyServer) error {