Java 之 Jedis

1、客戶端 Jedis

　　一、Jedis

　　　　Jedis 是一款java操做 redis 數據庫的工具。

　　二、使用步驟

　　　　（1）下載 Jedis 的 jar 包

　　　　（2）使用：

1  //1. 獲取鏈接
2 Jedis jedis = new Jedis("localhost",6379); // 可使用空參構造，默認值"localhost",6379端口 3 
4 //2. 操做
5  jedis.set("username","zhangsan"); 6 
7 //3. 關閉鏈接
8  jedis.close();

 

2、Jedis 操做各類 redis 中的數據結構

　　一、操做字符串類型 String

　　　　使用的方法同 redis 裏面的方法。

　　　　Demo：

 1         //1. 獲取鏈接
 2         Jedis jedis = new Jedis(); 3         //2. 操做  4         //存儲
 5         jedis.set("username","zhangsan");  6         //獲取
 7         String username = jedis.get("username");  8  System.out.println(username);  9 
10         //可使用setex()方法存儲能夠指定過時時間的 key value
11         jedis.setex("activecode",20,"asdf");//將activecode：asdf鍵值對存入redis，而且20秒後自動刪除該鍵值對 12 
13         //3. 關閉鏈接
14         jedis.close();

 

　　二、操做哈希類型 hash:map格式

　　　　使用的方法：hset、hget、hgetall

　　　　Demo：

 1 　　　　//1. 獲取鏈接
 2         Jedis jedis = new Jedis(); 3         //2. 操做  4         // 存儲hash
 5         jedis.hset("user","name","lisi");  6         jedis.hset("user","age","23");  7         jedis.hset("user","sex","man");  8 
 9         // 獲取hash
10         String name = jedis.hget("user", "name"); 11  System.out.println(name); 12 
13 
14         // 獲取hash的全部map中的數據
15         Map<String, String> user = jedis.hgetAll("user"); 16 
17         // keyset
18         Set<String> keySet = user.keySet(); 19         for (String key : keySet) { 20             //獲取value
21             String value = user.get(key); 22             System.out.println(key + ":" + value); 23  } 24 
25         //3. 關閉鏈接
26         jedis.close();

 

　　三、操做列表類型 list：linkedlist 格式。支持重複元素。

　　　　經常使用方法：lpush、lpush、lpop、rpop、lrange start end。

　　　　Demo：

 1 　　　　　//1. 獲取鏈接
 2         Jedis jedis = new Jedis(); 3         //2. 操做  4         // list 存儲
 5         jedis.lpush("mylist","a","b","c");//從左邊存
 6         jedis.rpush("mylist","a","b","c");//從右邊存  7 
 8         // list 範圍獲取
 9         List<String> mylist = jedis.lrange("mylist", 0, -1); 10  System.out.println(mylist); 11         
12         // list 彈出
13         String element1 = jedis.lpop("mylist");//c
14  System.out.println(element1); 15 
16         String element2 = jedis.rpop("mylist");//c
17  System.out.println(element2); 18 
19         // list 範圍獲取
20         List<String> mylist2 = jedis.lrange("mylist", 0, -1); 21  System.out.println(mylist2); 22 
23         //3. 關閉鏈接
24         jedis.close();

 

　　四、操做集合類型 set：不容許重複元素

　　　　經常使用方法：sadd、smembers。

　　　　Demo：

 1 　　　　　//1. 獲取鏈接
 2         Jedis jedis = new Jedis();  3 
 4         //2. 操做  5         // set 存儲
 6         jedis.sadd("myset","java","php","c++");  7 
 8         // set 獲取
 9         Set<String> myset = jedis.smembers("myset"); 10  System.out.println(myset); 11 
12         //3. 關閉鏈接
13         jedis.close();

 

　　五、操做有序集合類型 sortedset：不容許重複元素，且元素有序。

　　　　經常使用方法：zadd、zrange。

　　　Demo：

 1 　　　　 //1. 獲取鏈接
 2         Jedis jedis = new Jedis();  3         //2. 操做  4         // sortedset 存儲
 5         jedis.zadd("mysortedset",3,"亞瑟");  6         jedis.zadd("mysortedset",30,"後裔");  7         jedis.zadd("mysortedset",55,"孫悟空");  8 
 9         // sortedset 獲取
