使用Jedis jar操作Redis
1、配置redis.conf文件，修改
2、建java工程，加入 jedis jar包
3、代码示例：
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", "[email protected]");
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 }
4、使用JedisPool连接池
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 }
5、JedisPool配置参数
JedisPool的配置参数大部分是由JedisPoolConfig的对应项来赋值的。
maxActive：控制一个pool可分配多少个jedis实例，通过pool.getResource()来获取；如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted。
maxIdle：控制一个pool最多有多少个状态为idle(空闲)的jedis实例；
whenExhaustedAction：表示当pool中的jedis实例都被allocated完时，pool要采取的操作；默认有三种。
WHEN_EXHAUSTED_FAIL --> 表示无jedis实例时，直接抛出NoSuchElementException；
WHEN_EXHAUSTED_BLOCK --> 则表示阻塞住，或者达到maxWait时抛出JedisConnectionException；
WHEN_EXHAUSTED_GROW --> 则表示新建一个jedis实例，也就说设置的maxActive无用；
maxWait：表示当borrow一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛JedisConnectionException；
testOnBorrow：获得一个jedis实例的时候是否检查连接可用性（ping()）；如果为true，则得到的jedis实例均是可用的
testOnReturn：return 一个jedis实例给pool时，是否检查连接可用性（ping()）；
testWhileIdle：如果为true，表示有一个idle object evitor线程对idle object进行扫描，如果validate失败，此object会被从pool中drop掉；这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义；
timeBetweenEvictionRunsMillis：表示idle object evitor两次扫描之间要sleep的毫秒数；
numTestsPerEvictionRun：表示idle object evitor每次扫描的最多的对象数；
minEvictableIdleTimeMillis：表示一个对象至少停留在idle状态的最短时间，然后才能被idle object evitor扫描并驱逐；这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义；
softMinEvictableIdleTimeMillis：在minEvictableIdleTimeMillis基础上，加入了至少minIdle个对象已经在pool里面了。如果为-1，evicted不会根据idle time驱逐任何对象。如果minEvictableIdleTimeMillis>0，则此项设置无意义，且只有在timeBetweenEvictionRunsMillis大于0时才有意义；
lifo：borrowObject返回对象时，是采用DEFAULT_LIFO（last in first out，即类似cache的最频繁使用队列），如果为False，则表示FIFO队列；
==================================================================================================================
其中JedisPoolConfig对一些参数的默认设置如下：
testWhileIdle=true
minEvictableIdleTimeMills=60000
timeBetweenEvictionRunsMillis=30000
numTestsPerEvictionRun=-1