Method Client

internal/nodes/http_client_pool.go:52–228

Client 根据地址获取客户端

(req *HTTPRequest,
	origin *serverconfigs.OriginConfig,
	originAddr string,
	proxyProtocol *serverconfigs.ProxyProtocolConfig,
	followRedirects bool)

// Client 根据地址获取客户端
func (this *HTTPClientPool) Client(req *HTTPRequest,
	origin *serverconfigs.OriginConfig,
	originAddr string,
	proxyProtocol *serverconfigs.ProxyProtocolConfig,
	followRedirects bool) (rawClient *http.Client, err error) {
	if origin.Addr == nil {
		return nil, errors.New("origin addr should not be empty (originId:" + strconv.FormatInt(origin.Id, 10) + ")")
	}

	if req == nil || req.RawReq == nil || req.RawReq.URL == nil {
		err = errors.New("invalid request url")
		return
	}
	var originHost = req.RawReq.URL.Host
	var urlPort = req.RawReq.URL.Port()
	if len(urlPort) == 0 {
		if req.RawReq.URL.Scheme == "http" {
			urlPort = "80"
		} else {
			urlPort = "443"
		}

		originHost += ":" + urlPort
	}

	var rawKey = origin.UniqueKey() + "@" + originAddr + "@" + originHost

	// if we are under available ProxyProtocol, we add client ip to key to make every client unique
	var isProxyProtocol = false
	if proxyProtocol != nil && proxyProtocol.IsOn {
		rawKey += httpClientProxyProtocolTag + req.requestRemoteAddr(true)
		isProxyProtocol = true
	}

	// follow redirects
	if followRedirects {
		rawKey += "@follow"
	}

	var key = xxhash.Sum64String(rawKey)

	var isLnRequest = origin.Id == 0

	this.locker.RLock()
	client, found := this.clientsMap[key]
	this.locker.RUnlock()
	if found {
		client.UpdateAccessTime()
		return client.RawClient(), nil
	}

	// 这里不能使用RLock，避免因为并发生成多个同样的client实例
	this.locker.Lock()
	defer this.locker.Unlock()

	// 再次查找
	client, found = this.clientsMap[key]
	if found {