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次，竟然沒有壓出異常，仍是不夠仔細！