Method StartWriter

znet/kcp_connection.go:189–210

StartWriter is the goroutine that writes messages to the client (写消息Goroutine， 用户将数据发送给客户端)

()

// StartWriter is the goroutine that writes messages to the client
// (写消息Goroutine， 用户将数据发送给客户端)
func (c *KcpConnection) StartWriter() {
	zlog.Ins().DebugF("Writer Goroutine is running")
	defer zlog.Ins().DebugF("%s [conn Writer exit!]", c.RemoteAddr().String())

	for {
		select {
		case data, ok := <-c.msgBuffChan:
			if ok {
				if err := c.Send(data); err != nil {
					zlog.Ins().ErrorF("Send Buff Data error:, %s Conn Writer exit", err)
					break
				}

			} else {
				zlog.Ins().ErrorF("msgBuffChan is Closed")
				break
			}
		case <-c.ctx.Done():
			return
		}
	}
}

// StartReader is a goroutine that reads data from the client
// (读消息Goroutine，用于从客户端中读取数据)