redis连接池 go-redis

为什么使用连接池？

首先Redis也是一种数据库，它基于C/S模式，因此如果需要使用必须建立连接，稍微熟悉网络的人应该都清楚地知道为什么需要建立连接，C/S模式本身就是一种远程通信的交互模式，因此Redis服务器可以单独作为一个数据库服务器来独立存在。假设Redis服务器与客户端分处在异地，虽然基于内存的Redis数据库有着超高的性能，但是底层的网络通信却占用了一次数据请求的大量时间，因为每次数据交互都需要先建立连接，假设一次数据交互总共用时30ms，超高性能的Redis数据库处理数据所花的时间可能不到1ms，也即是说前期的连接占用了29ms，连接池则可以实现在客户端建立多个链接并且不释放，当需要使用连接的时候通过一定的算法获取已经建立的连接，使用完了以后则还给连接池，这就免去了数据库连接所占用的时间。

单线程不是redis的性能瓶颈，对redis而言，有两个性能所在，一个是计算机执行命令的速度，另一个是网络通信性。很显然，执行命令速度不是redis的性能瓶颈，通信才是其瓶颈。据我所知，redis每秒可执行10万次，因此，对于客户端将若干条命令传输给redis服务，命令执行时间和通信时间大概是比等于0，将设以1s举例，几条命令传输时间为40ms，而每秒可执行10万条命令，那么这些命令只是花费1ms来执行，其他39ms时间无事可做，等待下一个命令的到来，其中的间隙，造成redis的闲置。

综上，要提高redis的性能，可以降低单位时间内的通信成本，那么连接池就是一个不错的选择。客户端使用连接词+多线程方案，使得redis服务闲置时间降低，极大的提高了服务效率。

go-redis模块自带连接池，所有参数都是可选的，参数配置说明示例如下：

package main

import (

	"fmt"

	"github.com/go-redis/redis"

	"net/http"

	"net"

	"time"

)

var gClient *redis.Client

func handler(w http.ResponseWriter, r *http.Request) {

	gClient.Ping().Result()

	printRedisPool(gClient.PoolStats())

	fmt.Fprintf(w, "Hello")

}

func printRedisPool(stats *redis.PoolStats) {

	fmt.Printf("Hits=%d Misses=%d Timeouts=%d TotalConns=%d IdleConns=%d StaleConns=%d\n",

		stats.Hits, stats.Misses, stats.Timeouts, stats.TotalConns, stats.IdleConns, stats.StaleConns)

}

func printRedisOption(opt *redis.Options) {

	fmt.Printf("Network=%v\n", opt.Network)

	fmt.Printf("Addr=%v\n", opt.Addr)

	fmt.Printf("Password=%v\n", opt.Password)

	fmt.Printf("DB=%v\n", opt.DB)

	fmt.Printf("MaxRetries=%v\n", opt.MaxRetries)

	fmt.Printf("MinRetryBackoff=%v\n", opt.MinRetryBackoff)

	fmt.Printf("MaxRetryBackoff=%v\n", opt.MaxRetryBackoff)

	fmt.Printf("DialTimeout=%v\n", opt.DialTimeout)

	fmt.Printf("ReadTimeout=%v\n", opt.ReadTimeout)

	fmt.Printf("WriteTimeout=%v\n", opt.WriteTimeout)

	fmt.Printf("PoolSize=%v\n", opt.PoolSize)

	fmt.Printf("MinIdleConns=%v\n", opt.MinIdleConns)

	fmt.Printf("MaxConnAge=%v\n", opt.MaxConnAge)

	fmt.Printf("PoolTimeout=%v\n", opt.PoolTimeout)

	fmt.Printf("IdleTimeout=%v\n", opt.IdleTimeout)

	fmt.Printf("IdleCheckFrequency=%v\n", opt.IdleCheckFrequency)

	fmt.Printf("TLSConfig=%v\n", opt.TLSConfig)

}

func main() {

	gClient = redis.NewClient(&redis.Options{

		//连接信息

		Network:  "tcp",                  //网络类型，tcp or unix，默认tcp

		Addr:     "127.0.0.1:6379", //主机名+冒号+端口，默认localhost:6379

		Password: "",                     //密码

		DB:       0,                      // redis数据库index

		//连接池容量及闲置连接数量

		PoolSize:     15, // 连接池最大socket连接数，默认为4倍CPU数， 4 * runtime.NumCPU

		MinIdleConns: 10, //在启动阶段创建指定数量的Idle连接，并长期维持idle状态的连接数不少于指定数量；。

		//超时

		DialTimeout:  5 * time.Second, //连接建立超时时间，默认5秒。

		ReadTimeout:  3 * time.Second, //读超时，默认3秒， -1表示取消读超时

		WriteTimeout: 3 * time.Second, //写超时，默认等于读超时

		PoolTimeout:  4 * time.Second, //当所有连接都处在繁忙状态时，客户端等待可用连接的最大等待时长，默认为读超时+1秒。

		//闲置连接检查包括IdleTimeout，MaxConnAge

		IdleCheckFrequency: 60 * time.Second, //闲置连接检查的周期，默认为1分钟，-1表示不做周期性检查，只在客户端获取连接时对闲置连接进行处理。

		IdleTimeout:        5 * time.Minute,  //闲置超时，默认5分钟，-1表示取消闲置超时检查

		MaxConnAge:         0 * time.Second,  //连接存活时长，从创建开始计时，超过指定时长则关闭连接，默认为0，即不关闭存活时长较长的连接

		//命令执行失败时的重试策略

		MaxRetries:      0,                      // 命令执行失败时，最多重试多少次，默认为0即不重试

		MinRetryBackoff: 8 * time.Millisecond,   //每次计算重试间隔时间的下限，默认8毫秒，-1表示取消间隔

		MaxRetryBackoff: 512 * time.Millisecond, //每次计算重试间隔时间的上限，默认512毫秒，-1表示取消间隔

		//可自定义连接函数

		Dialer: func() (net.Conn, error) {

			netDialer := &net.Dialer{

				Timeout:   5 * time.Second,

				KeepAlive: 5 * time.Minute,

			}

			return netDialer.Dial("tcp", "127.0.0.1:6379")

		},

		//钩子函数

		OnConnect: func(conn *redis.Conn) error { //仅当客户端执行命令时需要从连接池获取连接时，如果连接池需要新建连接时则会调用此钩子函数

			fmt.Printf("conn=%v\n", conn)

			return nil

		},

	})

	defer gClient.Close()

	printRedisOption(gClient.Options())

	printRedisPool(gClient.PoolStats())

	http.HandleFunc("/", handler)

	http.ListenAndServe(":8080", nil)

}

https://blog.csdn.net/dreamwbt/article/details/76167340

https://blog.csdn.net/pengpengzhou/article/details/105385666

巴特西

redis连接池 go-redis

为什么使用连接池？

最新文章

热门文章