Redis系列八 使用Jedis

  1 package com.ntjr.redis;
  2 
  3 import java.util.HashMap;
  4 import java.util.Iterator;
  5 import java.util.List;
  6 import java.util.Map;
  7 import java.util.Set;
  8 
  9 import org.junit.Before;
 10 import org.junit.Test;
 11 
 12 import redis.clients.jedis.Jedis;
 13 
 14 public class TestApi {
 15     private Jedis jedis;
 16 
 17     /**
 18      * 连接192.168.15.128:6379 Redis
 19      */
 20     @Before
 21     public void before() {
 22         jedis = new Jedis("192.168.15.128", 6379);
 23     }
 24 
 25     
 26     /**
 27      * 测试set get  及 过期时间，返回-1代表永不过期
 28      */
 29     @Test
 30     public void testSetKey() {
 31         jedis.set("k1", "v1");
 32         jedis.set("k2", "v2");
 33         jedis.set("k3", "v3");
 34         System.out.println(jedis.get("k3"));
 35         System.out.println(jedis.ttl("k1"));
 36     }
 37 
 38     
 39     /**
 40      * 获取所有的key
 41      */
 42     @Test
 43     public void testGet() {
 44         Set<String> keys = jedis.keys("*");
 45         for (Iterator<String> iterator = keys.iterator(); iterator.hasNext();) {
 46             String key = (String) iterator.next();
 47             System.out.println(key);
 48         }
 49     }
 50 
 51     /**
 52      * 是否存在k2
 53      */
 54     @Test
 55     public void testExists() {
 56         System.out.println(jedis.exists("k2"));
 57     }
 58 
 59     /**
 60      * string 追加
 61      */
 62     @Test
 63     public void testAppend() {
 64         jedis.append("k1", "myredis");
 65         System.out.println(jedis.get("k1"));
 66     }
 67 
 68     /**
 69      * 设置多个键值对
 70      */
 71     @Test
 72     public void testMSET() {
 73         jedis.mset("str1", "v1", "str2", "v2", "str3", "v3");
 74         System.out.println(jedis.mget("str1", "str2", "str3"));
 75     }
 76 
 77     /**
 78      * 测试为list设置值，获取list集合
 79      */
 80     @Test
 81     public void testLPUSH() {
 82         jedis.lpush("mylist", "v1", "v2", "v3", "v4", "v5");
 83         List<String> myList = jedis.lrange("mylist", 0, -1);
 84         for (String element : myList) {
 85             System.out.println(element);
 86         }
 87     }
 88 
 89     /**
 90      * Set集合的添加、遍历、删除
 91      */
 92     @Test
 93     public void testSet() {
 94         jedis.sadd("orders", "jd001");
 95         jedis.sadd("orders", "jd002");
 96         jedis.sadd("orders", "jd003");
 97         Set<String> orders = jedis.smembers("orders");
 98         for (Iterator<String> iterator = orders.iterator(); iterator.hasNext();) {
 99             System.out.println(iterator.next());
100         }
101         jedis.srem("orders", "jd002");
102         System.out.println(jedis.smembers("orders").size());
103     }
104 
105     /**
106      * Map集合操作，获取多个值
107      */
108     @Test
109     public void testHash() {
110         jedis.hset("hash1", "uername", "lisi");
111         System.out.println(jedis.hget("hash1", "uername"));
112         Map<String, String> map = new HashMap<>();
113         map.put("telphone", "13811814763");
114         map.put("address", "atguigu");
115         map.put("email", "abc@163.com");
116         jedis.hmset("hash1", map);
117         List<String> result = jedis.hmget("hash1", "telphone", "email");
118         for (String element : result) {
119             System.out.println(element);
120         }
121     }
122 
123     /**
124      * Zset设置，为每个数据设置 score
125      */
126     @Test
127     public void testZSET() {
128         jedis.zadd("zset01", 60d, "v1");
129         jedis.zadd("zset01", 70d, "v2");
130         jedis.zadd("zset01", 80d, "v3");
131         jedis.zadd("zset01", 90d, "v4");
132         Set<String> zset = jedis.zrange("zset01", 0, -1);
133         for(Iterator<String> iterator = zset.iterator();iterator.hasNext(); ){
134             System.out.println(iterator.next());
135         }
136     }
137 
138 }

 1 package com.ntjr.redis;
 2 
 3 import redis.clients.jedis.Jedis;
 4 import redis.clients.jedis.JedisPool;
 5 import redis.clients.jedis.JedisPoolConfig;
 6 
 7 public class JedisPoolUtils {
 8 
 9     private static volatile JedisPool jedisPool = null;
10 
11     private JedisPoolUtils() {
12     }
13 
14     public static JedisPool getJedisPoolInstance() {
15         synchronized (JedisPoolUtils.class) {
16             if (jedisPool == null) {
17                 synchronized (JedisPoolUtils.class) {
18                     if (jedisPool == null) {
19                         JedisPoolConfig poolConfig = new JedisPoolConfig();
20                         poolConfig.setMaxActive(1000);
21                         poolConfig.setMaxIdle(30);
22                         poolConfig.setMaxWait(100*1000);
23                         poolConfig.setTestOnBorrow(true);
24                         jedisPool = new JedisPool(poolConfig, "192.168.15.128", 6379);
25                     }
26                 }
27             }
28         }
29         return jedisPool;
30     }
31     
32     
33     
34     public static void release(JedisPool jedisPool,Jedis jedis){
35         if(jedis!=null){
36             jedisPool.returnResourceObject(jedis);
37         }
38     }
39 
40 }