SETEX 错​​误 - “使用关闭的网络连接”

Question

我正在使用以下代码从我的 Go 应用程序执行 SET 和 EXPIRE。

_, err = C.Cache.Do("SETEX", key, 3600, data)

但我开始收到错误：使用关闭的网络连接。我使用 Gary Burd 的Redigo包和 RedisLabs。

我连接到Redis的代码是：

//Connect to cache (Redis)

cache, err := connectToCache()

if err != nil {

    log.Printf("Cache connection settings are invalid")

    os.Exit(1)

}

defer cache.Close()

func connectToCache() (redis.Conn, error) {

    cache, err := redis.Dial("tcp", CACHE_URI)

    if err != nil {

        return nil, err

    }

    _, err = cache.Do("AUTH", CACHE_AUTH)

    if err != nil {

        cache.Close()

        return nil, err

    }

    return cache, nil

}

Answer 1

您可以使用 aredis.Pool来管理多个连接，检查空闲连接是否处于活动状态，并自动获取新连接。您还可以在拨打新连接时自动执行 AUTH 步骤：func newPool(server, password string) *redis.Pool {    return &redis.Pool{        MaxIdle: 3,        IdleTimeout: 240 * time.Second,        Dial: func () (redis.Conn, error) {            c, err := redis.Dial("tcp", server)            if err != nil {                return nil, err            }            if _, err := c.Do("AUTH", password); err != nil {                c.Close()                return nil, err            }            return c, err        },        TestOnBorrow: func(c redis.Conn, t time.Time) error {            _, err := c.Do("PING")            return err        },    }}var (    pool *redis.Pool    redisServer = flag.String("redisServer", ":6379", "")    redisPassword = flag.String("redisPassword", "", ""))func main() {    flag.Parse()    pool = newPool(*redisServer, *redisPassword)    ...}