Go redis connection pool

1、 create profile

Store in conf Configure folders , It can be corresponding to your needs .

redis.go

package conf

var RedisConf = map[string]string{
   "name":    "redis",
   "type":    "tcp",
   "address": "127.0.0.1:6379",
   "auth":    "123456",
}

Copy

2、redis Connection pool

redispool.go Connection pool implementation

package redis

import (
   . "example/example/conf"   // Change to your own configuration directory 
   "github.com/garyburd/redigo/redis"
   "time"
)

var RedisClient *redis.Pool

func init() {
   //  Set up connection pool 
   RedisClient = &redis.Pool{
      //  Get... From the configuration file maxidle as well as maxactive, If not, use the following default value 
      MaxIdle: 16, // Initial number of connections 
      // MaxActive:1000000,    // Maximum number of connections 
      MaxActive:   0,                 // The maximum number of connections in the connection pool , I'm not sure I can use 0（0 Indicates automatic definition ）, Distribute on demand 
      IdleTimeout: 300 * time.Second, // Connection closing time  300 second  （300 Seconds do not use automatic shutdown ）
      Dial: func() (redis.Conn, error) { // To connect the redis database 
         c, err := redis.Dial(RedisConf["type"], RedisConf["address"])
         if err != nil {
            return nil, er
         }
         if _, err := c.Do("AUTH", RedisConf["auth"]); err != nil {
            c.Close()
            return nil, er
         }
         return c, nil
      },
   }
}

Copy

Examples of use ：

package main

import (
   "example/example/public/redispool"  // Change to your own redispool.go(redis Connection pool implementation file ) The catalog of 
   "fmt"
   "github.com/garyburd/redigo/redis"
)

var RedisExpire = 3600 // Cache lifetime 
func main() {

   //  Get connections from the pool 
   rc := redispool.RedisClient.Get()
   //  Put the connection back into the connection pool after use 
   defer rc.Close()
   key := "redis.cache"
   _, err := rc.Do("Set", key, "1", "EX", RedisExpire)
   if err != nil {
      fmt.Println(err)
      return
   }
   val, err := redis.String(rc.Do("Get", key))
   if err != nil {
      fmt.Println(err)
   }
   fmt.Println(val)
   // Delete 
   rc.Do("Del", key)

}

Copy

Project address ：https://github.com/guyan0319/golang_development_notes