fumiama/zbpdata
1
0
Fork 0
mirror of https://github.com/FloatTech/zbpdata.git synced 2025-06-08 07:10:51 +09:00
Code

feat: support multi-addrs

Browse Source
This commit is contained in:
源文雨 2025-05-31 03:53:48 +09:00
parent ca3652920a
commit 74c5464a0b
1 changed files with 28 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
main.go
View File

@ -9,6 +9,7 @@ import (
"flag"
"fmt"
"io/fs"
"net"
"os"
"strings"
"unicode"
@ -57,30 +58,37 @@ func main() {
*(*unsafe.Pointer)(unsafe.Pointer(&md5s[i])) = unsafe.Pointer(&buf)
*(*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"))
err = r.Connect()
names, err := net.LookupAddr("reilia.fumiama.top")
if err != nil {
panic(err)
}
for i, fn := range files {
for c := 0; c < 16; c++ {
err = r.Set("data/"+fn, md5s[i])
fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
if err == nil {
break
}
if c >= 15 {
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)
for _, nm := range names {
fmt.Println("推送到:", nm)
r := registry.NewRegedit(net.JoinHostPort(nm, "32664"), "", "fumiama", os.Getenv("REILIA_SPS"))
err = r.Connect()
if err != nil {
panic(err)
}
for i, fn := range files {
for c := 0; c < 16; c++ {
err = r.Set("data/"+fn, md5s[i])
fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
if err == nil {
break
}
if c >= 15 {
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()
}