Method SendBuffMsg

znet/ws_connection.go:434–477

SendBuffMsg sends BuffMsg

(msgID uint32, data []byte, opts ...ziface.MsgSendOption)

// SendBuffMsg sends BuffMsg
func (c *WsConnection) SendBuffMsg(msgID uint32, data []byte, opts ...ziface.MsgSendOption) error {
	c.msgLock.Lock()
	defer c.msgLock.Unlock()

	if c.msgBuffChan == nil {
		c.msgBuffChan = make(chan []byte, zconf.GlobalObject.MaxMsgChanLen)
		// Start the Goroutine for writing back to the client data stream
		// This method only reads data from MsgBuffChan, allocating memory and starting Goroutine without calling SendBuffMsg
		// (开启用于写回客户端数据流程的Goroutine
		// 此方法只读取MsgBuffChan中的数据没调用SendBuffMsg可以分配内存和启用协程)
		go c.StartWriter()
	}

	opt := ziface.MsgSendOptionObj{
		Timeout: 5 * time.Millisecond,
	}

	for _, o := range opts {
		o(&opt)
	}

	idleTimeout := time.NewTimer(opt.Timeout)
	defer idleTimeout.Stop()

	if c.isClosed == true {
		return errors.New("WsConnection closed when send buff msg")
	}

	// Package data and send
	// (将data封包，并且发送)
	msg, err := c.packet.Pack(zpack.NewMsgPackage(msgID, data))
	if err != nil {
		zlog.Ins().ErrorF("Pack error msg ID = %d", msgID)
		return errors.New("Pack error msg ")
	}

	// Send timeout
	select {
	case <-idleTimeout.C:
		return errors.New("send buff msg timeout")
	case c.msgBuffChan <- msg:
		return nil
	}
}

func (c *WsConnection) SetProperty(key string, value interface{}) {
	c.propertyLock.Lock()