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 }