Skip to content

L
lcc-akm
Commit 06f9dc9c authored by 王明明's avatar 王明明
Browse files
Options

Merge branch 'master' into fix_env 

# Conflicts:
#	src/test/testnk.go
parents 26105863 3c8a08e7
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 139 additions and 42 deletions
readme.md
View file @ 06f9dc9c
```shell
docker run -itd --name lcc-akm-api12 --privileged=true --restart=always -v /home/opt/lcc-akm2/src:/root/src/ -p 59002:59001 --cpus=1 -m 1G --log-driver=json-file --log-opt max-size=50m --log-opt max-file=3 golang/goenv:2.0 /bin/sh "/root/src/run.sh"
docker run -itd --name lcc-akm-api2 --privileged=true --restart=always -v /home/opt/lcc-akm2/src:/root/src/ -p 59002:59001 --cpus=1 -m 1G --log-driver=json-file --log-opt max-size=50m --log-opt max-file=3 golang/goenv:2.0 /bin/sh "/root/src/run.sh"
```
\ No newline at end of file
src/benchmark/js_sensor.go 0 → 100644
View file @ 06f9dc9c
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/js/run.js
View file @ 06f9dc9c
This diff is collapsed.
src/main.go
View file @ 06f9dc9c
package main
import (
"flag"
"fmt"
nested "github.com/antonfisher/nested-logrus-formatter"
"github.com/gorilla/mux"
"github.com/sirupsen/logrus"
"gopkg.in/natefinch/lumberjack.v2"
"io"
"log"
"net/http"
"os"
"path"
"test/model"
"test/util"
......@@ -20,6 +19,8 @@ func WelcomeHandler(w http.ResponseWriter, r *http.Request) {
}
func main() {
logname := flag.String("logname", "akm.log", "日志文件名")
flag.Parse()
logrus.SetLevel(logrus.TraceLevel)
//logrus.SetFormatter(&logrus.TextFormatter{
// //HideKeys: true,
......@@ -33,9 +34,10 @@ func main() {
NoColors: true,
})
logFilePath := util.GetCurrentAbPathByCaller()
logFileName := "akm.log"
fileName := path.Join(logFilePath, logFileName)
logFileName := *logname
fileName := path.Join(logFilePath, logFileName)
fmt.Println("日志文件路径 ", fileName)
// 写入文件
//src, err := os.OpenFile(fileName+".log", os.O_APPEND|os.O_WRONLY|os.O_CREATE, os.ModeAppend)
......@@ -57,8 +59,8 @@ func main() {
// 是否需要压缩滚动日志, 使用的 gzip 压缩
Compress: true, // disabled by default
}
//logrus.SetOutput(logWriter)
logrus.SetOutput(io.MultiWriter(os.Stdout, logWriter))
logrus.SetOutput(logWriter)
//logrus.SetOutput(io.MultiWriter(os.Stdout, logWriter))
//str := "<noscript><img src=\"https://www.easyjet.com/akam/13/pixel_7b9d10f9?a=dD1lMmMzOTBjM2M4NWUyYz\nkzNjljOTNhZDUyNmRkOGJjMDdjNjM2MWJmJmpzPW9mZg==\" style=\"visibility: hidden; position: absolu\nte; left: -999px; top: -999px;\" /></noscript><script type=\"text/javascript\" src=\"/-Hzovq/uluGM/jHPdr/v3N7/m5OOLVXmDOwY/NG4dCQE/Zy/lnEF9qaQI\"></script></body>\n</html>"
//str = "<noscript><img src=\"https://www.easyjet.com/akam/13/pixel_4ac30e0f?a=dD1kZmQ1ODJiODRhNzUxMzAzMDJmN\nTczMjdhMGVlZGEyNWM3MTcwNDY5JmpzPW9mZg==\" style=\"visibility: hidden; position: absolute; left: -999\npx; top: -999px;\" /></noscript><script type=\"text/javascript\" src=\"/9dz5yx/00N2ob/cHtIJhA/oGemj3/BA/SaOXNNXpVab5wO/PVZtb1s9Aw/by/ZID307CB8\"></script></body>\n"
//
......
src/run.sh
View file @ 06f9dc9c
export GOPROXY=https://goproxy.cn
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
cd /root/src/js && npm i && nohup /usr/local/bin/node --expose-gc --max-old-space-size=256 run.js > 1.log 2>&1 &
cd /root/src && go run main.go --logname=$logname
\ No newline at end of file
src/test/test.go
View file @ 06f9dc9c
......@@ -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
View file @ 06f9dc9c
......@@ -13,7 +13,6 @@ import (
"strconv"
"strings"
"sync"
"test/sensor"
)
func getCookie(client tls_client.HttpClient) (string, string) {
......@@ -37,14 +36,14 @@ var UA string
func abckSensor(client tls_client.HttpClient, sensorurl string) {
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, _ := http.Post("http://127.0.0.1:3033/akm2t", "application/x-www-form-urlencoded", strings.NewReader(datas))
//rs, _ := io.ReadAll(r.Body)
//rsss := strings.Split(string(rs), "|||||")
//sensorData := rsss[0]
//UA = rsss[1]
datas := fmt.Sprintf("times=%d&abck=%s&bm_sz=%s&url=%s", i, abck, bm_sz, "https://www.spirit.com/")
r, _ := http.Post("http://127.0.0.1:3033/akm2t", "application/x-www-form-urlencoded", strings.NewReader(datas))
rs, _ := io.ReadAll(r.Body)
rsss := strings.Split(string(rs), "|||||")
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 + "\"}"
......@@ -73,8 +72,6 @@ func abckSensor(client tls_client.HttpClient, sensorurl string) {
func main() {
wg := &sync.WaitGroup{}
println(sensor.Float64ToHex(1.2863))
for i := 0; i < 1; i++ {
wg.Add(1)
go func() {
......@@ -90,8 +87,8 @@ func main() {
tls_client.WithClientProfile(tls_client.Chrome_108),
tls_client.WithNotFollowRedirects(),
tls_client.WithCookieJar(jar), // create cookieJar instance and pass it as argument
tls_client.WithProxyUrl("http://127.0.0.1:8890"),
//tls_client.WithProxyUrl("http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600"),
//tls_client.WithProxyUrl("http://127.0.0.1:8890"),
tls_client.WithProxyUrl("http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600"),
//tls_client.WithProxyUrl(px),
//tls_client.WithInsecureSkipVerify(),
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment