Redis进阶二之池化技术

奶糖白大兔-

16天前发布

220

Jedis直连

Redis进阶二之池化技术

所谓直连是指Jedis每次都会新建TCP连接，使用后再断开连接，对于频繁访问Redis的场景显然不是高效的使用方式。

Jedis直连步骤

1、生成Jedis 对象

2、Jedis执行命令

3、返回执行结果

4、关闭Jedis连接

Jedis jedis = null;

try{
	jedis = new Jedis("localhost",6379);
	String value = jedis.get("name");
  return value;
} finally{
  if(jedis != null){
		jedis.close();
  }
}

什么是池化技术

池化技术 (Pool) 是一种很常见的编程技巧，在请求量大时能明显优化应用性能，降低系统频繁建连的资源开销。我们日常工作中常见的有数据库连接池、线程池、对象池等，它们的特点都是将 “昂贵的”、“费时的” 的资源维护在一个特定的 “池子” 中，规定其最小连接数、最大连接数、阻塞队列等配置，方便进行统一管理和复用，一般还会附带一些探活机制、强制回收、监控一类的配套功能。

池化技术的优势

1、避免频繁的连接创建、释放的性能开销

2、通过复用方式提高响应速度

3、资源的分配、通过连接池更好的管理资源

JedisPool

Jedis也有连接池，在生产环境中我们一般使用连接池的方式对Jedis连接进行管理，所有的Jedis对象预先放在池子中JedisPool。每次要连接Redis，只需要在池子中借，用完了在归还给池子。

Redis进阶二之池化技术

客户端连接Redis使用的是TCP协议，直连的方式每次都要建立TCP连接，而连接池的方式是可以预先初始化好Jedis连接，所以每次只需要从Jedis连接池借用即可，而借用和归还操作是在本地进行的，只要少量的并发同步开销，远远小于新建TCP连接的开销。另外直连的方式无法限制Jedis对象的个数，在极端情况下可能会造成连接泄漏，而连接池的形式可以有效的保护和控制资源的使用。

Jedis提供了JedisPool这个类作为对Jedis的连接池，同时使用了Apache的通用对象池工具common-pool作为资源的管理工具，下面是使用JedisPool操作Redis的代码栗子：

Jedis连接池使用步骤【一般JedisPool 是单例的】

1、从连接池借Jedis 对象

2、Jedis执行命令

3、返回执行结果

4、归还Jedis对象给连接池

// common-pool 连接池配置，这里使用默认配置
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
// 初始化Jedis连接池
JedisPool jedisPool = new JedisPool(poolConfig,"127.0.0.1",6379);

获取Jedis对象不再是直接生成一个Jedis对象进行直连，而是从连接池直接获取，代码如下：

 				Jedis jedis = null;
        try {
            // 从连接池获取Jedis对象
            jedis = jedisPool.getResource();
            // 执行操作
            String value =  jedis.get("name");
            return value;
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        } finally {
            if (jedis != null) {
                // 如果使用JedisPool,close操作不是关闭连接，代表归还连接池
                jedis.close();
            }
        }

这里可以看到在finally 中依然是 jedis.close() 操作为什么会把连接关闭呢，这不是和连接池原则违背吗？但实际上Jedis的close() 实现方式如下：

public void close() {
  		 // 使用Jedis连接池
        if (this.dataSource != null) {
            JedisPoolAbstract pool = this.dataSource;
            this.dataSource = null;
            if (this.client.isBroken()) {
                pool.returnBrokenResource(this);
            } else {
                pool.returnResource(this);
            }
        } else {
          // 直连
            super.close();
        }
    }

参数说明：

dataSource != null 代表使用的是连接池，所以jedis.close() 代表归还连接给连接池，而且Jedis会判断当前连接是否已经断开。

dataSource == null 代表直连，jedis.close() 代表关闭连接。

前面GenericObjectPoolConfig 使用的是默认配置，实则它提供了许多参数，例如池子中最大连接数，最大空闲连接数，最小空闲连接数，连接活性检测，等等，例如下面代码：

        GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
        //设置最大连接数为默认值5倍
        poolConfig.setMaxTotal(GenericObjectPoolConfig.DEFAULT_MAX_TOTAL * 5);
        //设置最大空闲连接数为默认的3倍
        poolConfig.setMaxIdle(GenericObjectPoolConfig.DEFAULT_MAX_IDLE * 3);
        //设置最小空闲连接数为默认的2倍
        poolConfig.setMinIdle(GenericObjectPoolConfig.DEFAULT_MIN_IDLE * 2);
        // 设置开启jmx功能
        poolConfig.setJmxEnabled(true);
        //设置连接池没有连接后客户端最大等待时间，单位毫秒
        poolConfig.setMaxWaitMillis(3000);
        JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379);