`
ssxxjjii
  • 浏览: 950399 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

redis的java客户端jedis 2.1.0版本使用备忘

 
阅读更多

http://blog.csdn.net/joeyyeoj/article/details/8101496

前言

工作中要使用redis作为cache server,目前应用是SSH架构,redis官方推荐的java客户端jedis,这里记录我使用过程中的问题和解决办法,jedis版本是2.1.0。

Jedis的框架概览

Jedis使用了apache commons-pool库,用来实现连接redis客户端的池子。
 
commons-pool库中有三个类:GenericObjectPool、PoolableObjectFactory、Config,其中:
PoolableObjectFactory:表示一个对象工厂,含有能控制一个对象生命周期的方法,如创建、销毁、验证、激活、失效等操作;
GenericObjectPool:表示了一个抽象的、支持泛型的对象池,ta内部包含从池中取出、退还、验证对象等操作(使用对象工厂PoolableObjectFactory来完成相应操作),并且记录了当前池中的active、idle对象的个数;
Config:则表示一个对象池的配置,配置参数包括:最大active、最大idle、最大wait毫秒数等。
 
Jedis中比较重要的几个类:
Jedis:表示一个Jedis Cilent示例;
Pool:继承自GenericObjectPool,表示一个支持泛型的对象池,构造方法接受Config和PoolableObjectFactory参数,使用代理模式(内部有一个GenericObjectPool对象),并提供了getResource、returnResource等操作(通过PoolableObjectFactory的操作来完成);【这个对象,被jedis放在了util包中,ta是个对象池工具类,可直接用于其他对象实现对象池。】
JedisPool:继承自Pool,利用Pool对泛型的支持实现了一个Jedis对象的对象池;
JedisFactory:继承自PoolableObjectFactory,包含了Jedis对象的生命周期管理;
JedisPoolConfig:继承自Config,ta只是为了方便与IoC容器(.java文件中有与Spring集成的示例代码)的集成,Config的各个类增加setter/getter方法;
 
【在Jedis中,与redis的pub/sub、pipeline、sharded等,暂时没用到,所以也没去看】

Jedis的使用

1.如何管理Jedis实例

Jedis在github上的readme中,介绍了最简单的Jedis实例使用方法,如下:
  1. Jedis jedis = new Jedis("localhost");  
  2. jedis.set("foo""bar");  
  3. String value = jedis.get("foo");  
Jedis jedis = new Jedis("localhost");
jedis.set("foo", "bar");
String value = jedis.get("foo");
上面的方式虽然简单,但不能在实际项目中使用。如果用单例模式,必然影响并发;如果创建多个jedis实例,就必须采用池的模式,否则新建/销毁的开销受不了。
还好Jedis没给出如何使用Pool,不过还好有代码,通过看代码,在JedisPoolConfig.java文件中有如下描述:
Spring example:
*
* <bean id="jedisConfig" class="redis.clients.jedis.JedisPoolConfig"> <property
* name="testWhileIdle" value="true"/> </bean>
*
* <bean id="jedisPool" class="redis.clients.jedis.JedisPool"
* destroy-method="destroy"> <constructor-arg ref="jedisConfig" />
* <constructor-arg value="localhost" /> <constructor-arg type="int"
* value="6379" /> </bean>
【摘自于https://github.com/xetorthio/jedis/blob/master/src/main/java/redis/clients/jedis/JedisPoolConfig.java
既然ta能跟Spring方便实现IoC,就继续看JedisPool和JedisPoolConfig的代码,才发现他们是如何利用commons-pool库的。
所以有两种靠谱儿方式来使用Jedis实例:
1.如果在IoC容器中,可直接使用上面的方式配置到Spring配置文件中;
2.如果没IoC容器,就可以直接new JedisPool(JedisPoolConfig, JedisFactory)来创建一个JedisPool实例来管理Jedis实例;

2.JedisPool如何管理Jedis实例

Jedis实例都在JedisPool中,所以:
1->获取Jedis实例需要从JedisPool中获取;
2->用完Jedis实例需要还给JedisPool;
3->如果Jedis在使用过程中出错,则也需要还给JedisPool;
总结以上三点,可以用下面一段代码来实现:
  1. <PRE class=java name="code">JedisPool pool = null;  
  2. Jedis instance = null;  
  3. pool = new JedisPool(poolConfig, "10.1.81.194"6379);  
  4. boolean borrowOrOprSuccess = true;  
  5. try {  
  6.     instance = pool.getResource();  
  7.     // do redis opt by instance</PRE><PRE class=java name="code" sizcache="1" sizset="5">        …………………………………………………………………………   
  8. catch (JedisConnectionException e) {  
  9. <PRE class=java name="code">        borrowOrOprSuccess = false;</PRE><PRE class=java name="code">        if (instance != null)</PRE> pool.returnBrokenResource(instance);  
  10. <PRE></PRE>  
  11. <PRE class=java name="code">} finally {</PRE><PRE class=java name="code">        if (borrowOrOprSuccess)  
  12.               pool.returnResource(instance);</PRE><PRE class=java name="code">}</PRE>  
  13. <PRE></PRE>  
  14. </PRE>  
  1. JedisPool pool = null;  
  2. Jedis instance = null;  
  3. pool = new JedisPool(poolConfig, "10.1.81.194"6379);  
  4. boolean borrowOrOprSuccess = true;  
  5. try {  
  6.     instance = pool.getResource();  
  7.     // do redis opt by instance  
JedisPool pool = null;
Jedis instance = null;
pool = new JedisPool(poolConfig, "10.1.81.194", 6379);
boolean borrowOrOprSuccess = true;
try {
	instance = pool.getResource();
	// do redis opt by instance
  1.         …………………………………………………………………………  
  2. catch (JedisConnectionException e) {  
  3. <PRE class=java name="code">        borrowOrOprSuccess = false;</PRE><PRE class=java name="code">        if (instance != null)</PRE> pool.returnBrokenResource(instance);  
  4. <PRE></PRE>  
  5. <PRE class=java name="code">} finally {</PRE><PRE class=java name="code">        if (borrowOrOprSuccess)  
  6.               pool.returnResource(instance);</PRE><PRE class=java name="code">}</PRE>  
  7. <PRE></PRE>  
…………………………………………………………………………
} catch (JedisConnectionException e) {
  1. borrowOrOprSuccess = false;  
        borrowOrOprSuccess = false;
  1. if (instance != null)  
        if (instance != null)
pool.returnBrokenResource(instance);

  1. finally {  
} finally {
  1. if (borrowOrOprSuccess)  
  2.       pool.returnResource(instance);  
        if (borrowOrOprSuccess)
              pool.returnResource(instance);
  1. }  
}
1->虽然抛出JedisConnectionException,但实际上有两类错误,一类是pool.getReource(),得不到可用的jedis实例;另一类是jedis.set/get时出错也会抛出这个Exception;为了实现区分,所以根据instance是否为null来实现,如果为空就证明instance根本就没初始化,也就不用return给pool;如果instance不为null,则证明是需要返还给pool的;
2->在instance出错时,也要调用returnBrokenResource返还给pool,否则下次通过getResource得到的instance的缓冲区可能还存在数据,出现问题!

3.如何配置Pool的参数

JedisPool的配置参数很大程度上依赖于实际应用需求、软硬件能力。以前没用过commons-pool,所以这次花了一整间专门看这些参数的含义。。。JedisPool的配置参数大部分是由JedisPoolConfig的对应项来赋值的。
 
maxActive:控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取;如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态就成exhausted了,在JedisPoolConfig
maxIdle:控制一个pool最多有多少个状态为idle的jedis实例;
whenExhaustedAction:表示当pool中的jedis实例都被allocated完时,pool要采取的操作;默认有三种WHEN_EXHAUSTED_FAIL(表示无jedis实例时,直接抛出NoSuchElementException)、WHEN_EXHAUSTED_BLOCK(则表示阻塞住,或者达到maxWait时抛出JedisConnectionException)、WHEN_EXHAUSTED_GROW(则表示新建一个jedis实例,也就说设置的maxActive无用);
maxWait:表示当borrow一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛出JedisConnectionException;
testOnBorrow:在borrow一个jedis实例时,是否提前进行alidate操作;如果为true,则得到的jedis实例均是可用的;
testOnReturn:在return给pool时,是否提前进行validate操作;
testWhileIdle:如果为true,表示有一个idle object evitor线程对idle object进行扫描,如果validate失败,此object会被从pool中drop掉;这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义;
timeBetweenEvictionRunsMillis:表示idle object evitor两次扫描之间要sleep的毫秒数;
numTestsPerEvictionRun:表示idle object evitor每次扫描的最多的对象数;
minEvictableIdleTimeMillis:表示一个对象至少停留在idle状态的最短时间,然后才能被idle object evitor扫描并驱逐;这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义;
softMinEvictableIdleTimeMillis:在minEvictableIdleTimeMillis基础上,加入了至少minIdle个对象已经在pool里面了。如果为-1,evicted不会根据idle time驱逐任何对象。如果minEvictableIdleTimeMillis>0,则此项设置无意义,且只有在timeBetweenEvictionRunsMillis大于0时才有意义;
lifo:borrowObject返回对象时,是采用DEFAULT_LIFO(last in first out,即类似cache的最频繁使用队列),如果为False,则表示FIFO队列;
 
其中JedisPoolConfig对一些参数的默认设置如下:
testWhileIdle=true
minEvictableIdleTimeMills=60000
timeBetweenEvictionRunsMillis=30000
numTestsPerEvictionRun=-1

4.在spring中如何使用jedis

在上面1中介绍了如何在spring的context.xml中如何配置JedisPool。
分享到:
评论

相关推荐

    redis java客户端 jedis

    一个简单java客户端Jedis,大家可以到https://github.com/xetorthio/jedis这网址下载相关源码 这里对其进行一个简单封转 包括key valye set list hashset的封装

    Redis Java客户端Jedis 2.9.0 jar包(含common-pool2)

    Redis的官方推荐Java客户端——Jedis 此Jar包为Jedis 2.9.0版(2016年7月22日发布) 支持Redis 3.0 (亲测有效) 使用方法: import redis.clients.jedis.Jedis; Jedis jedis = new Jedis("localhost"); jedis.set...

    redis相关jar包(redis2.1.5、jedis2.9.0)

    Jedis是Java社区广泛使用的Redis客户端库,版本2.9.1包含了对Redis各种命令的支持,包括基本的键值操作、事务处理、发布订阅、Lua脚本执行等功能。Jedis提供了简单易用的API,使得Java开发者可以方便地与Redis服务器...

    Redis的Java客户端Jedis

    **Redis的Java客户端Jedis详解** Redis是一款高性能的键值对数据存储系统,常用于缓存、消息中间件等场景。而Jedis是Redis官方推荐的Java语言客户端,提供了丰富的API来与Redis服务器进行交互。在2018年6月10日,...

    Redis Java客户端Jedis 2.9.0 jar+commons-pool2-2.4.2

    Java客户端Jedis是Redis官方推荐的Java语言接口库,它提供了丰富的API来操作Redis服务器。Jedis 2.9.0是该库的一个稳定版本,适用于各种Java项目与Redis服务器进行交互。 在Jedis 2.9.0版本中,主要包含了以下功能...

    各种版本的redis+Jedis驱动包

    4. **Jedis**:Jedis是Java语言的Redis客户端库,它提供了丰富的API,使Java开发者能够方便地与Redis进行交互。Jedis支持各种Redis命令,包括数据类型操作、事务处理、发布/订阅、持久化等。在实际项目中,通过Jedis...

    Jedis2.1.0源码与Jar包

    **Jedis 2.1.0:连接Redis的Java客户端** Jedis是Java社区中广泛使用的Redis客户端库,它提供了丰富的API,使得开发者能够轻松地在Java应用中操作Redis数据库。Jedis 2.1.0是这个库的一个版本,包含了源代码和对应...

    jedisRedis的Java客户端

    Jedis是Redis的Java客户端,它提供了一个丰富的API来操作Redis数据存储系统。Redis是一个高性能的键值数据库,常用于缓存、消息中间件以及数据结构服务器等场景。Jedis作为Java开发者与Redis交互的主要工具,使得在...

    spring_redis集成(jedis java客户端)

    spring_redis集成,通过jedis作为redis的客户端。 只提供集成方式,具体api,参照jedis API

    redis的Java客户端jedis池的介绍及使用.rar

    通过上述内容,我们了解了Redis的Java客户端Jedis池的基本概念、配置和使用。在实际开发中,正确使用JedisPool能够显著提升应用性能,同时降低资源消耗。在设计系统时,应充分考虑连接池的管理,确保系统的稳定性和...

    redis的Java客户端jedis使用示例.rar

    Jedis是Java社区中最常用的Redis客户端库,它提供了丰富的API来操作Redis服务器。本示例将详细介绍如何在Java应用中使用Jedis进行基本操作。 首先,我们需要在项目中引入Jedis的依赖。如果你使用的是Maven,可以在...

    Redis Java 客户端.zip

    Jedis 是Redis的 Java 客户端,专为性能和易用性而设计。您是否在寻找一个高级库来处理对象映射?请参阅redis-om-spring!如何使用 Redis?在 Redis 大学免费学习试用 Redis Cloud深入了解开发者教程加入 Redis 社区...

    jedis-2.9.0 最新版Redis客户端CSDN下载

    Jedis是Java语言中使用最广泛的Redis客户端库,它提供了丰富的API来操作Redis服务器。在这个"jedis-2.9.0"的最新版本中,我们包含了三个重要的文件: 1. `jedis-2.9.0.jar`:这是Jedis的二进制发行版,包含了所有...

    redis+spring jedis方式

    Jedis是Redis官方推荐的Java客户端,它提供了一套完整的Redis命令实现。虽然Spring Data Redis提供了更高级别的抽象,但有时直接使用Jedis可以实现更复杂的操作或优化性能。Jedis支持连接池,以提高并发性能。如果你...

    Redis客户端之Jedis

    Jedis是Java开发的Redis官方推荐的客户端,它提供了丰富的API来执行Redis命令,涵盖了Redis的所有功能,包括字符串、哈希、列表、集合、有序集合等数据类型的操作,以及事务、发布订阅、脚本执行等高级特性。...

    redis,jedis 需要的jar包

    使用Java操作Redis需要jedis-2.1.0.jar,如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar使用Java操作Redis需要jedis-2.1.0.jar,如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar

    (重新整理版)redis的java客户端jedis 管理类代码 支持主从复制的自动选择和自动恢复,读/写分离

    * redis主从架构的jedis客户端管理类,大概1000多行代码左右 * 1 支持主从复制key/value,pop/push,pub/sub,读/写分离等功能的灾难失败自动选择和恢复 * 2 可以选择读写分离功能,主写从读,默认不启用,都使用主服务...

    redis实现分布式锁(java/jedis)

    redis实现分布式锁(java/jedis),其中包含工具方法以及使用demo 本资源是利用java的jedis实现 redis实现分布式锁(java/jedis),其中包含工具方法以及使用demo 本资源是利用java的jedis实现

    redis的java客户端jedis 管理类代码 支持主从复制的自动选择和自动恢复,读/写分离

    * redis主从架构的jedis客户端管理类,大概1000行代码左右 * 1 支持主从复制key/value,pop/push,pub/sub,读/写分离等功能的灾难失败自动选择和恢复 * 2 可以选择读写分离功能,主写从读,默认不启用,都使用主服务进行...

Global site tag (gtag.js) - Google Analytics