10         Set<String> mysortedset = jedis.zrange("mysortedset", 0, -1); 11 
12  System.out.println(mysortedset); 13 
14 
15         //3. 關閉鏈接
16         jedis.close();

 

3、Jedis 鏈接池：JedisPool

　　一、使用步驟

　　　　（1）建立一個配置對象

　　　　（2）建立一個 JedisPool 鏈接池對象

　　　　（3）調用方法 getResource() 方法獲取 Jedis 鏈接

　　　　（4）使用鏈接

　　　　（5）關閉鏈接，把鏈接歸還到鏈接池中

　　二、代碼實現

　　　代碼實現：

 1         //1.建立一個配置對象
 2         JedisPoolConfig config = new JedisPoolConfig();  3         config.setMaxTotal(50); // 設置最大鏈接數
 4         config.setMaxIdle(10);  // 設置最大空閒數  5 
 6         //2.建立Jedis鏈接池對象
 7         JedisPool jedisPool = new JedisPool(config,"localhost",6379);  8 
 9         //3.獲取鏈接
10         Jedis jedis = jedisPool.getResource(); 11         //4. 使用
12         jedis.set("hehe","heihei"); 13 
14 
15         //5. 關閉 歸還到鏈接池中
16         jedis.close();;

 

4、鏈接池工具類

　　在上面的代碼中，將一些配置信息放入了代碼中，可是這樣並不有利於配置信息的修改，能夠將配置信息單獨放入一個文件中，而後讀取該文件的內容便可。

　　jedis 詳細配置說明：

 1 #最大活動對象數  2 redis.pool.maxTotal=1000  3 #最大可以保持idel狀態的對象數  4 redis.pool.maxIdle=100  5 #最小可以保持idel狀態的對象數  6 redis.pool.minIdle=50  7 #當池內沒有返回對象時，最大等待時間  8 redis.pool.maxWaitMillis=10000  9 #當調用borrow Object方法時，是否進行有效性檢查 10 redis.pool.testOnBorrow=true 11 #當調用return Object方法時，是否進行有效性檢查 12 redis.pool.testOnReturn=true 13 #「空閒連接」檢測線程，檢測的週期，毫秒數。若是爲負值，表示不運行「檢測線程」。默認爲-1. 14 redis.pool.timeBetweenEvictionRunsMillis=30000 15 #向調用者輸出「連接」對象時，是否檢測它的空閒超時； 16 redis.pool.testWhileIdle=true 17 # 對於「空閒連接」檢測線程而言，每次檢測的連接資源的個數。默認爲3. 18 redis.pool.numTestsPerEvictionRun=50 19 #redis服務器的IP 20 redis.ip=xxxxxx 21 #redis服務器的Port 22 redis1.port=6379   

 

　　jedis.properties 文件

1 host=127.0.0.1
2 port=6379
3 maxTotal=50
4 maxIdle=10

 

　　jedis 鏈接池工具類

 1 import redis.clients.jedis.Jedis;  2 import redis.clients.jedis.JedisPool;  3 import redis.clients.jedis.JedisPoolConfig;  4 
 5 import java.io.IOException;  6 import java.io.InputStream;  7 import java.util.Properties;  8 
 9 /**
10  JedisPool工具類 11  加載配置文件，配置鏈接池的參數 12  提供獲取鏈接的方法 13 
14  */
15 public class JedisPoolUtils { 16 
17     private static JedisPool jedisPool; 18 
19     static{ 20         //讀取配置文件
21         InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties"); 22         //建立Properties對象
23         Properties pro = new Properties(); 24         //關聯文件
25         try { 26  pro.load(is); 27         } catch (IOException e) { 28  e.printStackTrace(); 29  } 30         //獲取數據，設置到JedisPoolConfig中
31         JedisPoolConfig config = new JedisPoolConfig(); 32         config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal"))); 33         config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle"))); 34 
35         //初始化JedisPool
36         jedisPool = new JedisPool(config,pro.getProperty("host"),Integer.parseInt(pro.getProperty("port"))); 37 
38 
39  } 40 
41 
42     /**
43  * 獲取鏈接方法 44      */
45     public static Jedis getJedis(){ 46         return jedisPool.getResource(); 47  } 48 }