Method DialTCP

common/session.go:37–66

DialTCP 创建 TCP 连接，内含限速检查、代理、计数

(ctx context.Context, network, address string, timeout time.Duration)

// DialTCP 创建 TCP 连接，内含限速检查、代理、计数
func (s *ScanSession) DialTCP(ctx context.Context, network, address string, timeout time.Duration) (net.Conn, error) {
	// 检查发包限制
	if ok, err := CanSendPacketWith(s.Config, s.State); !ok {
		LogError(fmt.Sprintf("TCP连接 %s 受限: %s", address, err.Error()))
		return nil, fmt.Errorf("发包受限: %s", err.Error())
	}

	// 获取 dialer
	dialer, err := s.getDialer()
	if err != nil {
		LogError(fmt.Sprintf("获取代理拨号器失败: %v", err))
		s.State.IncrementTCPFailedPacketCount()
		return nil, err
	}

	conn, err := dialer.DialContext(ctx, network, address)
	if err != nil {
		s.State.IncrementTCPFailedPacketCount()
		LogDebug(fmt.Sprintf("连接 %s 失败: %v", address, err))
		return nil, err
	}

	// SO_LINGER=0: 连接关闭时立即发送 RST，避免 TIME_WAIT 堆积
	if tc, ok := conn.(*net.TCPConn); ok {
		_ = tc.SetLinger(0)
	}

	s.State.IncrementTCPSuccessPacketCount()
	return conn, nil
}

func (s *ScanSession) getDialer() (proxy.Dialer, error) {
	s.dialerOnce.Do(func() {