ShardedJedis 错误使用

BEFORE: 以前使用的单实例的JedisPool没有这个问题；JedisPool的connected_clients 通常不会超过80； AFTER： 扩展后6个实例，每一个实例能够达到10K，从80徒增到60w；

STEP 0. Jedis使用的是apache common-pool 的 BasePoolableObjectFactory管理对象。 public interface PooledObjectFactory<T> { PooledObject<T> makeObject(); void activateObject(PooledObject<T> obj); void passivateObject(PooledObject<T> obj); boolean validateObject(PooledObject<T> obj); void destroyObject(PooledObject<T> obj); }

STEP 1. 代码跟踪的时候，发现一直不断的建立对象，没有使用池中的对象；Redis 服务器接收到不少PING；connected_clients没有下降；

**STEP 2.**发现进入destroyObject后，没有处理过jedis.disconnect()，定位 (obj instanceof ShardedJedis) == false。

public void destroyObject(final Object obj) throws Exception {
    if ((obj != null) && (obj instanceof ShardedJedis)) {
        ShardedJedis shardedJedis = (ShardedJedis) obj;
        for (Jedis jedis : shardedJedis.getAllShards()) {
            try {
           		try {
           			jedis.quit();
                } catch (Exception e) {

                }
                jedis.disconnect();
            } catch (Exception e) {

            }
        }
    }
}

STEP 3. redis.clients.util.Pool中的 public void returnResourceObject(final Object resource){}//为何是Object，不使用泛型~~~

总结： ShardedJedis在使用完后要将整个ShardedJedis对象放回池中。

but：发布前在本地压测10个线程，每一个线程循环10000次，竟然没有压出异常，仍是不够仔细！