詳談Jedis連接池的使用
1、構(gòu)建redis連接池,返還到連接池
private static JedisPool jedisPool = null; private static Jedis jedis; static { jedis = getJedisPool().getResource(); } /** * 構(gòu)建redis連接池 */ public static JedisPool getJedisPool() { if (jedisPool == null) { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(1024); // 可用連接實(shí)例的最大數(shù)目,如果賦值為-1,表示不限制. config.setMaxIdle(5); // 控制一個(gè)Pool最多有多少個(gè)狀態(tài)為idle(空閑的)jedis實(shí)例,默認(rèn)值也是8 config.setMaxWaitMillis(1000 * 100); // 等待可用連接的最大時(shí)間,單位毫秒,默認(rèn)值為-1,表示永不超時(shí)/如果超過等待時(shí)間,則直接拋出異常 config.setTestOnBorrow(true); // 在borrow一個(gè)jedis實(shí)例時(shí),是否提前進(jìn)行validate操作,如果為true,則得到的jedis實(shí)例均是可用的 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; }
這種寫法會(huì)經(jīng)常忘記返回jedis到pool.參考Spting JdbcTemplate的實(shí)現(xiàn)方式,優(yōu)化如下
優(yōu)化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"); // 添加數(shù)據(jù) System.out.println("name -> " + jedis.get("name")); jedis.append("name", " , javaer"); // 拼接 System.out.println("name -> " + jedis.get("name")); jedis.del("name"); // 刪除數(shù)據(jù) System.out.println("name -> " + jedis.get("name")); jedis.mset("name", "webb", "age", "24"); // 設(shè)置多個(gè)鍵值對(duì) jedis.incr("age"); // 進(jìn)行加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)); // 列表長(zhǎng)度 System.out.println(jedis.lrange(key, 0, 3)); jedis.lset(key, 0 , "redis"); // 修改列表中單個(gè)值 System.out.println(jedis.lindex(key, 1)); // 獲取列表指定下標(biāo)的值 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); // 添加數(shù)據(jù) List<String> rsmap = jedis.hmget(key, "name", "age", "city"); // 第一個(gè)參數(shù)存入的是redis中map對(duì)象的key,后面跟的是放入map中的對(duì)象的key System.out.println(rsmap); jedis.hdel(key, "age"); // 刪除map中的某個(gè)鍵值 System.out.println(jedis.hmget(key, "age")); System.out.println(jedis.hlen(key)); // 返回key為user的鍵中存放的值的個(gè)數(shù) System.out.println(jedis.exists(key)); // 是否存在key為user的記錄 System.out.println(jedis.hkeys(key)); // 返回map對(duì)象中的所有key System.out.println(jedis.hvals(key)); // 返回map對(duì)象中所有的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)); // 隨機(jī)返回一個(gè)value System.out.println(jedis.scard(key)); // 返回集合的元素個(gè)數(shù) 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)); // 元素個(gè)數(shù) System.out.println(jedis.zscore(key, "three")); // 元素下標(biāo) 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內(nèi)的元素個(gè)數(shù) }
以上這篇詳談Jedis連接池的使用就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
一文詳解SpringBoot中CommandLineRunner接口
Spring Boot的CommandLineRunner接口是一個(gè)函數(shù)式接口,用于在Spring Boot應(yīng)用程序啟動(dòng)后執(zhí)行一些初始化操作,它提供了一個(gè)run方法,該方法在應(yīng)用程序啟動(dòng)后被調(diào)用,本文給大家詳細(xì)介紹了SpringBoot中CommandLineRunner接口,需要的朋友可以參考下2023-10-10SpringCloud 2020-Ribbon負(fù)載均衡服務(wù)調(diào)用的實(shí)現(xiàn)
這篇文章主要介紹了SpringCloud 2020-Ribbon負(fù)載均衡服務(wù)調(diào)用的實(shí)現(xiàn),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-03-03springboot整合springsecurity與mybatis-plus的簡(jiǎn)單實(shí)現(xiàn)
Spring Security基于Spring開發(fā),項(xiàng)目中如果使用Spring作為基礎(chǔ),配合Spring Security做權(quán)限更加方便,而Shiro需要和Spring進(jìn)行整合開發(fā)。因此作為spring全家桶中的Spring Security在java領(lǐng)域很常用2021-10-10Java 反射機(jī)制知識(shí)詳細(xì)介紹及總結(jié)
反射機(jī)制是在運(yùn)行狀態(tài)中,對(duì)于任意一個(gè)類,都能夠知道這個(gè)類的所有屬性和方法;對(duì)于任意一個(gè)對(duì)象,都能夠調(diào)用它的任意一個(gè)方法和屬性;這種動(dòng)態(tài)獲取的信息以及動(dòng)態(tài)調(diào)用對(duì)象的方法的功能稱為java語言的反射機(jī)制2017-01-01IDEA在一個(gè)工作空間中管理多個(gè)項(xiàng)目的詳細(xì)步驟
這篇文章主要介紹了IDEA在一個(gè)工作空間中管理多個(gè)項(xiàng)目的詳細(xì)步驟,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-01-01詳解Java如何優(yōu)雅的實(shí)現(xiàn)字典翻譯
當(dāng)我們?cè)贘ava應(yīng)用程序中需要對(duì)字典屬性進(jìn)行轉(zhuǎn)換返回給前端時(shí),如何簡(jiǎn)單、方便、并且優(yōu)雅的處理是一個(gè)重要問題。在本文中,我們將介紹如何使用Java中的序列化機(jī)制來優(yōu)雅地實(shí)現(xiàn)字典值的翻譯,從而簡(jiǎn)化開發(fā)2023-04-04