jedis

Posted 2020-12-25 dennyzhao

 

jedis ：

Jedis pool:

 

jedis:

        Jedis jedis2 = new Jedis(R_HOST, R_PORT + 1);
        jedis2.append("username", "zhangsan");

Jedis Pool：

JedisShardInfo jedis = new JedisShardInfo(R_HOST, R_PORT + 1, false);
        JedisShardInfo jedisSlave = new JedisShardInfo(R_HOST, R_PORT, false);
        List<JedisShardInfo> jedisList = new ArrayList<JedisShardInfo>();
        jedisList.add(jedisSlave);
        jedisList.add(jedis);
        
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        ShardedJedisPool pool = new ShardedJedisPool(poolConfig, jedisList,  Hashing.MURMUR_HASH, Sharded.DEFAULT_KEY_TAG_PATTERN);
        ShardedJedis sharedJedis = pool.getResource();

注意poolConfig中的内容：

     //   poolConfig.get("testOnBorrow")

• TestOnBorrow=false时，由于不检测池里连接的可用性，于是假如连接池中的连接被数据库关闭了，应用通过连接池getConnection时，都可能获取到这些不可用的连接，且这些连接如果不被其他线程回收的话，它们不会被连接池被废除，也不会重新被创建，占用了连接池的名额。
• ① 集群某实例宕掉时，如果连接刚好不处于通信阶段，tcp连接正处于CLOSE_WAIT状态或已关闭，当应用通过连接池getConnection时，在borrow时会检测连接，由于连接已关闭，于是报了如下报错，并重新建立新连接，此时的新连接到集群的其他实例上了。后面能正常通信。
• ② 集群某实例宕掉时，如果连接刚好处于通信阶段，由于客户端无法立即感知服务端已断连接，它可能会报如下错误，等待服务端的响应超时报错。当应用通过连接池getConnection时，在borrow时会检测连接，由于连接已关闭，于是报了如下报错，并重新建立新连接，此时的新连接到集群的其他实例上了。后面能正常通信。

 

参考文章： https://blog.csdn.net/wangyangzhizhou/article/details/52209336