add redis

go.mod

@@ -3,6 +3,7 @@ module github.com/yifanshaoye/ctdao
 go 1.18
 
 require (
+	github.com/go-redis/redis v6.15.9+incompatible // indirect
 	github.com/go-sql-driver/mysql v1.6.0 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect

go.sum

@@ -1,6 +1,8 @@
 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/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-redis/redis v6.15.9+incompatible h1:K0pv1D7EQUjfyoMql+r/jZqCLizCGKFlFgcHWWmHQjg=
+github.com/go-redis/redis v6.15.9+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA=
 github.com/go-sql-driver/mysql v1.6.0 h1:BCTh4TKNUYmOmMUcQ3IipzF5prigylS7XXjEkfCHuOE=
 github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=

goredis/redis.go

@@ -0,0 +1,34 @@
+package goredis
+
+import (
+	"errors"
+	"fmt"
+	"github.com/go-redis/redis"
+)
+
+// dsn: user:password@tcp(ip:port)/dbname?charset=utf8mb4&parseTime=True&loc=Local
+func GetRedisInstance(host, port, password string) (*redis.Client, error) {
+	if len(host) == 0 {
+		host = "127.0.0.1"
+	}
+	if len(port) == 0 {
+		port = "6379"
+	}
+	addr := host + ":" + port
+	client := redis.NewClient(&redis.Options{
+		Addr:               addr,
+		Password:           password,
+	})
+
+	for i := 0; i < 3; i++ {
+		if pong, err := client.Ping().Result(); err != nil {
+			fmt.Printf("connect redis %s, error: %+v\n", addr + " " + password, err)
+			continue
+		} else {
+			fmt.Println("connect redis ok: ", pong)
+			return client, nil
+		}
+	}
+
+	return client, errors.New("redis connect fails")
+}

main.go

@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/yifanshaoye/ctdao/gorm"
+	"github.com/yifanshaoye/ctdao/goredis"
 )
 
 type User struct {
@@ -12,12 +12,20 @@ type User struct {
 
 func main() {
 	fmt.Println("Hello, World !!!")
-	gorm.Done()
-	dsn := "root:long123456@tcp(127.0.0.1:3306)/collections?charset=utf8mb4&parseTime=True&loc=Local"
-	db, err := gorm.GetMysqlInstance(dsn)
-	fmt.Println("err: ", err)
-	user := []User{{Name: "teng"}, {Name: "chen"}}
-	db.Create(user)
+
+	rcli,_ := goredis.GetRedisInstance("", "", "")
+	res := rcli.Get("a")
+	fmt.Println( res)
+
+	res = rcli.Get("b")
+	fmt.Println( res)
+
+	//gorm.Done()
+	//dsn := "root:long123456@tcp(127.0.0.1:3306)/collections?charset=utf8mb4&parseTime=True&loc=Local"
+	//db, err := gorm.GetMysqlInstance(dsn)
+	//fmt.Println("err: ", err)
+	//user := []User{{Name: "teng"}, {Name: "chen"}}
+	//db.Create(user)
 
 	//zaplog.SetLogFilePath("./database/access.log")
 	//zaplog.InitZaplog()