package main
/**
* 羊了個羊小程式通關腳本
*
* max := 10000 // 通關次數
* concurrency = 20 // 控制并發量
* param.Set("t", "") // 登入token-自行抓包擷取(必須設定)
*
* @author thinklxr
*/
import (
"fmt"
"io/ioutil"
"net/http"
"net/url"
"sync"
"time"
)
type Limit struct {
number int
channel chan struct{}
}
// Limit struct 初始化
func New(number int) *Limit {
return &Limit{
number: number,
channel: make(chan struct{}, number),
}
}
// Run 方法:建立有限的 go f 函數的 goroutine
func (limit *Limit) Run(f func()) {
limit.channel <- struct{}{}
go func() {
f()
<-limit.channel
}()
}
// WaitGroup 對象内部有一個計數器,從0開始
// 有三個方法:Add(), Done(), Wait() 用來控制計數器的數量
var wg = sync.WaitGroup{}
const (
concurrency = 20 // 控制并發量
)
func main() {
start := time.Now()
limit := New(concurrency) // New Limit 控制并發量
// 接口請求URL
apiUrl := "https://cat-match.easygame2021.com/sheep/v1/game/game_over"
max := 50000 // 通關次數
// 初始化參數
param := url.Values{}
param.Set("rank_score", "1")
param.Set("rank_state", "1")
param.Set("rank_time", "888")
param.Set("rank_role", "1")
param.Set("skin", "1")
param.Set("t", "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE2OTQ1OTQxNzIsIm5iZiI6MTY2MzQ5MTk3MiwiaWF0IjoxNjYzNDkwMTcyLCJqdGkiOiJDTTpjYXRfbWF0Y2g6bHQxMjM0NTYiLCJvcGVuX2lkIjoiIiwidWlkIjo5NjgzMjMzMSwiZGVidWciOiIiLCJsYW5nIjoiIn0.XpajPZ-_9lTC-yYLpVQYi1rXz_9sgy5WYUEJQi3Q07k")
for i := 0; i < max; i++ {
wg.Add(1)
value := i
goFunc := func() {
fmt.Printf("start func: %d\n", value)
data, err := Get(apiUrl, param)
if err != nil {
fmt.Println(err)
return
}
// 其它邏輯代碼...
fmt.Println(string(data))
wg.Done()
}
limit.Run(goFunc)
}
// 阻塞代碼防止退出
wg.Wait()
fmt.Printf("耗時: %fs", time.Now().Sub(start).Seconds())
}
// Get 方式發起網絡請求
func Get(apiURL string, params url.Values) (rs []byte, err error) {
var Url *url.URL
Url, err = url.Parse(apiURL)
if err != nil {
fmt.Printf("解析url錯誤:\r\n%v", err)
return nil, err
}
//如果參數中有中文參數,這個方法會進行URLEncode
Url.RawQuery = params.Encode()
resp, err := http.Get(Url.String())
if err != nil {
fmt.Println("err:", err)
return nil, err
}
defer resp.Body.Close()
return ioutil.ReadAll(resp.Body)
}