首页 > 代码库 > Redis JedisPool
Redis JedisPool
获取连接池,通常连接池为单例,这里使用 双端检测机制保证只有一个实例
public class JedisPoolUtil { private static volatile JedisPool jedisPool = null; private JedisPoolUtil() { } public static JedisPool getJedisPoolInstance() { if (null == jedisPool) { synchronized (JedisPoolUtil.class) { //这里使用双端检测设计模式 if (null == jedisPool) { JedisPoolConfig poolConfig = new JedisPoolConfig(); //控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取;如果赋值为-1,则表示不限制, //如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted poolConfig.setMaxActive(1000); poolConfig.setMaxIdle(32); //设置剩余连接各数,如果小于这个就会抛异常 //表示当borrow一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛JedisConnectionException poolConfig.setMaxWait(100*1000); //获得一个jedis实例的时候是否检查连接可用性(ping()),如果为true,则得到的jedis实例均是可用的 poolConfig.setTestOnBorrow(true); jedisPool = new JedisPool(poolConfig, "192.168.1.201", 6379); } } } return jedisPool; } /** * 释放 * @param jedisPool 释放哪个池中 * @param jedis 的哪个对象 */ public static void release(JedisPool jedisPool,Jedis jedis){ if(null != jedis){ jedisPool.returnResourceObject(jedis); } } }
测试代码:
public class TestJedisPool { public static void main(String[] args) { JedisPool jedisPool = JedisPoolUtil.getJedisPoolInstance(); Jedis jedis = null; try { jedis = jedisPool.getResource(); jedis.set("aa", "bb"); } catch (Exception e) { e.printStackTrace(); } finally { JedisPoolUtil.release(jedisPool, jedis); } } }
127.0.0.1:6379> get aa
"bb"
127.0.0.1:6379>
JedisPoolCinfig
Redis JedisPool
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。