组件分享之后端组件——Redis数据库的一个Go客户端redigo
背景
近期正在探索前端、后端、系统端各类常用组件与工具，对其一些常见的组件进行再次整理一下，形成标准化组件专题，后续该专题将包含各类语言中的一些常用组件。欢迎大家进行持续关注。
组件基本信息
- 组件：redigo
- 开源协议： Apache-2.0 license
内容
本节分享一个Redis数据库的一个Go客户端redigo
它具有以下特征
- 一个类似打印的API，支持所有 Redis 命令。
- 流水线，包括流水线交易。
- 发布/订阅。
- 连接池。
- 乐观使用 EVALSHA 的脚本助手类型。
- 用于处理命令回复的辅助函数。
使用起来也非常简单，案例如下： 1、安装
代码语言：javascript复制go get github.com/gomodule/redigo/redis2、使用
代码语言：javascript复制type Redis struct {
Addr string `toml:"addr"` //redis地址因为需要考虑单机版和集成的情况下 地址使用[]string
Password string `toml:"password"` //密码 没有则为空
DB int `toml:"db"` //使用的数据库
DialConnectionTimeout time.Duration `toml:"dialConnectionTimeout"`
DialReadTimeout time.Duration `toml:"dialReadTimeout"`
DialWriteTimeout time.Duration `toml:"dialWriteTimeout"`
IdleTimeout time.Duration `toml:"idleTimeout"`
MaxIdle int `toml:"maxIdle"` // 连接池中的最大空闲连接数
MaxActive int `toml:"maxActive"` // 连接池在给定时间内分配的最大连接数。0没有限制
}
func initRedis() (*redis.Pool, error) {
log.Println("-----------开始初始化redis通用客户端")
// 获取配置信息
redisConfig := config.Get().Redis
redisUrl := fmt.Sprintf("redis://%s", redisConfig.Addr)
// 建立连接池
redisClient := &redis.Pool{
Dial: func() (redis.Conn, error) {
con, err := redis.DialURL(
redisUrl,
redis.DialPassword(redisConfig.Password),
redis.DialDatabase(redisConfig.DB),
redis.DialConnectTimeout(redisConfig.DialConnectionTimeout*time.Second),
redis.DialReadTimeout(redisConfig.DialReadTimeout*time.Second),
redis.DialWriteTimeout(redisConfig.DialWriteTimeout*time.Second),
)
if err != nil {
return nil, err
}
return con, nil
},
TestOnBorrow: func(c redis.Conn, t time.Time) error {
_, err := c.Do("PING")
if err != nil {
log.Printf("ping redis error: %s", err)
return err
}
return nil
},
MaxIdle: redisConfig.MaxIdle,
MaxActive: redisConfig.MaxActive,
IdleTimeout: redisConfig.IdleTimeout * time.Second,
Wait: true,
MaxConnLifetime: 0,
}
log.Printf("[redis util] init end !!!")
return redisClient, nil
}redisClient,_ := initRedis()
c := redisClient.Get()
defer c.Close()
n, err := c.Do("APPEND", "key", "value")
c.Send("SET", "foo", "bar")
c.Send("GET", "foo")
c.Flush()
c.Receive() // reply from SET
v, err = c.Receive() // reply from GET更多前后端组件，可以持续关注我，我将持续给大家分享各种各样的组件包。
本文声明：
88x31.png
知识共享许可协议
本作品由 cn華少 采用 知识共享署名-非商业性使用 4.0 国际许可协议 进行许可。
