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

go get github.com/gomodule/redigo/redis

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