回滚nk

src/benchmark/js_sensor.go

+package main
+
+import (
+	"fmt"
+	"io"
+	"net/http"
+	"strings"
+	"sync"
+	"time"
+)
+
+var (
+	// 计数器
+	count int
+	// count 变量的互斥锁
+	countMux sync.Mutex
+)
+
+// 返回当前计数器的值
+func Count() int {
+	countMux.Lock()
+	defer countMux.Unlock()
+	return count
+}
+
+// 对计数器的值加一
+func IncCount() {
+	countMux.Lock()
+	defer countMux.Unlock()
+	count++
+}
+
+func abckSensor() {
+	abck := "B9E0C674552DB391815F82C0647FADC9~-1~YAAQBGUzuBl9/72GAQAAyb94wAm4ydH5I2znFxoyfaPIvHOHSyqXZHzgQ7m2RkagTpBzztNa5LmNFcqg4DNXEm/tZ+r1JxOWYfLY1EA5bzEvauFo6puMeVBuo4HdbMVfmxlwKaZpIQRNtUq0Z1wEmw2rrWetb3RktDypg1QT1tuF/hnXMQseB7YMYUY2Gku1MCLDlJF3wgsm6+tXjbhbqG0RR5IKiv3My4Q5kx2JEGDFV+X/RgB5wQz1ggUsipMSyDhrqlBsYhuMxyOzZNUQX29HuKZZjKTF3omqkyGJIrMhWz7yQ3fwlKrTYjswHxIX/GP4rZqWUL3m0Zhnhu/SrZipSJOLtKbgTwTuQS+iAXNP5DsSVGL0s8+nMrQNuIVyCNUZg3nxRRjgDx/+AvYppn2xiwW/tkuOAYIbtFRkirM5J9U=~-1~||1-EAjzIUtDUl-2250-10-1000-2||~-"
+	bm_sz := "F7BF54E40B51C55E0818DC07CD173D3D~YAAQtto4fZOUjTaGAQAAu2TuXRLag7FMMOcGVWfM6R1TuxY9u8Z+UDLtA8qE03/kyE1u1gycaSyEWy9GEbaHoyc2CT7Gqokpc8mxNY8qoEITjbsXZlhLE9Zm2K7ekUb1wAsxocavW2rsJTBvlEfYAcPs6/04ASA1QueCbMErtMm5Jqg7MnPVmCym75ewsP6qihOts07wgEWNkbSsdaHzQf4cm3uHxirh3o91GojyUSGrxRcFRn4NJlQtxIX/PrOsUr4HyxcYTAX+WUh6QyBCzGQ4pNgiszuc4R9OdAy3XGc6LzUP7PBIl5fz6OpZUj2gTJT2j5WPOn2I469jdYrZCAMoajftNJ9nrdy36vkz9S+Xp3z7dh9btp+Q+bpRYd1M9zhtmlmHxTTSv7rs6sOBHE/tmvEHXtc=~3748403~3683895"
+
+	for i := 0; i < 4; i++ {
+		//abck, bm_sz := getCookie(client)
+		datas := fmt.Sprintf("times=%d&abck=%s&bm_sz=%s&url=%s", i, abck, bm_sz, "https://www.spirit.com/")
+		r, err := http.Post("http://127.0.0.1:3033/akm2t", "application/x-www-form-urlencoded", strings.NewReader(datas))
+		if err != nil {
+			return
+		}
+		io.ReadAll(r.Body)
+		IncCount()
+		//rsss := strings.Split(string(rs), "|||||")
+		//sensorData := rsss[0]
+		//UA := rsss[1]
+		//fmt.Println(rs[:10])
+		//if i == 2 {
+		//sensorData, UA := sensor.GenData(i, abck, bm_sz, "https://www.spirit.com/")
+		//}
+		//fmt.Println("ua", UA)
+		//sensor := "{\"sensor_data\":\"" + sensorData + "\"}"
+		//req, _ := http.NewRequest("POST", "https://www.spirit.com"+sensorurl, strings.NewReader(sensor))
+		//req.Header.Set("authority", "www.spirit.com")
+		//req.Header.Set("accept", "*/*")
+		//req.Header.Set("accept-language", "q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6")
+		//req.Header.Set("cache-control", "no-cache")
+		//req.Header.Set("content-type", "text/plain;charset=UTF-8")
+		//req.Header.Set("origin", "https://www.spirit.com")
+		//req.Header.Set("pragma", "no-cache")
+		//req.Header.Set("referer", "https://www.spirit.com/")
+		//req.Header.Set("user-agent", UA)
+		//resp, err := client.Do(req)
+		//if err != nil {
+		//	log.Println("网络出错")
+		//}
+		//defer resp.Body.Close()
+		////readBytes, _ := io.ReadAll(resp.Body)
+		////fmt.Println(string(readBytes))
+		//for _, cookie := range resp.Cookies() {
+		//	fmt.Println(cookie.Name, len(cookie.Value))
+		//}
+	}
+}
+
+func main() {
+
+	for i := 0; i < 10; i++ {
+		wg := &sync.WaitGroup{}
+		t1 := time.Now()
+		for i := 0; i < 2000; i++ {
+			wg.Add(1)
+			go func() {
+				abckSensor()
+				wg.Done()
+			}()
+		}
+		wg.Wait()
+		fmt.Println("cost", time.Since(t1).String(), "count ", Count())
+	}
+
+}

src/run.sh

 export GOPROXY=https://goproxy.cn
-cd /root/src/js  && nohup /usr/local/bin/node run.js > 1.log 2>&1 &
+cd /root/src/js && npm i && nohup /usr/local/bin/node run.js > 1.log 2>&1 &
 cd /root/src && go run main.go
\ No newline at end of file

src/test/test.go

@@ -150,8 +150,8 @@ func actVY() {
 }
 func actnk() {
 	t1 := time.Now()
-	resp, err := http.Post("http://lcc.unififi.com/akamai/gen",
-		//resp, err := http.Post("http://127.0.0.1:59001/akamai/gen",
+	//resp, err := http.Post("http://lcc.unififi.com/akamai/gen",
+	resp, err := http.Post("http://127.0.0.1:59001/akamai/gen",
 		"application/json", strings.NewReader("{\"type\": \"NK\", \"proxy\": \"http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600\"}"))
 	//"application/json", strings.NewReader("{\"type\": \"U2\", \"proxy\": \"http://127.0.0.1:8890\"}"))
 	//resp, err := http.Post("http://127.0.0.1:59001/akamai/gen", "application/json", strings.NewReader("{\"type\": \"u2\", \"proxy\": \"http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600\"}"))

src/test/testnk.go

@@ -43,7 +43,7 @@ func abckSensor(client tls_client.HttpClient, sensorurl string) {
 		sensorData := rsss[0]
 		UA = rsss[1]
 		//if i == 2 {
-		//	sensorData, UA = sensor.GenData(i, abck, bm_sz, "https://www.spirit.com/")
+		//sensorData, UA := sensor.GenData(i, abck, bm_sz, "https://www.spirit.com/")
 		//}
 		fmt.Println("ua", UA)
 		sensor := "{\"sensor_data\":\"" + sensorData + "\"}"