Java中使用Jedis操作Redis
本文内容纲要：
使用Java操作Redis需要jedis-2.1.0.jar，下载地址：https://files.cnblogs.com/liuling/jedis-2.1.0.jar.zip
如果需要使用Redis连接池的话，还需commons-pool-1.5.4.jar，下载地址:https://files.cnblogs.com/liuling/commons-pool-1.5.4.jar.zip
1packagecom.test;
2
3importjava.util.HashMap;
4importjava.util.Iterator;
5importjava.util.List;
6importjava.util.Map;
7
8importorg.junit.Before;
9importorg.junit.Test;
10
11importredis.clients.jedis.Jedis;
12
13publicclassTestRedis{
14privateJedisjedis;
15
16@Before
17publicvoidsetup(){
18//连接redis服务器，192.168.0.100:6379
19jedis=newJedis("192.168.0.100",6379);
20//权限认证
21jedis.auth("admin");
22}
23
24/**
25*redis存储字符串
26*/
27@Test
28publicvoidtestString(){
29//-----添加数据----------
30jedis.set("name","xinxin");//向key-->name中放入了value-->xinxin
31System.out.println(jedis.get("name"));//执行结果：xinxin
32
33jedis.append("name","ismylover");//拼接
34System.out.println(jedis.get("name"));
35
36jedis.del("name");//删除某个键
37System.out.println(jedis.get("name"));
38//设置多个键值对
39jedis.mset("name","liuling","age","23","qq","476777XXX");
40jedis.incr("age");//进行加1操作
41System.out.println(jedis.get("name")+"-"+jedis.get("age")+"-"+jedis.get("qq"));
42
43}
44
45/**
46*redis操作Map
47*/
48@Test
49publicvoidtestMap(){
50//-----添加数据----------
51Map<String,String>map=newHashMap<String,String>();
52map.put("name","xinxin");
53map.put("age","22");
54map.put("qq","123456");
55jedis.hmset("user",map);
56//取出user中的name，执行结果:[minxr]-->注意结果是一个泛型的List
57//第一个参数是存入redis中map对象的key，后面跟的是放入map中的对象的key，后面的key可以跟多个，是可变参数
58List<String>rsmap=jedis.hmget("user","name","age","qq");
59System.out.println(rsmap);
60
61//删除map中的某个键值
62jedis.hdel("user","age");
63System.out.println(jedis.hmget("user","age"));//因为删除了，所以返回的是null
64System.out.println(jedis.hlen("user"));//返回key为user的键中存放的值的个数2
65System.out.println(jedis.exists("user"));//是否存在key为user的记录返回true
66System.out.println(jedis.hkeys("user"));//返回map对象中的所有key
67System.out.println(jedis.hvals("user"));//返回map对象中的所有value
68
69Iterator<String>iter=jedis.hkeys("user").iterator();
70while(iter.hasNext()){
71Stringkey=iter.next();
72System.out.println(key+":"+jedis.hmget("user",key));
73}
74}
75
76/**
77*jedis操作List
78*/
79@Test
80publicvoidtestList(){
81//开始前，先移除所有的内容
82jedis.del("javaframework");
83System.out.println(jedis.lrange("javaframework",0,-1));
84//先向keyjavaframework中存放三条数据
85jedis.lpush("javaframework","spring");
86jedis.lpush("javaframework","struts");
87jedis.lpush("javaframework","hibernate");
88//再取出所有数据jedis.lrange是按范围取出，
89//第一个是key，第二个是起始位置，第三个是结束位置，jedis.llen获取长度-1表示取得所有
90System.out.println(jedis.lrange("javaframework",0,-1));
91
92jedis.del("javaframework");
93jedis.rpush("javaframework","spring");
94jedis.rpush("javaframework","struts");
95jedis.rpush("javaframework","hibernate");
96System.out.println(jedis.lrange("javaframework",0,-1));
97}
98
99/**
100*jedis操作Set
101*/
102@Test
103publicvoidtestSet(){
104//添加
105jedis.sadd("user","liuling");
106jedis.sadd("user","xinxin");
107jedis.sadd("user","ling");
108jedis.sadd("user","zhangxinxin");
109jedis.sadd("user","who");
110//移除noname
111jedis.srem("user","who");
112System.out.println(jedis.smembers("user"));//获取所有加入的value
113System.out.println(jedis.sismember("user","who"));//判断who是否是user集合的元素
114System.out.println(jedis.srandmember("user"));
115System.out.println(jedis.scard("user"));//返回集合的元素个数
116}
117
118@Test
119publicvoidtest()throwsInterruptedException{
120//jedis排序
121//注意，此处的rpush和lpush是List的操作。是一个双向链表（但从表现来看的）
122jedis.del("a");//先清除数据，再加入数据进行测试
123jedis.rpush("a","1");
124jedis.lpush("a","6");
125jedis.lpush("a","3");
126jedis.lpush("a","9");
127System.out.println(jedis.lrange("a",0,-1));//[9,3,6,1]
128System.out.println(jedis.sort("a"));//[1,3,6,9]//输入排序后结果
129System.out.println(jedis.lrange("a",0,-1));
130}
131
132@Test
133publicvoidtestRedisPool(){
134RedisUtil.getJedis().set("newname","中文测试");
135System.out.println(RedisUtil.getJedis().get("newname"));
136}
137}
Redis连接池：
1packagecom.test;
2
3importredis.clients.jedis.Jedis;
4importredis.clients.jedis.JedisPool;
5importredis.clients.jedis.JedisPoolConfig;
6
7publicfinalclassRedisUtil{
8
9//Redis服务器IP
10privatestaticStringADDR="192.168.0.100";
11
12//Redis的端口号
13privatestaticintPORT=6379;
14
15//访问密码
16privatestaticStringAUTH="admin";
17
18//可用连接实例的最大数目，默认值为8；
19//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
20privatestaticintMAX_ACTIVE=1024;
21
22//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。
23privatestaticintMAX_IDLE=200;
24
25//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；
26privatestaticintMAX_WAIT=10000;
27
28privatestaticintTIMEOUT=10000;
29
30//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
31privatestaticbooleanTEST_ON_BORROW=true;
32
33privatestaticJedisPooljedisPool=null;
34
35/**
36*初始化Redis连接池
37*/
38static{
39try{
40JedisPoolConfigconfig=newJedisPoolConfig();
41config.setMaxActive(MAX_ACTIVE);
42config.setMaxIdle(MAX_IDLE);
43config.setMaxWait(MAX_WAIT);
44config.setTestOnBorrow(TEST_ON_BORROW);
45jedisPool=newJedisPool(config,ADDR,PORT,TIMEOUT,AUTH);
46}catch(Exceptione){
47e.printStackTrace();
48}
49}
50
51/**
52*获取Jedis实例
53*@return
54*/
55publicsynchronizedstaticJedisgetJedis(){
56try{
57if(jedisPool!=null){
58Jedisresource=jedisPool.getResource();
59returnresource;
60}else{
61returnnull;
62}
63}catch(Exceptione){
64e.printStackTrace();
65returnnull;
66}
67}
68
69/**
70*释放jedis资源
71*@paramjedis
72*/
73publicstaticvoidreturnResource(finalJedisjedis){
74if(jedis!=null){
75jedisPool.returnResource(jedis);
76}
77}
78}
本文内容总结：
原文链接：https://www.cnblogs.com/liuling/p/2014-4-19-04.html