Redis】Java中使用Jedis操作Redis(Maven導入包)、創建Redis連接池
阿新 • • 發佈：2019-02-25
之前 maven項目 lse 位置 springmvc 替換 () value boolean
如果我們使用Java操作Redis， 需要確保已經安裝了 redis 服務及 Java redis 驅動。
Maven項目可以直接在pom.xml中加入jedis包驅動:
<!-- https://mvnrepository.com/artifact/redis.clients/jedis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId><version>2.9.0</version> </dependency>
Jedis中操作String，List，Set，Map，以及集合排序
package cn.hncu; import org.junit.Before; import org.junit.Test; import redis.clients.jedis.Jedis; import java.util.HashMap; import java.util.Iterator; import java.util.List;import java.util.Map; /** * Created with IntelliJ IDEA. * Explain:Java操作Redis測試 */ public class TestRedis { private Jedis jedis; @Before public void setJedis() { //連接redis服務器(在這裏是連接本地的) jedis = new Jedis("127.0.0.1", 6379); //權限認證 jedis.auth("chenhaoxiang"); System.out.println("連接服務成功"); } /** * Redis操作字符串 */ @Test public void testString() { //添加數據 jedis.set("name", "chx"); //key為name放入value值為chx System.out.println("拼接前:" + jedis.get("name"));//讀取key為name的值 //向key為name的值後面加上數據 ---拼接 jedis.append("name", " is my name;"); System.out.println("拼接後:" + jedis.get("name")); //刪除某個鍵值對 jedis.del("name"); System.out.println("刪除後:" + jedis.get("name")); //s設置多個鍵值對 jedis.mset("name", "chenhaoxiang", "age", "20", "email", "[email protected]"); jedis.incr("age");//用於將鍵的整數值遞增1。如果鍵不存在，則在執行操作之前將其設置為0。 如果鍵包含錯誤類型的值或包含無法表示為整數的字符串，則會返回錯誤。此操作限於64位有符號整數。 System.out.println(jedis.get("name") + " " + jedis.get("age") + " " + jedis.get("email")); } @Test public void testMap() { //添加數據 Map<String, String> map = new HashMap<String, String>(); map.put("name", "chx"); map.put("age", "100"); map.put("email", "***@outlook.com"); jedis.hmset("user", map); //取出user中的name，結果是一個泛型的List //第一個參數是存入redis中map對象的key，後面跟的是放入map中的對象的key，後面的key是可變參數 List<String> list = jedis.hmget("user", "name", "age", "email"); System.out.println(list); //刪除map中的某個鍵值 jedis.hdel("user", "age"); System.out.println("age:" + jedis.hmget("user", "age")); //因為刪除了，所以返回的是null System.out.println("user的鍵中存放的值的個數:" + jedis.hlen("user")); //返回key為user的鍵中存放的值的個數2 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 //拿到key，再通過叠代器得到值 Iterator<String> iterator = jedis.hkeys("user").iterator(); while (iterator.hasNext()) { String key = iterator.next(); System.out.println(key + ":" + jedis.hmget("user", key)); } jedis.del("user"); System.out.println("刪除後是否存在key為user的記錄:" + jedis.exists("user"));//是否存在key為user的記錄 } /** * jedis操作List */ @Test public void testList(){ //移除javaFramwork所所有內容 jedis.del("javaFramwork"); //存放數據 jedis.lpush("javaFramework","spring"); jedis.lpush("javaFramework","springMVC"); jedis.lpush("javaFramework","mybatis"); //取出所有數據,jedis.lrange是按範圍取出 //第一個是key，第二個是起始位置，第三個是結束位置 System.out.println("長度:"+jedis.llen("javaFramework")); //jedis.llen獲取長度，-1表示取得所有 System.out.println("javaFramework:"+jedis.lrange("javaFramework",0,-1)); jedis.del("javaFramework"); System.out.println("刪除後長度:"+jedis.llen("javaFramework")); System.out.println(jedis.lrange("javaFramework",0,-1)); } /** * jedis操作Set */ @Test public void testSet(){ //添加 jedis.sadd("user","chenhaoxiang"); jedis.sadd("user","hu"); jedis.sadd("user","chen"); jedis.sadd("user","xiyu"); jedis.sadd("user","chx"); jedis.sadd("user","are"); //移除user集合中的元素are jedis.srem("user","are"); System.out.println("user中的value:"+jedis.smembers("user"));//獲取所有加入user的value System.out.println("chx是否是user中的元素:"+jedis.sismember("user","chx"));//判斷chx是否是user集合中的元素 System.out.println("集合中的一個隨機元素:"+jedis.srandmember("user"));//返回集合中的一個隨機元素 System.out.println("user中元素的個數:"+jedis.scard("user")); } /** * 排序 */ @Test public void test(){ jedis.del("number");//先刪除數據，再進行測試 jedis.rpush("number","4");//將一個或多個值插入到列表的尾部(最右邊) jedis.rpush("number","5"); jedis.rpush("number","3"); jedis.lpush("number","9");//將一個或多個值插入到列表頭部 jedis.lpush("number","1"); jedis.lpush("number","2"); System.out.println(jedis.lrange("number",0,jedis.llen("number"))); System.out.println("排序:"+jedis.sort("number")); System.out.println(jedis.lrange("number",0,-1));//不改變原來的排序 jedis.del("number");//測試完刪除數據 } }
Redis連接池
package cn.hncu; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; /** * Created with IntelliJ IDEA. * Explain:Redis連接池 */ public final class RedisPool { //Redis服務器IP private static String ADDR = "127.0.0.1"; //Redis的端口號 private static Integer PORT = 6379; //訪問密碼 private static String AUTH = "chenhaoxiang"; //可用連接實例的最大數目，默認為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 config = new JedisPoolConfig(); /*註意： 在高版本的jedis jar包，比如本版本2.9.0，JedisPoolConfig沒有setMaxActive和setMaxWait屬性了 這是因為高版本中官方廢棄了此方法，用以下兩個屬性替換。 maxActive ==> maxTotal maxWait==> maxWaitMillis */ config.setMaxTotal(MAX_TOTAL); config.setMaxIdle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT_MILLIS); config.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT,AUTH); } catch (Exception e) { e.printStackTrace(); } } /** * 獲取Jedis實例 * @return */ public synchronized static Jedis getJedis(){ try { if(jedisPool != null){ Jedis jedis = jedisPool.getResource(); return jedis; }else{ return null; } } catch (Exception e) { e.printStackTrace(); return null; } } public static void returnResource(final Jedis jedis){ //方法參數被聲明為final，表示它是只讀的。 if(jedis!=null){ jedisPool.returnResource(jedis); //jedis.close()取代jedisPool.returnResource(jedis)方法將3.0版本開始 //jedis.close(); } } }
RedisJava測試連接池
package cn.hncu; import redis.clients.jedis.Jedis; /** * Created with IntelliJ IDEA. * Explain:測試RedisPool */ public class RedisJava { public static void main(String[] args) { RedisPool.getJedis().set("name","陳浩翔"); System.out.println(RedisPool.getJedis().get("name")); } }
Redis】Java中使用Jedis操作Redis(Maven導入包)、創建Redis連接池