feat: 改为并行上传

:wrench:添加vup数据库

.github/workflows/release.yml

@@ -24,5 +24,6 @@ jobs:
         run: |
           ls
           go mod init updater
+          sed -i '1,3d' main.go
           go mod tidy
           go run main.go

.gitignore

@@ -18,4 +18,5 @@ scale
 .vscode
 MockingBird/cache
 driftbottle
-job
+job
+hyaku

main.go

@@ -1,3 +1,6 @@
+//go:build ignore
+// +build ignore
+
 package main
 
 import (
@@ -7,9 +10,11 @@ import (
 	"io/fs"
 	"os"
 	"strings"
+	"sync"
 	"unicode"
 	"unsafe"
 
+	"github.com/FloatTech/zbputils/process"
 	"github.com/fumiama/go-registry"
 	"github.com/wdvxdr1123/ZeroBot/utils/helper"
 )
@@ -41,12 +46,33 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	for i, fn := range files {
-		fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
-		err = r.Set("data/"+fn, md5s[i])
-		if err != nil {
-			panic(err)
+	defer r.Close()
+	for i := 0; i < 1024; i++ {
+		err = r.Set("__setlock__", "fill")
+		if err == nil {
+			break
 		}
+		fmt.Println("accqiring set lock, retry times:", i)
 	}
-	r.Close()
+	var wg sync.WaitGroup
+	wg.Add(len(files))
+	for i, fn := range files {
+		go func(i int, fn string) {
+			defer wg.Done()
+			for c := 0; c < 5; 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 >= 4 {
+					panic("ERROR:" + err.Error() + "max retry times exceeded")
+				} else {
+					fmt.Println("ERROR:", err, ", retry times:", c)
+				}
+				process.SleepAbout1sTo2s()
+			}
+		}(i, fn)
+	}
+	wg.Wait()
 }