(三)redis连接池详解
2018-01-11 17:29
204 查看
摘要: 原子性(atomicity): 一个事务是一个不可分割的最小工作单位,事务中包括的诸操作要么都做,要么都不做。 Redis所有单个命令的执行都是原子性的,这与它的单线程机制有关; Redis命令的原子性使得我们不用考虑并发问题,可以方便的利用原子性自增操作INCR实现简单计数器功能;
一、首先我们看一个异常
需要注意的是,redis-cli客户端在进入subscribe模式以后,将不能再响应其他的任何命令:
二、我们将Jedis实例获取方式改为JedisPool
一、首先我们看一个异常
Exception in thread "main" redis.clients.jedis.exceptions.JedisDataException: ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT allowed in this context at redis.clients.jedis.Protocol.processError(Protocol.java:127) at redis.clients.jedis.Protocol.process(Protocol.java:161) at redis.clients.jedis.Protocol.read(Protocol.java:215) at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:340) at redis.clients.jedis.Connection.getRawObjectMultiBulkReply(Connection.java:285) at redis.clients.jedis.JedisPubSub.process(JedisPubSub.java:121) at redis.clients.jedis.JedisPubSub.proceed(JedisPubSub.java:115) at redis.clients.jedis.Jedis.subscribe(Jedis.java:2680) at redis.v1.client.RedisSubscribe.main(RedisSubscribe.java:23)根据异常的提示我们大概可以判断出由于redis客户端是个单例模式,发布订阅频道之后就不允许其它的操作(除(P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT之外);
需要注意的是,redis-cli客户端在进入subscribe模式以后,将不能再响应其他的任何命令:
二、我们将Jedis实例获取方式改为JedisPool
package redis.v1.client.server; import org.apache.commons.pool2.impl.GenericObjectPoolConfig; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class JedisPoolClient { private static JedisPool pool = null; /** * * 方法描述 构建redis连接池 * * @return * * @author yaomy * @date 2018年1月11日 下午4:53:07 */ static { if(pool == null) { JedisPoolConfig config = new JedisPoolConfig(); //控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取; //如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。 config.setMaxTotal(500); //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。 config.setMaxIdle(5); //表示当borrow(引入)一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛出JedisConnectionException;单位毫秒 config.setMaxWaitMillis(1000*100); //在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是 4000 可用的; config.setTestOnBorrow(true); pool = new JedisPool(config, "127.0.0.1", 6379, 1000, "619868"); } } /** * * 方法描述 获取Jedis实例 * * @return * * @author yaomy * @date 2018年1月11日 下午4:56:58 */ public static Jedis getJedis() { return pool.getResource(); } }三、获取订阅频道
List<String> list = JedisPoolClient.getJedis().pubsubChannels("*"); for(String channel:list) { System.out.println("---订阅频道:"+channel); }执行结果:
订阅服务器运行状态:PONG onSubscribe---redisChat---1 onSubscribe---redisChat1---2 onSubscribe---redisChat2---3 休眠第2秒 ---channels---3 ---订阅频道:redisChat ---订阅频道:redisChat2 ---订阅频道:redisChat1 休眠第4秒 ---channels---3 ---订阅频道:redisChat ---订阅频道:redisChat2 ---订阅频道:redisChat1 休眠第8秒 ---channels---3 ---订阅频道:redisChat ---订阅频道:redisChat2 ---订阅频道:redisChat1 休眠第16秒 ---channels---3 ---订阅频道:redisChat ---订阅频道:redisChat2 ---订阅频道:redisChat1 休眠第32秒 ---channels---3 ---订阅频道:redisChat ---订阅频道:redisChat2 ---订阅频道:redisChat1 休眠第64秒 ---channels---3 ---订阅频道:redisChat ---订阅频道:redisChat2 ---订阅频道:redisChat1