Go Redis客户端使用的两种对比
作者:Johns 发布时间:2024-05-09 09:31:15
介绍
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
猜你喜欢
- 2006-10-8表数据:tab1id name numA  
- python2.7,下面是跑在window上的,稍作修改就可以跑在linux上。实测win7和raspbian均可,且raspbian可以直
- 如何定义多对多关系Django 本身自带了一个很强大的ORM,支持自定义model并将其映射到数据库的表中model中可以定义各种类型的数据
- python 读写中文json的实例详解读写中文json想要 读写中文json ,可以使用python中的 json 库可以对j
- 用python做一个简单的随机点名程序(不重复点名)这是我来到csdn的第一篇文章,内容如果有瑕疵的地方或者代码可以进一步改善,请大家对我指
- anaconda中安装的python环境中没有pip3在使用anaconda配置的python环境时,发现在python环境中并没有安装pi
- 本文实例讲述了Python实现矩阵转置的方法。分享给大家供大家参考,具体如下:前几天群里有同学提出了一个问题:手头现在有个列表,列表里面两个
- 我们到目前为止所谈到的SQL语句相对较为简单,如果再能通过标准的recordset循环查询,那么这些语句也能满足一些更复杂的要求。不过,何必
- 概述从今天开始, 小白我将带领大家一起来补充一下 数据库的知识.条件查询我们可以使用关键词Where来指定条件, 用于插入, 修改删除或者查
- 常见的一种应用场景:条件:假设A的shape为[4, 2],B的shape为[5, 2]目的:实现A中的每一行, 减去B中的所有行(broa
- 1.数据采集和标记先采集数据,再对数据进行标记。其中采集数据要就有代表性,以确保最终训练出来模型的准确性。2.特征选择选择特征的直观方法:直
- 1.TCP是一种面向连接的可靠地协议,在一方发送数据之前,必须在双方之间建立一个连接,建立的过程需要经过三次握手,通信完成后要拆除连接,需要
- 就像我的日志中的地址路径一样,让 index.php?action=one&do=two 变成: ?
- # 2014.10.15 更新了memo.zip, 网盘的exe:修复:1.隔日启动不能正常加载json,加入:1.隐藏任务栏图标,2.通过
- 什么是类,对象,实例,类## 标题变量(类属性),实例变量(实例属性)面向对象编程(Object-oriented Programming,
- 本文介绍了vue.js $refs和$emit 父子组件交互的方法,分享给大家,废话不多说直接看代码:<strong>父调子 $
- yaml简单介绍YAML是一种标记语言,它使用空白符号缩进和大量依赖外观的特色,特别适合用来表达或编辑数据结构、各种配置文件、倾印调试内容、
- 一、什么是Perl Hash哈希是一种数据结构,和数组类似,可以将值存放到其中,或者从中取回值。但是,和数组不同的是,其索引不是数字,而是名
- 本文实例分析了Python闭包执行时值的传递方式。分享给大家供大家参考,具体如下:代码中有问题和问题的解释。#!/usr/bin/pytho
- 这个语法是用来代替传统的try...finally语法的。 with EXPRESSION [ as VARIABLE] WITH-BLOC