1
0
mirror of https://github.com/FloatTech/zbpdata.git synced 2025-06-28 23:47:46 +09:00

Compare commits

...

3 Commits

Author SHA1 Message Date
源文雨
4f751a1cda feat: support multi-addrs 2025-05-31 04:10:30 +09:00
源文雨
f97dac5ce0 feat: support multi-addrs 2025-05-31 04:01:55 +09:00
源文雨
74c5464a0b feat: support multi-addrs 2025-05-31 03:53:48 +09:00

49
main.go
View File

@ -9,6 +9,7 @@ import (
"flag" "flag"
"fmt" "fmt"
"io/fs" "io/fs"
"net"
"os" "os"
"strings" "strings"
"unicode" "unicode"
@ -57,30 +58,38 @@ func main() {
*(*unsafe.Pointer)(unsafe.Pointer(&md5s[i])) = unsafe.Pointer(&buf) *(*unsafe.Pointer)(unsafe.Pointer(&md5s[i])) = unsafe.Pointer(&buf)
*(*uintptr)(unsafe.Add(unsafe.Pointer(&md5s[i]), unsafe.Sizeof(uintptr(0)))) = uintptr(16) *(*uintptr)(unsafe.Add(unsafe.Pointer(&md5s[i]), unsafe.Sizeof(uintptr(0)))) = uintptr(16)
} }
r := registry.NewRegedit("reilia.fumiama.top:32664", "", "fumiama", os.Getenv("REILIA_SPS")) hosts, err := net.LookupHost("reilia.fumiama.top")
err = r.Connect()
if err != nil { if err != nil {
panic(err) panic(err)
} }
for i, fn := range files { for _, h := range hosts {
for c := 0; c < 16; c++ { fmt.Println("推送到:", h)
err = r.Set("data/"+fn, md5s[i]) r := registry.NewRegedit(net.JoinHostPort(h, "32664"), "", "fumiama", os.Getenv("REILIA_SPS"))
fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i]))) err = r.Connect()
if err == nil { if err != nil {
break fmt.Println(err)
} continue
if c >= 15 { }
panic("ERROR:" + err.Error() + ", max retry times exceeded") for i, fn := range files {
} else { for c := 0; c < 16; c++ {
fmt.Println("ERROR:", err, ", retry times:", c) err = r.Set("data/"+fn, md5s[i])
} fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
_ = r.Close() if err == nil {
process.SleepAbout1sTo2s() break
err = r.Connect() }
if err != nil { if c >= 15 {
panic(err) panic("ERROR:" + err.Error() + ", max retry times exceeded")
} else {
fmt.Println("ERROR:", err, ", retry times:", c)
}
_ = r.Close()
process.SleepAbout1sTo2s()
err = r.Connect()
if err != nil {
panic(err)
}
} }
} }
_ = r.Close()
} }
_ = r.Close()
} }