Merge pull request #24 from IceFireDB/feat_upgrade

feat(framework):update framework

.github/workflows/pages.yml

@@ -35,7 +35,7 @@ jobs:
     - name: Set up Go
       uses: actions/setup-go@v5
       with:
-        go-version: 1.18
+        go-version: 1.23.2
 
     - name: Build
       run: |

.gitignore

@@ -24,4 +24,5 @@ release_bin
 vendor
 
 #vscode
-.vscode
+.vscode
+example/memory_kv/memory_kv

example/memory_kv/server.go

@@ -15,51 +15,69 @@ import (
 )
 
 func main() {
+	// Define a mutex and a map to store data
 	var mu sync.RWMutex
 	var items = make(map[string][]byte)
+
+	// Define command-line arguments
 	var network string
 	var addr string
 	var multicore bool
 	var reusePort bool
 	var pprofDebug bool
 	var pprofAddr string
+
+	// Parse command-line arguments
 	flag.StringVar(&network, "network", "tcp", "server network (default \"tcp\")")
-	flag.StringVar(&addr, "addr", "127.0.0.1:6380", "server addr (default \":6380\")")
-	flag.BoolVar(&multicore, "multicore", true, "multicore")
-	flag.BoolVar(&reusePort, "reusePort", false, "reusePort")
-	flag.BoolVar(&pprofDebug, "pprofDebug", false, "open pprof")
+	flag.StringVar(&addr, "addr", "127.0.0.1:6380", "server address (default \":6380\")")
+	flag.BoolVar(&multicore, "multicore", true, "enable multicore support")
+	flag.BoolVar(&reusePort, "reusePort", false, "enable port reuse")
+	flag.BoolVar(&pprofDebug, "pprofDebug", false, "enable pprof debugging")
 	flag.StringVar(&pprofAddr, "pprofAddr", ":8888", "pprof address")
 	flag.Parse()
+
+	// Start pprof server if debugging is enabled
 	if pprofDebug {
 		go func() {
 			http.ListenAndServe(pprofAddr, nil)
 		}()
 	}
 
+	// Create the protocol address string
 	protoAddr := fmt.Sprintf("%s://%s", network, addr)
+
+	// Define RedHub options
 	option := redhub.Options{
 		Multicore: multicore,
 		ReusePort: reusePort,
 	}
 
+	// Create a new RedHub instance with custom handlers
 	rh := redhub.NewRedHub(
+		// Connection initialization handler
 		func(c *redhub.Conn) (out []byte, action redhub.Action) {
 			return
 		},
+		// Connection error handler
 		func(c *redhub.Conn, err error) (action redhub.Action) {
 			return
 		},
+		// Command handler
 		func(cmd resp.Command, out []byte) ([]byte, redhub.Action) {
 			var status redhub.Action
 			switch strings.ToLower(string(cmd.Args[0])) {
 			default:
+				// Handle unknown commands
 				out = resp.AppendError(out, "ERR unknown command '"+string(cmd.Args[0])+"'")
 			case "ping":
+				// Handle PING command
 				out = resp.AppendString(out, "PONG")
 			case "quit":
+				// Handle QUIT command
 				out = resp.AppendString(out, "OK")
 				status = redhub.Close
 			case "set":
+				// Handle SET command
 				if len(cmd.Args) != 3 {
 					out = resp.AppendError(out, "ERR wrong number of arguments for '"+string(cmd.Args[0])+"' command")
 					break
@@ -69,6 +87,7 @@ func main() {
 				mu.Unlock()
 				out = resp.AppendString(out, "OK")
 			case "get":
+				// Handle GET command
 				if len(cmd.Args) != 2 {
 					out = resp.AppendError(out, "ERR wrong number of arguments for '"+string(cmd.Args[0])+"' command")
 					break
@@ -82,6 +101,7 @@ func main() {
 					out = resp.AppendBulk(out, val)
 				}
 			case "del":
+				// Handle DEL command
 				if len(cmd.Args) != 2 {
 					out = resp.AppendError(out, "ERR wrong number of arguments for '"+string(cmd.Args[0])+"' command")
 					break
@@ -96,17 +116,20 @@ func main() {
 					out = resp.AppendInt(out, 1)
 				}
 			case "config":
-				// This simple (blank) response is only here to allow for the
-				// redis-benchmark command to work with this example.
+				// Handle CONFIG command (for redis-benchmark compatibility)
 				out = resp.AppendArray(out, 2)
 				out = resp.AppendBulk(out, cmd.Args[2])
 				out = resp.AppendBulkString(out, "")
 			}
 			return out, status
 		},
 	)
+
+	// Log the server start
 	log.Printf("started redhub server at %s", addr)
-	err := redhub.ListendAndServe(protoAddr, option, rh)
+
+	// Start the RedHub server
+	err := redhub.ListenAndServe(protoAddr, option, rh)
 	if err != nil {
 		log.Fatal(err)
 	}

go.mod

@@ -1,12 +1,15 @@
 module github.com/IceFireDB/redhub
 
-go 1.16
+go 1.22
+
+require github.com/panjf2000/gnet v1.6.7
 
 require (
 	github.com/panjf2000/ants/v2 v2.9.0 // indirect
-	github.com/panjf2000/gnet v1.6.7
 	github.com/stretchr/testify v1.8.4 // indirect
-	go.uber.org/zap v1.21.0 // indirect
-	golang.org/x/sys v0.15.0 // indirect
+	github.com/valyala/bytebufferpool v1.0.0 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
+	go.uber.org/zap v1.27.0 // indirect
+	golang.org/x/sys v0.26.0 // indirect
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1 // indirect
 )

go.sum

@@ -1,5 +1,4 @@
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
-github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8=
 github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
@@ -12,7 +11,6 @@ github.com/panjf2000/ants/v2 v2.9.0 h1:SztCLkVxBRigbg+vt0S5QvF5vxAbxbKt09/YfAJ0t
 github.com/panjf2000/ants/v2 v2.9.0/go.mod h1:7ZxyxsqE4vvW0M7LSD8aI3cKwgFhBHbxnlN8mDqHa1I=
 github.com/panjf2000/gnet v1.6.7 h1:zv1k6kw80sG5ZQrLpbbFDheNCm50zm3z2e3ck5GwMOM=
 github.com/panjf2000/gnet v1.6.7/go.mod h1:KcOU7QsCaCBjeD5kyshBIamG3d9kAQtlob4Y0v0E+sc=
-github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
@@ -31,17 +29,17 @@ github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6Kllzaw
 github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc=
 github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
 go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
-go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE=
 go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
 go.uber.org/goleak v1.1.11-0.20210813005559-691160354723/go.mod h1:cwTWslyiVhfpKIDGSZEM2HlOvcqm+tG4zioyIeLoqMQ=
-go.uber.org/goleak v1.1.11 h1:wy28qYRKZgnJTxGxvye5/wgWr1EKjmUDGYox5mGlRlI=
-go.uber.org/goleak v1.1.11/go.mod h1:cwTWslyiVhfpKIDGSZEM2HlOvcqm+tG4zioyIeLoqMQ=
+go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
+go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
 go.uber.org/multierr v1.6.0/go.mod h1:cdWPpRnG4AhwMwsgIHip0KRBQjJy5kYEpYjJxpXp9iU=
-go.uber.org/multierr v1.7.0 h1:zaiO/rmgFjbmCXdSYJWQcdvOCsthmdaHfr3Gm2Kx4Ec=
 go.uber.org/multierr v1.7.0/go.mod h1:7EAYxJLBy9rStEaz58O2t4Uvip6FSURkq8/ppBp95ak=
+go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
+go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 go.uber.org/zap v1.19.1/go.mod h1:j3DNczoxDZroyBnOT1L/Q79cfUMGZxlv/9dzN7SM1rI=
-go.uber.org/zap v1.21.0 h1:WefMeulhovoZ2sYXz7st6K0sLj7bBhpiFaud4r4zST8=
-go.uber.org/zap v1.21.0/go.mod h1:wjWOCqI0f2ZZrJF/UufIOkiC8ii6tm1iqIsLo76RfJw=
+go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
+go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
@@ -59,8 +57,8 @@ golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20211204120058-94396e421777/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc=
-golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.26.0 h1:KHjCJyddX0LoSTb3J+vWpupP9p0oznkqVk/IfjymZbo=
+golang.org/x/sys v0.26.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
@@ -78,7 +76,6 @@ gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST
 gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.7/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10=
 gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=