Function NewTransport

thirdlib/gdylib/httputils/common.go:119–272

NewTransport transportNetwork 网络类型 tcp tcp4 tcp6 localAddr 指定网卡出口

(transportNetwork,
	localAddrStr string,
	secureSkipVerify bool,
	proxyType,
	proxyUrl,
	user,
	passwd string)

// transportNetwork 网络类型 tcp tcp4 tcp6
// localAddr 指定网卡出口
func NewTransport(transportNetwork,
	localAddrStr string,
	secureSkipVerify bool,
	proxyType,
	proxyUrl,
	user,
	passwd string) (*http.Transport, error) {
	var transport *http.Transport
	proxyType = strings.ToLower(proxyType)
	ti := transportIt{
		Network:          transportNetwork,
		LocalAddr:        localAddrStr,
		ProxyType:        proxyType,
		ProxyUrl:         proxyUrl,
		User:             user,
		Passwd:           passwd,
		SecureSkipVerify: secureSkipVerify}

	globalTransportMapMutex.Lock()
	defer globalTransportMapMutex.Unlock()

	tr, ok := globalTransportMap[ti.String()]
	if ok {
		//log.Printf("map[%s]已存在", ti.String())
		return tr, nil
	}
	//log.Printf("map[%s]未存在", ti.String())

	switch proxyType {
	case "http", "https":
		{
			//log.Printf("http proxy Transport network:%s", transportNetwork)
			if !strings.Contains(proxyUrl, "http") {
				proxyUrl = fmt.Sprintf("%s://%s", proxyType, proxyUrl)
			}
			urlProxy, err := url.Parse(proxyUrl)
			if err != nil {
				return nil, fmt.Errorf("NewTransport=>proxy url.Parse error:%s", err.Error())
			}

			if user != "" && passwd != "" {
				urlProxy.User = url.UserPassword(user, passwd)
			}

			var localAddr net.Addr
			localAddr = nil

			if localAddrStr != "" {
				lAddr, err := net.ResolveTCPAddr(transportNetwork, localAddrStr+":0")
				if err != nil {
					return nil, fmt.Errorf("NewTransport=> ResolveTCPAddr localAddr:%s error:%s", localAddrStr, err.Error())
				}
				localAddr = lAddr
			}

			dialer := (&net.Dialer{
				Timeout:   30 * time.Second,
				KeepAlive: 30 * time.Second,