文档章节

源码梳理——Jedis连接池的创建过程

Schema_子小山夆
 Schema_子小山夆
发布于 2015/11/01 05:24
字数 1124
阅读 180
收藏 0

一、Jedis介绍

Jedis 是 Redis 官方首选的 Java 客户端开发包。借助该开发包我们可以通过创建单个redis客户端实例来访问redis数据库,同时它也提供了连接池的实现。Jedis开发包中连接池是利用apachec开发的对象池框架commons-pool实现的,所以要想使用Jedis的连接池功能必须要导入commons-pool包。

二、一个使用连接池的小例子(Jedis-2.1.0+commons-pool-1.6)

package com.fsun.framework.cache.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class RedisManager {
	//Redis服务器IP
	private static String ADDR = "";
	    
	//Redis的端口号
	private static int PORT = 6379;
	 
	//访问密码
	private static String AUTH = "admin";
	     
	//可用连接实例的最大数目,默认值为8;
	//如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。
	private static int MAX_ACTIVE = 1024;
	  
	//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。
	private static int MAX_IDLE = 200;
	    
	//等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException;
	private static int MAX_WAIT = 10000;
	   
	private static int TIMEOUT = 10000;
	    
	//在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的;
	private static boolean TEST_ON_BORROW = true;
	 
	private static JedisPool jedisPool;
	   
	/**
	* 初始化Redis连接池
	*/
	static {
	         try {
	            JedisPoolConfig config = new JedisPoolConfig();
	           config.setMaxActive(MAX_ACTIVE);
	           config.setMaxIdle(MAX_IDLE);
	           config.setMaxWait(MAX_WAIT);
	           config.setMaxWait(MAX_WAIT);
	           config.setTestOnBorrow(TEST_ON_BORROW);
	            jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);
	         } catch (Exception e) {
	             e.printStackTrace();
	         }
	     }
	    
	    /**
	     * 获取Jedis实例
	     * @return
	      */
	     public static Jedis getJedis() {
	         try {
	             if (jedisPool != null) {
	                 Jedis resource = jedisPool.getResource();
	                 return resource;
	             } else {
	                 return null;
	             }
	        } catch (Exception e) {
	             e.printStackTrace();
	            return null;
	         }
	     }
	     
	     /**
	      * 释放jedis资源
	      * @param jedis
	      */
	     public static void returnResource(final Jedis jedis) {
	         if (jedis != null) {
	             jedisPool.returnResource(jedis);
	         }
	     }
}

三、连接池创建过程

上面例子连接池初始化代码如下;

JedisPoolConfig config = new JedisPoolConfig();
config.setMaxActive(MAX_ACTIVE);
config.setMaxIdle(MAX_IDLE);
config.setMaxWait(MAX_WAIT);
config.setMaxWait(MAX_WAIT);
config.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);

连接池一些配置信息如池中最大活跃数量、最大空闲数量等等被存储在JedisPoolConfig对象中。JedisPoolConfig继承commons-pool包中的Config类,是一个比较纯碎的javabean,不做过多阐述。

JedisPool继承commons-pool包中的Pool类,其初始化的过程是调用父类Pool类的构造器完成的。

public abstract class Pool<T> {
    private final GenericObjectPool internalPool;

    public Pool(final GenericObjectPool.Config poolConfig,
            PoolableObjectFactory factory) {
        this.internalPool = new GenericObjectPool(factory, poolConfig);
    }

Jedis把JedisFactory传工厂类给了父类的构造器,JedisFactory继承BasePoolableObjectFactory抽象类(BasePoolableObjectFactory实现了PoolableObjectFactory接口),重写了其中的makeObject方法。

 public Object makeObject() throws Exception {
       final Jedis jedis = new Jedis(this.host, this.port, this.timeout);

       jedis.connect();
       if (null != this.password) {
           jedis.auth(this.password);
       }
       if( database != 0 ) {
           jedis.select(database);
       }
            
       return jedis;
 }

makeObject方法提供了创建Jedis实例的功能,commons-pool在初始化池的时候调用我们传入的工厂类makeObject方法来创建要放入缓存池中的对象,这个地方用到了抽象工厂模式这样的设计思想。JedisFactory的makeObject方法做了这几件事:

                                    (1)创建Jedis实例

                                    (2)连接redis服务器

                                    (3)如果redis服务器需要密码则向服务器提供密码

