这篇文章给大家介绍如何进行JedisPool.java的分析,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
专注于为中小企业提供成都网站制作、做网站服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业通榆免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了成百上千家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。
package redis.clients.jedis; import redis.clients.util.FixedResourcePool; public class JedisPool extends FixedResourcePool{ private String host;//IP private int port;//端口 private int timeout;//超时时间 public JedisPool(String host) {//设置IP this.host = host; this.port = Protocol.DEFAULT_PORT; } public JedisPool(String host, int port) {//设置IP和端口 this.host = host; this.port = port; } public JedisPool(String host, int port, int timeout) {//设置IP和端口,超时时间 this.host = host; this.port = port; this.timeout = timeout; } @Override protected Jedis createResource() {//一直连接,返回jedis并且已经连接上了... Jedis jedis = new Jedis(this.host, this.port, this.timeout); boolean done = false; while (!done) { try { jedis.connect(); done = true; } catch (Exception e) { try { Thread.sleep(100); } catch (InterruptedException e1) { } } } return jedis; } @Override protected void destroyResource(Jedis jedis) {//销毁资源 if (jedis != null && jedis.isConnected()) { try { jedis.quit(); jedis.disconnect(); } catch (Exception e) { } } } @Override protected boolean isResourceValid(Jedis jedis) {//资源是否有效 try { return jedis.isConnected() && jedis.ping().equals("PONG"); } catch (Exception ex) { return false; } } }
关于如何进行JedisPool.java的分析就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。