Method SendToQueue

znet/connection.go:401–443

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

}

func (c *Connection) SendToQueue(data []byte, opts ...ziface.MsgSendOption) error {

	if c.msgBuffChan == nil && c.setStartWriterFlag() {
		c.msgBuffChan = make(chan []byte, zconf.GlobalObject.MaxMsgChanLen)
		// Start a Goroutine to write data back to the client
		// This method only reads data from the MsgBuffChan without allocating memory or starting a Goroutine
		// (开启用于写回客户端数据流程的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("Connection closed when send buff msg")
	}

	if data == nil {
		zlog.Ins().ErrorF("Pack data is nil")
		return errors.New("Pack data is nil")
	}

	// Send timeout
	select {
	case <-c.ctx.Done():
		// Close all channels associated with the connection
		close(c.msgBuffChan)
		return errors.New("connection closed when send buff msg")
	case <-idleTimeout.C:
		return errors.New("send buff msg timeout")
	case c.msgBuffChan <- data:
		return nil
	}
}

// SendMsg directly sends Message data to the remote TCP client.
// (直接将Message数据发送数据给远程的TCP客户端)