组件分享之后端组件——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地址因为需要考虑单机版和集成的情况下 地址使用[]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 国际许可协议 进行许可。