【Java】Jedis连接池使用
2017-05-11 09:35
288 查看
1.构建redis连接池,返还到连接池
private static JedisPool jedisPool = null;
private static Jedis jedis;
static {
jedis = getJedisPool().getResource();
}
/**
* 构建redis连接池
*/
public static JedisPool getJedisPool() {
if (jedisPool == null) {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(1024); // 可用连接实例的最大数目,如果赋值为-1,表示不限制.
config.setMaxIdle(5); // 控制一个Pool最多有多少个状态为idle(空闲的)jedis实例,默认值也是8
config.setMaxWaitMillis(1000 * 100); // 等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时/如果超过等待时间,则直接抛出异常
config.setTestOnBorrow(true); // 在borrow一个jedis实例时,是否提前进行validate操作,如果为true,则得到的jedis实例均是可用的
jedisPool = new JedisPool(config, "127.0.0.1", 6379);
}
return jedisPool;
}
/**
* 释放jedis资源
*/
public static void returnResource(Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}
2.jedis使用
典型的jedis使用方法
这种写法会经常忘记返回jedis到pool.参考Spting JdbcTemplate的实现方式,优化如下
优化jedis使用方法
RedisTemplate封装了从JedisPool中取jedis以及返回池中
public class RedisTemplate {
private JedisPool jedisPool;
public RedisTemplate(JedisPool jedisPool) {
this.jedisPool = jedisPool;
}
public <T> T execute(RedisCallback<T> callback) {
Jedis jedis = jedisPool.getResource();
try {
return callback.handle(jedis);
}
catch (Exception e) {
// throw your exception
throw e;
}
finally {
returnResource(jedis);
}
}
private void returnResource(Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}
}
常用的jedis方法
字符串
列表
@Test
public void testList() {
String key = "java framework";
jedis.lpush(key, "spring");
jedis.lpush(key, "spring mvc");
jedis.lpush(key, "mybatis");
System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
jedis.del(key);
jedis.rpush(key, "spring");
jedis.rpush(key, "spring mvc");
jedis.rpush(key, "mybatis");
System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
System.out.println(jedis.llen(key)); // 列表长度
System.out.println(jedis.lrange(key, 0, 3));
jedis.lset(key, 0 , "redis"); // 修改列表中单个值
System.out.println(jedis.lindex(key, 1)); // 获取列表指定下标的值
System.out.println(jedis.lpop(key)); // 列表出栈
System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
}
散列
@Test
public void testMap() {
String key = "user";
Map<String, String> map = new HashMap<>();
map.put("name", "webb");
map.put("age", "24");
map.put("city", "hangzhou");
jedis.hmset(key, map); // 添加数据
List<String> rsmap = jedis.hmget(key, "name", "age", "city"); // 第一个参数存入的是redis中map对象的key,后面跟的是放入map中的对象的key
System.out.println(rsmap);
jedis.hdel(key, "age"); // 删除map中的某个键值
System.out.println(jedis.hmget(key, "age"));
System.out.println(jedis.hlen(key)); // 返回key为user的键中存放的值的个数
System.out.println(jedis.exists(key)); // 是否存在key为user的记录
System.out.println(jedis.hkeys(key)); // 返回map对象中的所有key
System.out.println(jedis.hvals(key)); // 返回map对象中所有的value
Iterator<String> iterator = jedis.hkeys("user").iterator();
while (iterator.hasNext()) {
String key2 = iterator.next();
System.out.print(key2 + " : " + jedis.hmget("user", key2) + "\n");
}
}
集合
@Test
public void testSet() {
String key = "userSet";
String key2 = "userSet2";
jedis.sadd(key, "webb");
jedis.sadd(key, "webb");
jedis.sadd(key, "lebo");
jedis.sadd(key, "lebo0425");
jedis.sadd(key, "who");
jedis.srem(key, "who"); // 删除
System.out.println(jedis.smembers(key)); // 获取所有加入的value
System.out.println(jedis.sismember(key, "who")); // 判断value是否在集合中
System.out.println(jedis.srandmember(key)); // 随机返回一个value
System.out.println(jedis.scard(key)); // 返回集合的元素个数
jedis.sadd(key2, "webb");
jedis.sadd(key2, "ssq");
System.out.println(jedis.sinter(key, key2)); // 交集
System.out.println(jedis.sunion(key, key2)); // 并集
System.out.println(jedis.sdiff(key, key2)); // 差集
}
有序集合
@Test
public void testSortedSet() {
String key = "sortedSet";
jedis.zadd(key, 1999, "one");
jedis.zadd(key, 1994, "two");
jedis.zadd(key, 1998, "three");
jedis.zadd(key, 2000, "four");
jedis.zadd(key, 2017, "five");
Set<String> setValues = jedis.zrange(key, 0 , -1); // score从小到大
System.out.println(setValues);
Set<String> setValues2 = jedis.zrevrange(key, 0, -1); // score从大到小
System.out.println(setValues2);
System.out.println(jedis.zcard(key)); // 元素个数
System.out.println(jedis.zscore(key, "three")); // 元素下标
System.out.println(jedis.zrange(key, 0, -1)); // 集合子集
System.out.println(jedis.zrem(key, "five")); // 删除元素
System.out.println(jedis.zcount(key, 1000, 2000)); // score在1000-2000内的元素个数
}
private static JedisPool jedisPool = null;
private static Jedis jedis;
static {
jedis = getJedisPool().getResource();
}
/**
* 构建redis连接池
*/
public static JedisPool getJedisPool() {
if (jedisPool == null) {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(1024); // 可用连接实例的最大数目,如果赋值为-1,表示不限制.
config.setMaxIdle(5); // 控制一个Pool最多有多少个状态为idle(空闲的)jedis实例,默认值也是8
config.setMaxWaitMillis(1000 * 100); // 等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时/如果超过等待时间,则直接抛出异常
config.setTestOnBorrow(true); // 在borrow一个jedis实例时,是否提前进行validate操作,如果为true,则得到的jedis实例均是可用的
jedisPool = new JedisPool(config, "127.0.0.1", 6379);
}
return jedisPool;
}
/**
* 释放jedis资源
*/
public static void returnResource(Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}
2.jedis使用
典型的jedis使用方法
public static String get(String key) { String value = null; Jedis jedis = null; try { JedisPool pool = getJedisPool(); jedis = pool.getResource(); value = jedis.get(key); } catch (Exception e) { returnResource(jedis); e.printStackTrace(); } finally { returnResource(jedis); } return value; }
这种写法会经常忘记返回jedis到pool.参考Spting JdbcTemplate的实现方式,优化如下
优化jedis使用方法
public static String getByTemplate(final String key) { RedisTemplate redisTemplate = new RedisTemplate(getJedisPool()); String value = redisTemplate.execute(new RedisCallback<String>() { @Override public String handle(Jedis jedis) { return jedis.get(key); } }); return value; }
RedisTemplate封装了从JedisPool中取jedis以及返回池中
public class RedisTemplate {
private JedisPool jedisPool;
public RedisTemplate(JedisPool jedisPool) {
this.jedisPool = jedisPool;
}
public <T> T execute(RedisCallback<T> callback) {
Jedis jedis = jedisPool.getResource();
try {
return callback.handle(jedis);
}
catch (Exception e) {
// throw your exception
throw e;
}
finally {
returnResource(jedis);
}
}
private void returnResource(Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}
}
public interface RedisCallback<T> { public T handle(Jedis jedis); }
常用的jedis方法
字符串
@Test public void testString() { jedis.set("name", "webb"); // 添加数据 System.out.println("name -> " + jedis.get("name")); jedis.append("name", " , javaer"); // 拼接 System.out.println("name -> " + jedis.get("name")); jedis.del("name"); // 删除数据 System.out.println("name -> " + jedis.get("name")); jedis.mset("name", "webb", "age", "24"); // 设置多个键值对 jedis.incr("age"); // 进行加1操作 System.out.println("name -> " + jedis.get("name") + ", age -> " + jedis.get("age")); }
列表
@Test
public void testList() {
String key = "java framework";
jedis.lpush(key, "spring");
jedis.lpush(key, "spring mvc");
jedis.lpush(key, "mybatis");
System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
jedis.del(key);
jedis.rpush(key, "spring");
jedis.rpush(key, "spring mvc");
jedis.rpush(key, "mybatis");
System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
System.out.println(jedis.llen(key)); // 列表长度
System.out.println(jedis.lrange(key, 0, 3));
jedis.lset(key, 0 , "redis"); // 修改列表中单个值
System.out.println(jedis.lindex(key, 1)); // 获取列表指定下标的值
System.out.println(jedis.lpop(key)); // 列表出栈
System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
}
散列
@Test
public void testMap() {
String key = "user";
Map<String, String> map = new HashMap<>();
map.put("name", "webb");
map.put("age", "24");
map.put("city", "hangzhou");
jedis.hmset(key, map); // 添加数据
List<String> rsmap = jedis.hmget(key, "name", "age", "city"); // 第一个参数存入的是redis中map对象的key,后面跟的是放入map中的对象的key
System.out.println(rsmap);
jedis.hdel(key, "age"); // 删除map中的某个键值
System.out.println(jedis.hmget(key, "age"));
System.out.println(jedis.hlen(key)); // 返回key为user的键中存放的值的个数
System.out.println(jedis.exists(key)); // 是否存在key为user的记录
System.out.println(jedis.hkeys(key)); // 返回map对象中的所有key
System.out.println(jedis.hvals(key)); // 返回map对象中所有的value
Iterator<String> iterator = jedis.hkeys("user").iterator();
while (iterator.hasNext()) {
String key2 = iterator.next();
System.out.print(key2 + " : " + jedis.hmget("user", key2) + "\n");
}
}
集合
@Test
public void testSet() {
String key = "userSet";
String key2 = "userSet2";
jedis.sadd(key, "webb");
jedis.sadd(key, "webb");
jedis.sadd(key, "lebo");
jedis.sadd(key, "lebo0425");
jedis.sadd(key, "who");
jedis.srem(key, "who"); // 删除
System.out.println(jedis.smembers(key)); // 获取所有加入的value
System.out.println(jedis.sismember(key, "who")); // 判断value是否在集合中
System.out.println(jedis.srandmember(key)); // 随机返回一个value
System.out.println(jedis.scard(key)); // 返回集合的元素个数
jedis.sadd(key2, "webb");
jedis.sadd(key2, "ssq");
System.out.println(jedis.sinter(key, key2)); // 交集
System.out.println(jedis.sunion(key, key2)); // 并集
System.out.println(jedis.sdiff(key, key2)); // 差集
}
有序集合
@Test
public void testSortedSet() {
String key = "sortedSet";
jedis.zadd(key, 1999, "one");
jedis.zadd(key, 1994, "two");
jedis.zadd(key, 1998, "three");
jedis.zadd(key, 2000, "four");
jedis.zadd(key, 2017, "five");
Set<String> setValues = jedis.zrange(key, 0 , -1); // score从小到大
System.out.println(setValues);
Set<String> setValues2 = jedis.zrevrange(key, 0, -1); // score从大到小
System.out.println(setValues2);
System.out.println(jedis.zcard(key)); // 元素个数
System.out.println(jedis.zscore(key, "three")); // 元素下标
System.out.println(jedis.zrange(key, 0, -1)); // 集合子集
System.out.println(jedis.zrem(key, "five")); // 删除元素
System.out.println(jedis.zcount(key, 1000, 2000)); // score在1000-2000内的元素个数
}
相关文章推荐
- Java使用AES加密和解密的实例详解
- JAVA 使用哈希表操作数据库的例子 Using Hashtables to Store & Extract results from a Database.
- 如何使用Java编写NT服务
- JML起步---使用JML 改进你的Java程序(4)
- 我学习使用java的一点体会
- 使用JavaServer Pages2.0开发Web应用
- 使用java.io.*操作文件的拆分与合并,Application一例!
- JML起步---使用JML 改进你的Java程序(1)
- JML起步---使用JML 改进你的Java程序(3)
- VisualAge for Java使用技巧
- Java Q&A: 使用Factory Method模式
- 使用JAVA建立稳定的多线程服务器
- 在xmlspy中使用java的xslt转换
- Java Q&A: 使用Singleton模式?给我一个理由先!
- 使用Java实现数据报通讯过程
- 企业内部网中使用Policy文件来设置Java的安全策略
- Java Q&A: 使用Observer模式
- Java的秘密:使用全屏幕模式
- 我学习使用java的一点体会(2)
- 我学习使用java的一点体会(4)