Java 之 Jedis

扫码查看

一、客户端 Jedis

  1、Jedis

    Jedis 是一款java操作 redis 数据库的工具。

  2、使用步骤

    (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();

二、Jedis 操作各种 redis 中的数据结构

  1、操作字符串类型 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();

  2、操作哈希类型 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();

  3、操作列表类型 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();

  4、操作集合类型 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();

  5、操作有序集合类型 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();

三、Jedis 连接池:JedisPool

  1、使用步骤

    (1)创建一个配置对象

    (2)创建一个 JedisPool 连接池对象

    (3)调用方法 getResource() 方法获取 Jedis 连接

    (4)使用连接

    (5)关闭连接,把连接归还到连接池中

  2、代码实现

   代码实现:

 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();;

四、连接池工具类

  在上面的代码中,将一些配置信息放入了代码中,但是这样并不有利于配置信息的修改,可以将配置信息单独放入一个文件中,然后读取该文件的内容即可。

  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 }
01-15 20:01
查看更多