私はredisサーバーへの接続を管理するためにjedisプールを使用しています。次のように私のコード例:Jedis Poolの仕組みは?
public Set<String> getTopArticleList(int start, int end) {
Set<String> list = null;
Jedis j = JedisFactory.getInstance().getJedisPool().getResource();
Pipeline pipe = j.pipelined();
try {
// do stuff with redis
pipe.sync();
} catch (JedisConnectionException jex) {
JedisFactory.getInstance().getJedisPool().returnBrokenResource(j);
} finally {
JedisFactory.getInstance().getJedisPool().returnResource(j);
}
return list;
}
とコードjedisを取得するためには、問題が限定された接続数に達した後、ウェブはもうアクセスできないことである
class JedisFactory {
private static JedisPool jedisPool;
public JedisFactory() {
JedisPoolConfig poolConfig = new JedisPoolConfig();
jedisPool = new JedisPool(
poolConfig,
RedisDBConfig.HOST,
RedisDBConfig.PORT,
RedisDBConfig.TIMEOUT,
RedisDBConfig.PASSWORD
);
}
public JedisPool getJedisPool() {
return jedisPool;
}
public static JedisFactory getInstance() {
if (instance == null) {
instance = new JedisFactory();
}
return instance;
}
をプール。私は何か間違っているのですか?
はあなたがJedisFactoryの全体のコードを追加することはできますか?特にgetInstance()implとgetJedisPool()? – zenbeni
JedisFactoryの完全なコードを追加しました – ipkiss
2つ以上のスレッドを使用していますか?マルチスレッドの問題ですか? – zenbeni