一個 key ,五大數據類型
package test;import java.util.HashMap;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Set;import redis.clients.jedis.Jedis;public class TestAPI { public static void main(String[] args) { Jedis jedis = new Jedis("127.0.0.1", 6379); //key Set<String> sets = jedis.keys("*"); for(Iterator iterator = sets.iterator();iterator.hasNext();){ String key = (String) iterator.next(); System.out.println(key); } System.out.println("jedis.exists====>"+jedis.exists("k2")); System.out.println(jedis.ttl("k1")); //String System.out.println(jedis.get("k1")); jedis.set("k4", "v4"); System.out.println("----------------------------------"); jedis.mset("str1","v1","str2","v2","str3","v3"); System.out.println(jedis.mget("str1","str2","str3")); //list System.out.println("----------------------------------"); jedis.lpush("mylist", "v1","v2","v3","v4","v5"); List<String> list = jedis.lrange("mylist", 0, -1); for(String element:list){ System.out.println(element); } //set System.out.println("----------------------------------"); jedis.sadd("orders", "jd001"); jedis.sadd("orders", "jd002"); jedis.sadd("orders", "jd003"); Set<String> set1 = jedis.smembers("orders"); for(Iterator iterator = set1.iterator();iterator.hasNext();){ String string = (String) iterator.next(); System.out.println(string); } jedis.srem("orders", "jd002"); System.out.println(jedis.smembers("orders").size()); //hash System.out.println("----------------------------------"); jedis.hset("hash1", "userName", "lisi"); System.out.println(jedis.hget("hash1", "userName")); Map<String, String> map = new HashMap<String, String>(); map.put("telphone", "13811814763"); map.put("address", "atguigu"); map.put("email", "abc@163.com"); jedis.hmset("hash2", map); List<String> result =jedis.hmget("hash2", "telphone","email"); for(String element : result){ System.out.println(element); } //zset System.out.println("----------------------------------"); jedis.zadd("zset01", 60d,"v1"); jedis.zadd("zset01", 70d,"v2"); jedis.zadd("zset01", 80d,"v3"); jedis.zadd("zset01", 90d,"v4"); Set<String> s1 = jedis.zrange("zset01", 0, -1); for(Iterator iterator = s1.iterator();iterator.hasNext();){ String string = (String) iterator.next(); System.out.println(string); } }}JedisPoolUtil.java
package test;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;public class JedisPoolUtil { private static volatile JedisPool jedisPool = null; private JedisPoolUtil(){} public static JedisPool getJedisPoolInstance(){ if(null == jedisPool){ synchronized (JedisPoolUtil.class) { if(null == jedisPool){ JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxTotal(1000); poolConfig.setMaxIdle(32); poolConfig.setMaxWaitMillis(100*1000); poolConfig.setTestOnBorrow(true); jedisPool = new JedisPool(poolConfig,"127.0.0.1",6379); } } } return jedisPool; } public static void release(JedisPool jedisPool,Jedis jedis){ if(null != jedis){ jedisPool.returnResourceObject(jedis); } }}TestPool.java
package test;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;public class TestPool { public static void main(String[] args) { JedisPool jedisPool = JedisPoolUtil.getJedisPoolInstance(); Jedis jedis = null; try { jedis = jedisPool.getResource(); jedis.set("aa", "bb"); } catch (Exception e) { e.printStackTrace(); }finally{ JedisPoolUtil.release(jedisPool, jedis); } }}JedisPool的配置參數大部分是由JedisPoolConfig的對應項來賦值的。
maxActive:控制一個pool可分配多少個jedis實例,通過pool.getResource()來獲??;如果賦值為-1,則表示不限制;如果pool已經分配了maxActive個jedis實例,則此時pool的狀態為exhausted。maxIdle:控制一個pool最多有多少個狀態為idle(空閑)的jedis實例;whenExhaustedAction:表示當pool中的jedis實例都被allocated完時,pool要采取的操作;默認有三種。 WHEN_EXHAUSTED_FAIL –> 表示無jedis實例時,直接拋出NoSuchElementException;WHEN_EXHAUSTED_BLOCK –> 則表示阻塞住,或者達到maxWait時拋出JedisConnectionException;WHEN_EXHAUSTED_GROW –> 則表示新建一個jedis實例,也就說設置的maxActive無用;maxWait:表示當borrow一個jedis實例時,最大的等待時間,如果超過等待時間,則直接拋JedisConnectionException;testOnBorrow:獲得一個jedis實例的時候是否檢查連接可用性(ping());如果為true,則得到的jedis實例均是可用的;testOnReturn:return 一個jedis實例給pool時,是否檢查連接可用性(ping());testWhileIdle:如果為true,表示有一個idle object evitor線程對idle object進行掃描,如果validate失敗,此object會被從pool中drop掉;這一項只有在timeBetweenEvictionRunsMillis大于0時才有意義;timeBetweenEvictionRunsMillis:表示idle object evitor兩次掃描之間要sleep的毫秒數;numTestsPerEvictionRun:表示idle object evitor每次掃描的最多的對象數;minEvictableIdleTimeMillis:表示一個對象至少停留在idle狀態的最短時間,然后才能被idle object evitor掃描并驅逐;這一項只有在timeBetweenEvictionRunsMillis大于0時才有意義;softMinEvictableIdleTimeMillis:在minEvictableIdleTimeMillis基礎上,加入了至少minIdle個對象已經在pool里面了。如果為-1,evicted不會根據idle time驅逐任何對象。如果minEvictableIdleTimeMillis>0,則此項設置無意義,且只有在timeBetweenEvictionRunsMillis大于0時才有意義;lifo:borrowObject返回對象時,是采用DEFAULT_LIFO(last in first out,即類似cache的最頻繁使用隊列),如果為False,則表示FIFO隊列;/================================================================================================================== 其中JedisPoolConfig對一些參數的默認設置如下:
testWhileIdle=trueminEvictableIdleTimeMills=60000timeBetweenEvictionRunsMillis=30000numTestsPerEvictionRun=-1新聞熱點
疑難解答