组件分享之后端组件——Redis数据库的一个Go客户端redigo

背景

近期正在探索前端、后端、系统端各类常用组件与工具，对其一些常见的组件进行再次整理一下，形成标准化组件专题，后续该专题将包含各类语言中的一些常用组件。欢迎大家进行持续关注。

组件基本信息

• 组件：redigo
• 开源协议： Apache-2.0 license

内容

本节分享一个Redis数据库的一个Go客户端redigo

它具有以下特征

• 一个类似打印的API，支持所有 Redis 命令。
• 流水线，包括流水线交易。
• 发布/订阅。
• 连接池。
• 乐观使用 EVALSHA 的脚本助手类型。
• 用于处理命令回复的辅助函数。

使用起来也非常简单，案例如下：
1、安装

go get github.com/gomodule/redigo/redis

2、使用

type Redis struct {Addr                  string        `toml:"addr"`     //redis地址因为需要考虑单机版和集成的情况下 地址使用[]stringPassword              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().RedisredisUrl := 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 国际许可协议 进行许可。