Method netLoop

client/network.go:334–429

netLoop 通过循环来不停接收数据包

()

// netLoop 通过循环来不停接收数据包
func (c *QQClient) netLoop() {
	errCount := 0
	for c.alive {
		l, err := c.TCP.ReadInt32()
		if err != nil {
			time.Sleep(time.Millisecond * 500)
			continue
		}
		if l < 4 || l > 1024*1024*10 { // max 10MB
			c.error("parse incoming packet error: invalid packet length %v", l)
			errCount++
			if errCount > 2 {
				go c.quickReconnect()
			}
			continue
		}
		data, _ := c.TCP.ReadBytes(int(l) - 4)
		resp, err := c.transport.ReadResponse(data)
		// pkt, err := packets.ParseIncomingPacket(data, c.sig.D2Key)
		if err != nil {
			switch {
			case errors.Is(err, network.ErrSessionExpired) || errors.Is(err, network.ErrAuthenticationFailed):
				// 返回错误
				go func() {
					if f, ok := c.handlers.LoadAndDelete(uint32(resp.SequenceID)); ok {
						// does not need decoder
						f.fun(nil, err)
					}
				}()
			case errors.Is(err, network.ErrPacketDropped):
				fallthrough
			default:
				c.error("parse incoming packet error: %v", err)
				c.Disconnect()
				go c.DisconnectedEvent.dispatch(c, &DisconnectedEvent{Message: err.Error()})
				continue
			}
			errCount++
			if errCount > 2 {
				go c.quickReconnect()
			}
			continue
		}
		if resp.EncryptType == network.EncryptTypeEmptyKey && strings.HasPrefix(resp.CommandName, "wtlogin") {
			m, err := c.oicq.Unmarshal(resp.Body)
			if err != nil {
				c.error("decrypt payload error: %v", err)
				if errors.Is(err, oicq.ErrUnknownFlag) {
					go c.quickReconnect()
				}
				continue
			}
			resp.Body = m.Body
		}
		errCount = 0
		c.debug("rev pkt: %v seq: %v", resp.CommandName, resp.SequenceID)
		c.stat.PacketReceived.Add(1)
		pkt := &network.Packet{