Java使用Redis學習筆記
阿新 • • 發佈：2018-02-28
users 添加 進行 ember ali redis服務器 [] 排序 ktr
如果我們使用Java操作Redis， 需要確保已經安裝了 redis 服務及 Java redis 驅動。
Maven項目可以直接在pom.xml中加入jedis包驅動:
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
Jedis中操作String，List，Set，Map，以及集合排序
package com.ww.exercise; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import org.junit.Before; import org.junit.Test; import redis.clients.jedis.Jedis; /** * 練習redis對接java * @author 旺旺 */ public class RedisExercise {private static Jedis jedis; /*public static void setJedis() { //連接到本地redis服務器 jedis = new Jedis("127.0.0.1",6379); //驗證用戶密碼 jedis.auth("zww"); System.out.println("登入Redis數據庫"); }*/ public static void main(String[] args) { jedis = new Jedis("127.0.0.1",6379); //驗證用戶密碼 jedis.auth("zww"); System.out.println("登入Redis數據庫"); exerciseString(); exerciseHash(); exerciseList(); exerciseSet(); exerciseSSet(); } /** * 聯系String類型的操作 */ public static void exerciseString() { //setJedis(); //添加數據 jedis.set("name", "zww");//如果已存在，覆蓋 System.out.println("新增." + jedis.get("name")); //拼接數據 jedis.append("nane", " is my name"); System.out.println("拼接." + jedis.get("name")); //刪除數據 jedis.del("name"); System.out.println("刪除." + jedis.get("name")); //批量新增數據 jedis.mset("name","zww","age","20","email","www.ww.cn"); jedis.decr("age");//Redis Decr 命令將 key 中儲存的數字值減一。 //如果 key 不存在，那麽 key 的值會先被初始化為 0 ，然後再執行 DECR 操作。 //如果值包含錯誤的類型，或字符串類型的值不能表示為數字，那麽返回一個錯誤。 //本操作的值限制在 64 位(bit)有符號數字表示之內。 System.out.println("批量." + jedis.get("name")+ jedis.get("age")+ jedis.get("email")); } /** * 聯系Hash類型的操作 */ @Test public static void exerciseHash() { //添加數據 Map<String, String> user = new HashMap<String, String>(); user.put("name", "zww"); user.put("age", "20"); user.put("email", "www.ww"); jedis.hmset("user", user); //取出user中的name，結果是一個泛型的List<String> //第一個參數是存入redis中map對象的key，後面跟的是放入map中的對象的key，後面的key是可變參數 List<String> users = jedis.hmget("user", "name","age","email"); System.out.println("新增." + users); //拼接數據 jedis.hset("user", "hobby", "guitar"); System.out.println("拼接." + jedis.hmget("user", "name","age","email","hobby")); //拿到hash中所有key，再通過叠代器得到值 Iterator<String> userKey = jedis.hkeys("user").iterator(); while (userKey.hasNext()) { String key = userKey.next(); System.out.println(key + ":" + jedis.hget("user", key)); } //部分刪除數據 jedis.hdel("user", "email"); System.out.println("刪除." + jedis.hmget("user", "name","age","email","hobby")); System.out.println("age:" + jedis.hmget("user", "age")); //因為刪除了，所以返回的是null System.out.println("user的鍵中存放的值的個數:" + jedis.hlen("user")); //返回key為user的鍵中存放的值的個數 System.out.println("是否存在key為user的記錄:" + jedis.exists("user"));//是否存在key為user的記錄 返回true System.out.println("user對象中的所有key:" + jedis.hkeys("user"));//返回user對象中的所有key System.out.println("user對象中的所有value:" + jedis.hvals("user"));//返回map對象中的所有value //刪除整個hash jedis.del("user"); System.out.println("刪除後是否存在key為user的記錄:" + jedis.exists("user"));//是否存在key為user的記錄 } /** * 聯系List類型的操作 */ @Test public static void exerciseList() { //添加數據 jedis.lpush("framework", "spring"); jedis.lpush("framework", "spring");//可以相同？ jedis.lpush("framework", "mybatis"); jedis.lpush("framework", "struts2"); List<String> framework = jedis.lrange("framework", 0, -1);//結果是一個泛型的List<String> System.out.println("新增." + framework); //部分刪除數據 String pop = jedis.lpop("framework");//移除最左邊的數據 System.out.println("移除." + pop); System.out.println("移除後." + jedis.lrange("framework", 0, -1)); } /** * 聯系Set類型的操作 */ @Test public static void exerciseSet() { //添加數據 jedis.sadd("database", "redis"); jedis.sadd("database", "oracle"); jedis.sadd("database", "mysql"); jedis.sadd("databas", "redis");//可以相同？ Set<String> database = jedis.smembers("database");//結果是一個泛型的Set<String> System.out.println("新增."+database); //刪除 jedis.srem("database","oracle");//移除成員 System.out.println("user中的value:"+jedis.smembers("database"));//獲取所有加入user的value System.out.println("chx是否是user中的元素:"+jedis.sismember("database","redis"));//判斷chx是否是user集合中的元素 System.out.println("集合中的一個隨機元素:"+jedis.srandmember("database"));//返回集合中的一個隨機元素 System.out.println("user中元素的個數:"+jedis.scard("database")); //再來個 jedis.sadd("database1", "redis"); jedis.sadd("database1", "db2"); jedis.sadd("database1", "mysql"); System.out.println("獲取兩個數據庫的交集:"+jedis.sinter("database","database1")); System.out.println("獲取兩個數據庫的並集:"+jedis.sunion("database","database1")); } /** * 聯系SSet類型的操作 */ @Test public static void exerciseSSet() { //添加數據 jedis.zadd("bat", 1,"baidu"); jedis.zadd("bat", 2,"ali"); jedis.zadd("bat", 3,"tengx"); jedis.zadd("bat", 3,"zww");//覆蓋 Set<String> database = jedis.zrange("bat", 0, -1);//結果是一個泛型的Set<String> System.out.println("所有成員:"+database); //刪除成員 //jedis.zrem("bat", "zww"); jedis.zremrangeByScore("bat", 3, 3);//通過序號刪除指定成員 System.out.println("所有成員:"+database); } /** * 聯系 類型的操作 */ @Test public void exercise() { } }
Redis連接池
package com.ww.exercise; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public final class RedisPool { private static String ADDR = "127.0.0.1"; //服務器IP地址 private static int PORT = 6379; //服務器端口 private static String PASSW = "zww"; //redis服務器密碼 //可用連接實例的最大數目，默認為8； //如果賦值為-1，則表示不限制，如果pool已經分配了maxActive個jedis實例，則此時pool的狀態為exhausted(耗盡) private static Integer MAX_TOTAL = 1024; //控制一個pool最多有多少個狀態為idle(空閑)的jedis實例，默認值是8 private static Integer MAX_IDLE = 200; //等待可用連接的最大時間，單位是毫秒，默認值為-1，表示永不超時。 //如果超過等待時間，則直接拋出JedisConnectionException private static Integer MAX_WAIT_MILLIS = 10000; private static Integer TIMEOUT = 10000; //在borrow(用)一個jedis實例時，是否提前進行validate(驗證)操作； //如果為true，則得到的jedis實例均是可用的 private static Boolean TEST_ON_BORROW = true; private static JedisPool jedisPool = null; /** * 靜態塊，初始化Redis連接池 */ static { try { JedisPoolConfig conf = new JedisPoolConfig(); /*註意： 在高版本的jedis jar包，比如本版本2.9.0，JedisPoolConfig沒有setMaxActive和setMaxWait屬性了 這是因為高版本中官方廢棄了此方法，用以下兩個屬性替換。 maxActive ==> maxTotal maxWait==> maxWaitMillis */ conf.setMaxTotal(MAX_TOTAL); conf.setMaxIdle(MAX_IDLE); conf.setMaxWaitMillis(MAX_WAIT_MILLIS); conf.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(conf,ADDR,PORT,TIMEOUT,PASSW); } catch (Exception e) { e.printStackTrace(); } } /** * 獲取Jedis實例 * @return */ public synchronized static Jedis getRedis() { try { if(jedisPool != null) { //從線程池獲取 Jedis jedis = jedisPool.getResource(); } else { System.out.println("沒有找到jedis池"); return null; } } catch (Exception e) { e.printStackTrace(); return null; } return null; } }
看代碼，寫代碼。
Java使用Redis學習筆記