|
import java.util.List;
import java.util.Map;
import java.util.ResourceBundle;
import java.util.Set;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.ShardedJedisPool;
public class RedisUtils {
private static JedisPool pool;
static {
ResourceBundle bundle = ResourceBundle.getBundle("properties/redis");
if (bundle == null) {
throw new IllegalArgumentException(
"[redis.properties] is not found!");
}
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxActive(Integer.valueOf(bundle
.getString("redis.pool.maxActive")));
config.setMaxIdle(Integer.valueOf(bundle
.getString("redis.pool.maxIdle")));
config.setMaxWait(Long.valueOf(bundle.getString("redis.pool.maxWait")));
config.setTestOnBorrow(Boolean.valueOf(bundle
.getString("redis.pool.testOnBorrow")));
config.setTestOnReturn(Boolean.valueOf(bundle
.getString("redis.pool.testOnReturn")));
pool = new JedisPool(config, bundle.getString("redis.ip1"),
Integer.valueOf(bundle.getString("redis.port")));
}
private ShardedJedisPool shardedJedisPool;
private Jedis jedis;
public void setPool(JedisPool pool) {
this.pool = pool;
}
public void setShardedJedisPool(ShardedJedisPool shardedJedisPool) {
this.shardedJedisPool = shardedJedisPool;
}
public void setJedis(Jedis jedis) {
this.jedis = jedis;
}
public String setString(String key, String value) {
Jedis jedis = pool.getResource();
try {
return jedis.set(key, value);
} finally {
pool.returnResource(jedis);
}
} |
|
|
|
|
|
|