~~~ package redis import ( "github.com/go-redis/redis" "project/library/dao/config" ) /* //命令執行失敗重試次數(默認不重試) MaxRetries: 3, // 空閑連接超時時間，超過超時時間的空閑連接會被關閉。 // 如果設置成0，空閑連接將不會被關閉 // 應該設置一個比redis服務端超時時間更短的時間 IdleTimeout: time.Second * 30, */ type RedisSingleMgr struct { Conn *redis.Client } func InitRedisSingle(cfg *config.RedisCfg) *RedisSingleMgr { return &RedisSingleMgr{ Conn: redis.NewClient(&redis.Options{ Addr: cfg.Addr, Password: cfg.Password, //DB: 0, //PoolSize: viper.GetInt("redis.pool.max"), //MinIdleConns: viper.GetInt("redis.pool.min"), }), } } type RedisDoubleMgr struct { Conn *redis.ClusterClient } func InitRedisDouble(cfg *config.RedisCfg) *RedisDoubleMgr { return &RedisDoubleMgr{ Conn: redis.NewClusterClient(&redis.ClusterOptions{ Addrs: cfg.Addrs, }), } } /* 隊列(左出右進) */ func (mgr *RedisSingleMgr) Push(key string, values ...interface{}) *redis.IntCmd { return mgr.Conn.RPush(key, values...) } func (mgr *RedisSingleMgr) Pop(key string) *redis.StringCmd { return mgr.Conn.LPop(key) } func (mgr *RedisSingleMgr) Range(key string, start, stop int64) *redis.StringSliceCmd { return mgr.Conn.LRange(key, start, stop) } ~~~