Jedis1.0.0版源码分析系列3：JedisPool.java

package redis.clients.jedis;import redis.clients.util.FixedResourcePool;public class JedisPool extends FixedResourcePool {private String host;//IPprivate int port;//端口private int timeout;//超时时间public JedisPool(String host) {//设置IPthis.host &＃61; host;this.port &＃61; Protocol.DEFAULT_PORT;}public JedisPool(String host, int port) {//设置IP和端口this.host &＃61; host;this.port &＃61; port;}public JedisPool(String host, int port, int timeout) {//设置IP和端口,超时时间this.host &＃61; host;this.port &＃61; port;this.timeout &＃61; timeout;}&＃64;Overrideprotected Jedis createResource() {//一直连接&＃xff0c;返回jedis并且已经连接上了...Jedis jedis &＃61; new Jedis(this.host, this.port, this.timeout);boolean done &＃61; false;while (!done) {try {jedis.connect();done &＃61; true;} catch (Exception e) {try {Thread.sleep(100);} catch (InterruptedException e1) {}}}return jedis;}&＃64;Overrideprotected void destroyResource(Jedis jedis) {//销毁资源if (jedis !&＃61; null && jedis.isConnected()) {try {jedis.quit();jedis.disconnect();} catch (Exception e) {}}}&＃64;Overrideprotected boolean isResourceValid(Jedis jedis) {//资源是否有效try {return jedis.isConnected() && jedis.ping().equals("PONG");} catch (Exception ex) {return false;}}
}