Method StartReader

znet/ws_connection.go:210–272

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

()

// StartReader is a Goroutine that reads messages from the client.
// (StartReader 读消息Goroutine，用于从客户端中读取数据)
func (c *WsConnection) StartReader() {
	zlog.Ins().InfoF("[Reader Goroutine is running]")
	defer zlog.Ins().InfoF("%s [conn Reader exit!]", c.RemoteAddr().String())
	defer c.Stop()

	// Create a pack-unpack object. (创建拆包解包的对象)
	for {
		select {
		case <-c.ctx.Done():
			return
		default:
			// add by uuxia 2023-02-03
			// Read data from the conn's IO to the memory buffer.
			// (从conn的IO中读取数据到内存缓冲buffer中)
			messageType, buffer, err := c.conn.ReadMessage()
			if err != nil {
				c.cancel()
				return
			}
			if messageType == websocket.PingMessage {
				c.updateActivity()
				continue
			}
			n := len(buffer)
			if err != nil {
				zlog.Ins().ErrorF("read msg head [read datalen=%d], error = %s", n, err.Error())
				return
			}
			zlog.Ins().DebugF("read buffer %s \n", hex.EncodeToString(buffer[0:n]))

			// Update the Active status of heartbeat detection normally after reading data from the peer.
			// (正常读取到对端数据，更新心跳检测Active状态)
			if n > 0 && c.hc != nil {
				c.updateActivity()
			}

			// Handle custom protocol fragmentation and packet sticking issues add by uuxia 2023-03-21
			// (处理自定义协议断粘包问题)
			if c.frameDecoder != nil {
				// Decode the 0-n bytes of data read.
				// (为读取到的0-n个字节的数据进行解码)
				bufArrays := c.frameDecoder.Decode(buffer)
				if bufArrays == nil {
					continue
				}
				for _, bytes := range bufArrays {
					zlog.Ins().DebugF("read buffer %s \n", hex.EncodeToString(bytes))
					msg := zpack.NewMessage(uint32(len(bytes)), bytes)
					// Get the Request data requested by the current client.
					// (得到当前客户端请求的Request数据)
					req := GetRequest(c, msg)
					c.msgHandler.Execute(req)
				}
			} else {
				msg := zpack.NewMessage(uint32(n), buffer[0:n])
				// Get the Request data requested by the current client.
				// (得到当前客户端请求的Request数据)
				req := GetRequest(c, msg)