Go Redis客户端使用的两种对比
作者：Johns 发布时间：2024-05-09 09:31:15
标签：Go,Redis,客户端
介绍
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
从上图可以看出, go-redis虽然每次操作会比redigo慢10％左右, 但是redigo需要显示申请/关闭连接,所以总体上二者的性能差异其实不大
Redigo库
redigo 是Redis数据库的Go客户端, 操作Redis基本和commands一样. Redigo命令基本都是通过Do方法来实现的.
Do(ctx context.Context, cmd string, args ...interface{}) (interface{}, error)
虽然调用Do函数万能参数可以实现所有的功能，但是使用起来非常的不友好，参数类型是万能类型，所以在编译阶段无法检查参数类型, 其次每个命令都需要花时间记录使用方法，参数个数等，使用成本高；
演示
演示基本的连接池建立, ping, string操作, hash操作, list操作, expire等操作
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())
}
}
go-redis组件介绍和使用
go-redis提供了三种对应服务端的客户端模式，集群，哨兵，和单机模式，三种模式在连接池这一块都是公用的, 同时还提供了灵活的Hook机制, 其底层实际也是调用的万能 Do 方法.
但go-redis细化了每个redis每个命令的功能, 我们只需记住命令，具体的用法直接查看接口的申请就可以了，使用成本低；其次它对数据类型按照redis底层的类型进行统一，编译时就可以帮助检查参数类型, 并且它的响应统一采用 Result 的接口返回，确保了返回参数类型的正确性，对用户更加友好；
演示
演示基本的连接池建立, ping, string操作, hash操作, list操作, expire等操作
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: darwin
goarch: amd64
cpu: Intel(R) Core(TM) i7-9750H CPU @ 2.60GHz
BenchmarkRedis
BenchmarkRedis/redigo_client_Benchmark
BenchmarkRedis/redigo_client_Benchmark-12 26386 39110 ns/op
BenchmarkRedis/go-redis_client_Benchmark
BenchmarkRedis/go-redis_client_Benchmark-12 28186 37794 ns/op
来源：https://cloud.tencent.com/developer/article/2056319
0
投稿猜你喜欢
- 注释注释就是对代码的解释和说明。目的是为了让别人和自己很容易看懂。为了让别人一看就知道这段代码是做什么用的。正确的程序注释一般包括序言性注释
一、Pycharm下载与安装附：Python、Pycharm和Anaconda的关系：Python是一种解释型、面向对象、动态数据类型的高级- 今天工作中遇到，拿出来说说。网上CSS下拉菜单不少，不过都存在这样那样的问题，主要问题是，如果你菜单下面有一个FLASH的话，很多都会被FL
- 结合网上的资料，自己亲自的去安装了一次MySQL，安装版本是win7x64 5.7.16。在安装过程中出现并解决了如下问题:“mysql 服
- 在我们制作网页的时候会经常碰到一些需求，如果不知道方法，说不定会困扰我们半天。其实实现它们都很简单，下面我们就一起来看看这些常用的网页编辑方
- 本文实例讲述了Python中XlsxWriter模块用法。分享给大家供大家参考，具体如下：XlsxWriter，可以生成excel文件（xl
- jupyter notebook 自定义python解释器jupyter notebook 和虚拟环境的好处就不多废话了jupyter no
- 本文实例讲述了js实现向右横向滑出的二级菜单效果。分享给大家供大家参考。具体如下：这是一个网页上的横向滑出二级菜单，菜单是竖向排列的，但二级
- 今天我们说一下Redis中最后一个数据类型 “有序集合类型”，回首之前学过的几个数据结构，不知道你会不会由衷感叹，开源的世界真好，写这些代码
- 导语今天就给大家带来个语言识别跟语言赚文字的小工具感兴趣的铁汁萌可以往下滑了1.直接使用在1.2官网注册后拿到APISecret和APIKe
- pandas 对于数据分析的人员来说都是必须熟悉的第三方库，pandas 在科学计算上有很大的优势，特别是对于数据分析人员来说，相当的重要。
- --SQL正则替换函数 代码如下:CREATE function dbo.regexReplace ( @source ntext, --
- 本文为大家分享了网易2016研发工程师编程题，供大家参考，具体内容如下'''[编程题] 奖学金时间限制：1秒空间限制
- Array.prototype._ = function(){var _p = 0;var _v = 0;(function(){
- 以下函数采用FSO对象，文件位置在FSO.ASP。FSO对象的文件编码属性只有三种，系统默认，Unicode，ASCII，并没有我们要的ut
- 昨晚今晚写了两晚，总算把Py Port Scanner 写完了，姑且称之为0.1版本，算是一个Python多线程端口扫描工具。水平有限，实话
- 传入参数一个，为元素的id值或元素本身，返回为元素的真实背景色值（字符串）。 值得一提的是IE里面返回的是16进制的值，而Mozi
- 使用MySQL的命令终端时，如果输入SQL有误，将有beep声。若要关闭该功能，根据mysql --help，使用mysql --no-be
- Python 3中的File对象不支持next()方法。 Python 3有一个内置函数next()，它通过调用其next ()方法从迭代器
- 流程控制流程:代码执行的过程控制:对代码执行过程的把控三大结构顺序结构:代码默认从上到下,依次执行分支结构:单项分支,双向分支,多项分支,巢
