超时处理

model/easyjet.go

@@ -66,7 +66,7 @@ func (c *AkmClient) PostJson(times int, url, data string) (int, error) {
 			"user-agent",
 		},
 	}
-	for i := 0; i < 3; i++ {
+	for i := 0; i < 1; i++ {
 		startTime := time.Now()
 		response, err := c.Client.Do(req)
 		if err != nil {

test/test.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	http "github.com/bogdanfinn/fhttp"
 	tls_client "github.com/bogdanfinn/tls-client"
-	"io"
 	"io/ioutil"
 	"net/url"
 	"strings"
@@ -25,8 +24,8 @@ func query(data []byte) {
 		tls_client.WithClientProfile(tls_client.Chrome_110),
 		tls_client.WithNotFollowRedirects(),
 		tls_client.WithCookieJar(jar), // create cookieJar instance and pass it as argument
-		//tls_client.WithProxyUrl("http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600"),
-		tls_client.WithProxyUrl("http://127.0.0.1:8888"),
+		tls_client.WithProxyUrl("http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600"),
+		//tls_client.WithProxyUrl("http://127.0.0.1:8888"),
 		tls_client.WithInsecureSkipVerify(),
 	}
 	uri, _ := url.Parse("https://www.easyjet.com/")
@@ -60,8 +59,8 @@ func query(data []byte) {
 	}
 	defer resp.Body.Close()
 	fmt.Println("响应结果", resp.StatusCode)
-	readBytes, _ := io.ReadAll(resp.Body)
-	fmt.Println(string(readBytes))
+	//readBytes, _ := io.ReadAll(resp.Body)
+	//fmt.Println(string(readBytes))
 
 }
 func main() {
@@ -69,7 +68,7 @@ func main() {
 		t1 := time.Now()
 		fmt.Println(t1)
 		wg := sync.WaitGroup{}
-		for i := 0; i < 1; i++ {
+		for i := 0; i < 10; i++ {
 			wg.Add(1)
 			go func() {
 				defer wg.Done()
@@ -78,7 +77,7 @@ func main() {
 				//resp, err := http.Get("http://127.0.0.1:9999/ping")
 				//resp, err := http.Post("http://lcc.unififi.com/proxy/get-proxy", "application/json", strings.NewReader("{\n  \"name\": \"NK\",\n  \"type\": \"shopping\"\n}"))
 				t1 := time.Now()
-				resp, err := http.Post("http://127.0.0.1:19999/akamai/gen", "application/json", strings.NewReader("{\"type\": \"u2\", \"proxy\": \"http://127.0.0.1:8888\"}"))
+				resp, err := http.Post("http://127.0.0.1:19999/akamai/gen", "application/json", strings.NewReader("{\"type\": \"u2\", \"proxy\": \"http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600\"}"))
 				if err != nil {
 					//panic(err)
 					fmt.Println(err)