Jedis缓存实现无JedisPool /公地pool2-2.0

Question

如何实现Jedis没有JedisPool /公地pool2-2.0，因为我们仍然使用的是JDK 1.5（公地pool2-2.0不支持JDK 1.5）

如何实现线程安全连接池？

Answer 1

我不确定Jedis与Java 5的兼容性。您可以基于较早的commons-pool 1.6库创建自己的池。您不需要在班级路径上使用commons-pool2来运行jedis。我使用Jedis 2.7.3和commons-pool 1.6来验证解决方案。

查找附加示例代码：

import org.apache.commons.pool.ObjectPool; 
import org.apache.commons.pool.PoolableObjectFactory; 
import org.apache.commons.pool.impl.GenericObjectPool; 
import redis.clients.jedis.Jedis; 

public class JedisWithOwnPooling { 

    public static void main(String[] args) throws Exception { 

     ObjectPool<Jedis> pool = new GenericObjectPool(new JedisFactory("localhost")); 

     Jedis j = pool.borrowObject(); 
     System.out.println(j.ping()); 

     pool.returnObject(j); 

     pool.close(); 

    } 

    private static class JedisFactory implements PoolableObjectFactory<Jedis> { 

     private String host; 

     /** 
     * Add fields as you need. That's only an example. 
     */ 
     public JedisFactory(String host) { 
      this.host = host; 
     } 

     @Override 
     public Jedis makeObject() throws Exception { 
      return new Jedis(host); 
     } 

     @Override 
     public void destroyObject(Jedis jedis) throws Exception { 
      jedis.close(); 
     } 

     @Override 
     public boolean validateObject(Jedis jedis) { 
      return jedis.isConnected(); 
     } 

     @Override 
     public void activateObject(Jedis jedis) throws Exception { 
      if (!jedis.isConnected()) { 
       jedis.connect(); 
      } 
     } 

     @Override 
     public void passivateObject(Jedis jedis) throws Exception { 

     } 
    } 
}