// 定義redis鏈接池

var client *redis.Client

// 初始化redis鏈接池

func init() {

db, err := beego.AppConfig.Int("redisDB")

if err != nil {

logs.Error("redis-db", err)

}

client = redis.NewClient(&redis.Options{

Addr: beego.AppConfig.String("redisAddr"), // Redis地址

Password: beego.AppConfig.String("redisPassword"), // Redis賬號

DB: db, // Redis庫

PoolSize: 40, // Redis連接池大小

MaxRetries: 3, // 最大重試次數

IdleTimeout: 5 * time.Second, // 空閑鏈接超時時間

MinIdleConns: 5, // 空閑連接數量

})

pong, err := client.Ping().Result()

if err == redis.Nil {

logs.Info("Redis異常")

} else if err != nil {

logs.Info("失敗:", err)

} else {

logs.Info(pong)

}

}

type Redis struct{}

func (r Redis) Get(key string) (string, error) {

result, err := client.Get(key).Result()

if err != nil {

return "", err

}

return result, nil

}

Options相關說明

總結

以上是生活随笔為你收集整理的linux go redis,go-redis 连接池的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。