                                    (4)如果指定数据库不是默认的0,则选择指定的数据库

下面是单个Jedis实例的构造很简单,目标就是要创建Client客户端实例保存到成员属性中,Client间接继承了Connection,Jedis的构造仅仅是把从Connection继承而来的三个属性主机地址、端口号和连接超时时间进行赋值:

public Connection(final String host, final int port) {
    super();
    this.host = host;
    this.port = port;
}

Jedis实例创建完之后利用Socket套接字和redis服务器进行连接,这个过程是在Connection类中进行的,建立连接之后将输入流和输出流保存到成员对象中,这样以后就可以向redis服务器发送命令,代码如下:

 public void connect() {
        if (!isConnected()) {
            try {
                socket = new Socket();
                //->@wjw_add
                socket.setReuseAddress(true);
                socket.setKeepAlive(true);  //Will monitor the TCP connection is valid
                socket.setTcpNoDelay(true);  //Socket buffer Whetherclosed, to ensure timely deliver//y of data
                socket.setSoLinger(true,0);  //Control calls close () method, the underlying socket //is closed immediately
                //<-@wjw_add

                socket.connect(new InetSocketAddress(host, port), timeout);
                socket.setSoTimeout(timeout);
                outputStream = new RedisOutputStream(socket.getOutputStream());
                inputStream = new RedisInputStream(socket.getInputStream());
            } catch (IOException ex) {
                throw new JedisConnectionException(ex);
            }
        }
    }

这样redis连接池就完成了初始化的工作。




© 著作权归作者所有

Schema_子小山夆
粉丝 0
博文 18
码字总数 51128
作品 0
南京
高级程序员
私信 提问
源码走读-从JedisCluster的设计来发现对象池的奥秘

JedisCluster究竟是如何获得一个connection的?内部对象池又是如何工作的? 今天我们就去JedisCluster的源码看看,一探究竟。 好,先从JedisCluster开始。 JedisCluster 可以看到JedisCluste...

ImportSource
2018/04/21
0
0
Redis应用学习(三)——Jedis客户端的简单使用介绍

Redis的Java客户端程序——Jedis 1. 在Redis的安装目录中redis-cli是一个Redis的Shell语言写的客户端,通过运行该客户端就可以实现一系列Redis操作,而如果要使用Java语言的Redis客户端,就必...

江左煤郎
2018/10/27
59
0
Redis初探(7)——Jedis操纵集群

在Redis初探(2)——Jedis的使用中,我们已经学会了Jedis操纵单机Redis的简单使用,本章将继续深入,介绍Jedis对集群的操纵。 一、Jedis连接单机 在开始介绍Jedis连接集群之前,先简单回顾下...

yuanlaijike
2018/04/09
0
0
Jedis cluster集群初始化源码剖析

在项目中我们经常使用spring-data-redis来操作Redis,它封装了Jedis客户端来与Redis服务器进行各种命令操作。由于最近用到了Redis Cluster集群功能,这里就分析总结一下Jedis cluster集群初始...

九州暮云
2017/10/30
1K
0
Redis 客户端Jedis使用(一)

Jedis 是Redis 的Java客户端,通过一段时间的使用,jedis基本实现redis的所有功能,并且jedis在客户端实现redis数据分片功能,Redis本身是没有数据分布功能。 一、下载jedis 代码 jedis 代码...

小李飞刀008
2013/10/17
27.9K
0

没有更多内容

加载失败,请刷新页面

加载更多

MainThreadSupport

MainThreadSupport EventBus 3.0 中的代码片段. org.greenrobot.eventbus.MainThreadSupport 定义一个接口,并给出默认实现类. 调用者可以在EventBus的构建者中替换该实现. public interface ...

马湖村第九后羿
31分钟前
3
0
指定要使用的形状来代替文字的显示

控制手机键盘弹出的功能只能在ios上实现,安卓是实现不了的,所以安卓只能使用type类型来控制键盘类型,例如你要弹出数字键盘就使用type="number",如果要弹出电话键盘就使用type="tel",但这...

前端老手
41分钟前
5
0
总结:Raft协议

一、Raft协议是什么? 分布式一致性算法。即解决分布式系统中各个副本数据一致性问题。 二、Raft的日志广播过程 发送日志到所有Followers(Raft中将非Leader节点称为Follower)。 Followers收...

浮躁的码农
49分钟前
5
0
Flask-admin Model View字段介绍

Model View字段介绍 can_create = True 是否可以创建can_edit = True 是否可以编辑can_delete = True 是否可以删除list_template = 'admin/model/list.html' 修改显......

dillonxiao
今天
5
0
从AnnotationTransactionAspect开始rushSpring事务

0. Spring 事务 with LTW 0.1. Spring 事务 With LTW的原因: Pure Proxy-base mode有缺陷,其失效原因分析及使用方法及运行机制(LoadTimeWeaverBeanDefinitionParser和 AspectJWeavingEnable......

Aruforce
今天
9
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部