go-redis和redigo底層是透過呼叫的萬能Do 方法實作, 但是
redigo:
#由於輸入是萬能類型所以必須記住每個命令的參數和返回值情況, 使用起來非常的不友好，
參數類型是萬能類型導致在編譯階段無法檢查參數類型,
每個指令都需要花時間記錄使用方法，參數個數等，使用成本高；
#go-redis:
細化了每個redis每個命令的功能, 我們只需記住命令，具體的用法直接查看接口的申請就可以了，使用成本低；
其次它對資料類型按照redis底層的類型進行統一，編譯時就可以幫助檢查參數類型
並且它的響應統一採用Result 的介面返回，確保了返回參數類型的正確性，對用戶更加友好；
BenchmarkRedis/redigo_client_Benchmark-12 31406 36919 ns/op BenchmarkRedis/go-redis_client_Benchmark-12 29977 38152 ns/op BenchmarkRedis/redigo_client_Benchmark-12 27928 39923 ns/op BenchmarkRedis/go-redis_client_Benchmark-12 27127 46451 ns/op
Do(ctx context.Context, cmd string, args ...interface{}) (interface{}, error)Do函數萬用參數可以實現所有的功能，但是使用起來非常的不友好，參數類型是萬能類型，所以在編譯階段無法檢查參數類型, 其次每個命令都需要花時間記錄使用方法，參數個數等，使用成本高；
package main
import (
"fmt"
"github.com/gomodule/redigo/redis"
)
func main() {
// 新建一个连接池
var pool *redis.Pool
pool = &redis.Pool{
MaxIdle: 10, //最初的连接数量
MaxActive: 0, //连接池最大连接数量,（0表示自动定义），按需分配
IdleTimeout: 300, //连接关闭时间 300秒 （300秒不使用自动关闭）
Dial: func() (redis.Conn, error) { //要连接的redis数据库
return redis.Dial("tcp", "localhost:6379")
},
}
conn := pool.Get() //从连接池，取一个链接
defer conn.Close()
// 0. ping正常返回pong， 异常res is nil, err not nil
res, err := conn.Do("ping")
fmt.Printf("ping res=%v\n", res)
if err != nil {
fmt.Printf("ping err=%v\n", err.Error())
}
// string操作
// set
res, err = conn.Do("set", "name", "测试001")
fmt.Printf("set res=%v\n", res)
if err != nil {
fmt.Printf("set err=%v\n", err.Error())
}
// get
res, err = redis.String(conn.Do("get", "name"))
fmt.Printf("get res=%v\n", res)
if err != nil {
fmt.Printf("get err=%v\n", err.Error())
}
// MSet MGet
res, err = conn.Do("MSet", "name", "测试001", "age", 18)
fmt.Printf("MSet res=%v\n", res)
if err != nil {
fmt.Printf("MSet err=%v\n", err.Error())
}
r, err := redis.Strings(conn.Do("MGet", "name", "age"))
fmt.Printf("MGet res=%v\n", r)
if err != nil {
fmt.Printf("MGet err=%v\n", err.Error())
}
// expire
res, err = conn.Do("expire", "name", 5)
fmt.Printf("expire res=%v\n", r)
if err != nil {
fmt.Printf("expire err=%v\n", err.Error())
}
// list操作
// lpush lpop
res, err = conn.Do("lpush", "hobby", "篮球", "足球", "乒乓球")
fmt.Printf("lpush res=%v\n", r)
if err != nil {
fmt.Printf("lpush err=%v\n", err.Error())
}
// lpop
rs, er := conn.Do("lpop", "hobby")
fmt.Printf("lpop res=%v\n", rs)
if er != nil {
fmt.Printf("lpop err=%v\n", er.Error())
}
// hash 操作
// hset
res, err = conn.Do("HSet", "userinfo", "name", "lqz")
fmt.Printf("HSet res=%v\n", r)
if err != nil {
fmt.Printf("HSet err=%v\n", err.Error())
}
// hget
r4, er4 := conn.Do("HGet", "userinfo", "name")
fmt.Printf("HGet res=%v\n", r4)
if er4 != nil {
fmt.Printf("HGet err=%v\n", er4.Error())
}
}
func main() {
var rdb = redis2.NewClient(
&redis2.Options{
Addr: "localhost:6379",
Password: "", DB: 1,
MinIdleConns: 1,
PoolSize: 1000,
})
ctx := context.Background()
res, err = rdb.Ping(ctx).Result()
fmt.Printf("ping res=%v\n", res)
if err != nil {
fmt.Printf("ping err=%v\n", err.Error())
}
// string操作
// set
res, err = rdb.Set(ctx, "name", "测试001", 0).Result()
fmt.Printf("set res=%v\n", res)
if err != nil {
fmt.Printf("set err=%v\n", err.Error())
}
// get
res, err = rdb.Get(ctx, "name").Result()
fmt.Printf("get res=%v\n", res)
if err != nil {
fmt.Printf("get err=%v\n", err.Error())
}
// MSet MGet
res, err = rdb.MSet(ctx, "name", "测试001", "age", "18").Result()
fmt.Printf("MSet res=%v\n", res)
if err != nil {
fmt.Printf("MSet err=%v\n", err.Error())
}
var ret []interface{}
ret, err = rdb.MGet(ctx, "name", "age").Result()
fmt.Printf("MGet res=%v\n", ret)
if err != nil {
fmt.Printf("MGet err=%v\n", err.Error())
}
// expire
res, err = rdb.Expire(ctx, "name", time.Second).Result()
fmt.Printf("expire res=%v\n", res)
if err != nil {
fmt.Printf("expire err=%v\n", err.Error())
}
// list操作
// lpush lpop
res, err = rdb.LPush(ctx, "hobby", "篮球", "足球", "乒乓球").Result()
fmt.Printf("lpush res=%v\n", res)
if err != nil {
fmt.Printf("lpush err=%v\n", err.Error())
}
// lpop
rs, err = rdb.LPop(ctx, "hobby").Result()
fmt.Printf("lpop res=%v\n", rs)
if er != nil {
fmt.Printf("lpop err=%v\n", er.Error())
}
// hash 操作
// hset
res, err = rdb.HSet(ctx, "userinfo", "name", "lqz").Result()
fmt.Printf("HSet res=%v\n", r)
if err != nil {
fmt.Printf("HSet err=%v\n", err.Error())
}
// hget
r4, er4 = rdb.HGet(ctx, "userinfo", "name").Result()
fmt.Printf("HGet res=%v\n", r4)
if er4 != nil {
fmt.Printf("HGet err=%v\n", er4.Error())
}
}package main
import (
"context"
redis2 "github.com/go-redis/redis/v8"
"github.com/gomodule/redigo/redis"
"testing"
"time"
)
func BenchmarkRedis(b *testing.B) {
// 新建一个连接池
var pool *redis.Pool
pool = &redis.Pool{
MaxIdle: 10, //最初的连接数量
MaxActive: 1000, //连接池最大连接数量,（0表示自动定义），按需分配
IdleTimeout: 300, //连接关闭时间 300秒 （300秒不使用自动关闭）
Dial: func() (redis.Conn, error) { //要连接的redis数据库
return redis.Dial("tcp", "localhost:6379")
},
}
var rdb = redis2.NewClient(
&redis2.Options{
Addr: "localhost:6379",
Password: "",
MinIdleConns: 10,
PoolSize: 1000,
})
b.Run("redigo client Benchmark", func(b *testing.B) {
for j := 0; j < b.N; j++ {
conn := pool.Get() //从连接池，取一个链接
conn.Do("set", time.Now().String(), 10000, time.Second)
conn.Do("get", time.Now().String())
conn.Close()
}
})
ctx := context.Background()
b.Run("go-redis client Benchmark", func(b *testing.B) {
for j := 0; j < b.N; j++ {
rdb.Set(ctx, time.Now().String(), 1000, time.Second)
rdb.Get(ctx, time.Now().String())
}
})
}goos: darwingoarch:amd64
cpu: Intel(R) Core(TM) i7-9750H CPU @ 2.60GHz
BenchmarkRedis
BenchmarkRedis/redigo_client_Benchmark
BenchmarkRedis/redigo_client_Benchmark-12 26386 is/go-redis_client_Benchmark-12 28186 37794 ns/op
以上是Go Redis客戶端使用的方法有哪些的詳細內容。更多資訊請關注PHP中文網其他相關文章！
