Redis连接池的介绍与使用

Redis连接池的介绍与使用一.介绍说明:通过golang对redis操作,还可以通过redis连接池,流程如下:事先初始化一定数量的连接,放入到连接池。 当go需要操作redis时,直接从redis连接池取出连接即可。 这样可以节省临时获取redis连接的时间,从而提高效率。二.核心代码:varpool*redis.Poolpool=&redis.Pool{MaxIdle:8,/…

一.介绍

说明:通过golang对redis操作,还可以通过redis连接池,流程如下:

  1. 事先初始化一定数量的连接,放入到连接池。
  2. 当go需要操作redis时,直接从redis连接池取出连接即可。
  3. 这样可以节省临时获取redis连接的时间,从而提高效率。

二.核心代码:

var pool *redis.Pool
pool =&redis.Pool{
   MaxIdle:8,//最大空闲连接数
   MaxActive:0,//表示和数据库的最大连接数,0表示没有限制
   IdleTimeout:100,//最大空闲时间
   Dial: func() (redis.Conn, error) {//初始化连接,连接到哪个ip的redis数据库
      return redis.Dial("tcp","localhost:6379")
   },
}
con := pool.Get()//先从pool取出一个连接
pool.Close()//关闭连接池

三.连接池案例:

package main

import (
	"fmt"
	"github.com/garyburd/redigo/redis"
)

var pool *redis.Pool

//当启动程序时,就初始化连接池
func init()  {
	pool =&redis.Pool{
		MaxIdle:8,//最大空闲连接数
		MaxActive:0,//表示和数据库的最大连接数,0表示没有限制
		IdleTimeout:100,//最大空闲时间
		Dial: func() (redis.Conn, error) {//初始化连接,连接到哪个ip的redis数据库
			return redis.Dial("tcp","localhost:6379")
		},
	}

}

func main()  {

	con := pool.Get()//先从pool取出一个连接
	defer con.Close()//延迟关闭连接

	_,err := con.Do("Set","name","小米")
	if err != nil{
		fmt.Println("set失败")
		return
	}

	reply,err :=redis.String(con.Do("Get","name"))
	if err != nil{
		fmt.Println("get失败")
		return
	}

	fmt.Println("名字:",reply)
}

执行结果:

Redis连接池的介绍与使用

 

今天的文章Redis连接池的介绍与使用分享到此就结束了,感谢您的阅读,如果确实帮到您,您可以动动手指转发给其他人。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/25342.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注