Java中使用Jedis操作Redis
一. redis 的安装
1. 下载源码，解压缩后编译源码。
[root@cwt123 ~]# tar xzf redis-2.8.3.tar.gz
[root@cwt123 ~]# cd redis-2.8.3
[root@cwt123 ~]# make
2. 启动 Redis 服务。(src 在 redis-2.8.3 下)
[root@cwt123 ~]# cd src
[root@cwt123 ~] ./redis-server
3. 连接 redis 客户端
[root@cwt123 ~]# ./redis-cli
4. 测试,redis 的 ip 即为机器的 ip, 端口默认为 6379
127.0.0.1:6379> set 'hello' 'test'
OK
127.0.0.1:6379> get hello
"test"
二. java 操作 redis
1. 直接连接 redis, 并操作 redis
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 | package com.sinovatech.mactivity.web.controller;import java.util.HashMap;import java.util.Iterator;import java.util.List;import java.util.Map;import org.junit.Before;import org.junit.Test;import redis.clients.jedis.Jedis;public class TestredisOwn { private Jedis jedis; @Before public void setup() { //连接redis服务器，192.168.0.100:6379 jedis = new Jedis("10.143.131.63", 6378); //权限认证 //jedis.auth("admin"); } /** * redis存储字符串 */ @Test public void testString() { //-----添加数据---------- jedis.set("name","xinxin");//向key-->name中放入了value-->xinxin System.out.println(jedis.get("name"));//执行结果：xinxin jedis.append("name", " is my lover"); //拼接 System.out.println(jedis.get("name")); jedis.del("name"); //删除某个键 System.out.println(jedis.get("name")); //设置多个键值对 jedis.mset("name","liuling","age","23","qq","476777XXX"); jedis.incr("age"); //进行加1操作 System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq")); } /** * redis操作Map */ @Test public void testMap() { //-----添加数据---------- Map<String, String> map = new HashMap<String, String>(); map.put("name", "xinxin"); map.put("age", "22"); map.put("qq", "123456"); jedis.hmset("user",map); //取出user中的name，执行结果:[minxr]-->注意结果是一个泛型的List //第一个参数是存入redis中map对象的key，后面跟的是放入map中的对象的key，后面的key可以跟多个，是可变参数 List<String> rsmap = jedis.hmget("user", "name", "age", "qq"); System.out.println(rsmap); //删除map中的某个键值 jedis.hdel("user","age"); System.out.println(jedis.hmget("user", "age")); //因为删除了，所以返回的是null System.out.println(jedis.hlen("user")); //返回key为user的键中存放的值的个数2 System.out.println(jedis.exists("user"));//是否存在key为user的记录 返回true System.out.println(jedis.hkeys("user"));//返回map对象中的所有key System.out.println(jedis.hvals("user"));//返回map对象中的所有value Iterator<String> iter=jedis.hkeys("user").iterator(); while (iter.hasNext()){ String key = iter.next(); System.out.println(key+":"+jedis.hmget("user",key)); } } /** * jedis操作List */ @Test public void testList(){ //lpush将数据从链表的头部插入,如果没有该key,在插入之前创建与key关联的空链表 jedis.lpush("java framework","spring"); jedis.lpush("java framework","struts"); jedis.lpush("java framework","hibernate"); //rpush将数据从链表的尾部插入元素,如果没有该key,在插入前穿件与该key关联的空链表 jedis.rpush("java frameworkr", "spring"); jedis.rpush("java frameworkr", "struts"); jedis.rpush("java frameworkr", "hibernate"); //lpop,取出链表的头部元素,没有返回null jedis.lpop("java framework"); //rpop取出链表的尾部元素,key不存在返回null jedis.rpop("java framework"); //再取出所有数据jedis.lrange是按范围取出， // 第一个是key，第二个是起始位置，第三个是结束位置，jedis.llen获取长度 -1表示取得所有 System.out.println(jedis.lrange("java framework",0,-1)); } /** * jedis操作Set */ @Test public void testSet(){ //添加 jedis.sadd("user","liuling"); jedis.sadd("user","xinxin"); jedis.sadd("user","ling"); jedis.sadd("user","zhangxinxin"); jedis.sadd("user","who"); //移除noname jedis.srem("user","who"); System.out.println(jedis.smembers("user"));//获取所有加入的value System.out.println(jedis.sismember("user", "who"));//判断 who 是否是user集合的元素 System.out.println(jedis.srandmember("user")); System.out.println(jedis.scard("user"));//返回集合的元素个数 } /** * jedis操作hash数据类型 存值hset(key,field,value) ,取值hget(key,field),删除hdel key field[field…],删除整个对象 所以该类型非常适合于存储值对象的信息。如Username、Password和Age等 * */ @Test public void testSet() { jedis.hset("TCradVoice:{17647435605}", "receiveFlag", ""); jedis.gset("TCradVoice:{17647435605}", "receiveFlag"); jedis.getall("TCradVoice:{17647435605}");//得到整个key下的所有值,返回map jedis.hdel("TCradVoice:{17647435605} ", "receiveFlag")//删除一个field jedis.del("TCradVoice:{17647435605}")//删除整个key } /* redis设置key的过期时间 expire(key,seconds) * */ @Test public void testExpire() { jedisDidiFreeFlow.expire("testexpire", 60);//过期时间60秒 } @Test public void test() throws InterruptedException { //jedis 排序 //注意，此处的rpush和lpush是List的操作。是一个双向链表（但从表现来看的） jedis.del("a");//先清除数据，再加入数据进行测试 jedis.rpush("a", "1"); jedis.lpush("a","6"); jedis.lpush("a","3"); jedis.lpush("a","9"); System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1] System.out.println(jedis.sort("a")); //[1, 3, 6, 9] //输入排序后结果 System.out.println(jedis.lrange("a",0,-1)); } //下面方法调用redis中的连接池 @Test public void testRedisPool() { TestRedisUtil.getJedis().set("newname", "中文测试"); System.out.println(TestRedisUtil.getJedis().get("newname")); } public static void main(){ Jedis jedis=TestRedisUtil.getJedis(); jedis.set("testrediskey001", "testrediskey001"); String getvalue=jedis.get("testrediskey001"); System.out.println(getvalue); }} |
2. 创建 redis 连接池, 并操作使用 redis
①Redis 连接池的创建
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 | package com.sinovatech.mactivity.web.controller;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;public final class TestRedisUtil { //Redis服务器IP private static String ADDR = "10.143.131.63"; //Redis的端口号 private static int PORT = 6378; //访问密码 private static String AUTH = "admin"; //可用连接实例的最大数目，默认值为8； //如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。 private static int MAX_ACTIVE = 1024; //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。 private static int MAX_IDLE = 200; //等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException； private static int MAX_WAIT = 10000; private static int TIMEOUT = 10000; //在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的； private static boolean TEST_ON_BORROW = true; private static JedisPool jedisPool = null; /** * 初始化Redis连接池 */ static { try { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(MAX_ACTIVE); config.setMaxIdle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT); config.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(config, ADDR, PORT); } catch (Exception e) { e.printStackTrace(); } } /** * 获取Jedis实例 * @return */ public synchronized static Jedis getJedis() { try { if (jedisPool != null) { Jedis resource = jedisPool.getResource(); return resource; } else { return null; } } catch (Exception e) { e.printStackTrace(); return null; } } /** * 释放jedis资源 * @param jedis */ public static void returnResource(final Jedis jedis) { if (jedis != null) { jedisPool.returnResource(jedis); } }} |
②使用创建好的 redis 连接池操作 redis
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | package com.sinovatech.mactivity.web.controller;import redis.clients.jedis.Jedis;public class TestRedisOwnNew { public static void main(String[] args) { // TODO Auto-generated method stub Jedis jedis=TestRedisUtil.getJedis(); jedis.set("testrediskey001", "testrediskey001"); String getvalue=jedis.get("testrediskey001"); System.out.println(getvalue); jedis.del("testrediskey001"); }} |
三.Redis 常用方法
1.redis 存储字符串:
① //----- 添加数据 ---------- 调用 set 方法
jedis.set("name","xinxin");// 向 key-->name 中放入了 value-->xinxin
System.out.println(jedis.get("name"));// 执行结果：xinxin
jedis.append("name", "is my lover"); // 拼接
System.out.println(jedis.get("name"));
②// 删除数据, 调用 del 方法
jedis.del("name"); // 删除某个键
System.out.println(jedis.get("name"));
③// 设置多个键值对, 调用 mset 方法参数格式为 (key,value,key,value)
jedis.mset("name","liuling","age","23","qq","476777XXX");
④//incr 方法, 对某个 key 的 value 值进行加 1 操作, 如果没有该 key 会自动创建, 并加 1
jedis.incr("age"); // 进行加 1 操作
System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));
2. redis 操作 Map
①//----- 添加数据 ---------- 调 hmset 方法, 放入一个 map
Map<String, String> map = new HashMap<String, String>();
map.put("name", "xinxin");
map.put("age", "22");
map.put("qq", "123456");
jedis.hmset("user",map);
// 取出 user 中的 name，执行结果:[minxr]--> 注意结果是一个泛型的 List
// 第一个参数是存入 redis 中 map 对象的 key，后面跟的是放入 map 中的对象的 key，后面的 key 可以跟多个，是可变参数
② // 取数据, 调用 hmget 方法, 参数是之前放入的 map 的 key, 返回的是一个 list
List<String> rsmap = jedis.hmget("user", "name", "age", "qq");
System.out.println(rsmap);
③ // 删除 map 中的某个键值 , 调用 hdel 方法, 可是删除多个键
jedis.hdel("user","age");
System.out.println(jedis.hmget("user", "age")); // 因为删除了，所以返回的是 null
System.out.println(jedis.hlen("user")); // 返回 key 为 user 的键中存放的值的个数 2
System.out.println(jedis.exists("user"));// 是否存在 key 为 user 的记录 返回 true
System.out.println(jedis.hkeys("user"));// 返回 map 对象中的所有 key
System.out.println(jedis.hvals("user"));// 返回 map 对象中的所有 value
Iterator<String> iter=jedis.hkeys("user").iterator();
while (iter.hasNext()){
String key = iter.next();
System.out.println(key+":"+jedis.hmget("user",key));
}
3.jedis 操作 List
①//lpush 将数据从链表的头部插入, 如果没有该 key, 在插入之前创建与 key 关联的空链表
jedis.lpush("java framework","spring");
jedis.lpush("java framework","struts");
jedis.lpush("java framework","hibernate");
②//rpush 将数据从链表的尾部插入元素, 如果没有该 key, 在插入前穿件与该 key 关联的空链表
jedis.rpush("java frameworkr", "spring");
jedis.rpush("java frameworkr", "struts");
jedis.rpush("java frameworkr", "hibernate");
③//lpop, 取出链表的头部元素, 没有返回 null
jedis.lpop("java framework");
④ //rpop 取出链表的尾部元素,key 不存在返回 null
jedis.rpop("java framework");
⑤ // 再取出所有数据 jedis.lrange 是按范围取出， 第一个是 key，第二个是起始位置，第三个是结束位置，jedis.llen 获取长度 -1 表示取得所有
System.out.println(jedis.lrange("java framework",0,-1));