03.RedisJava客戶端Jedis的使用

 

1.Jedis基本使用

使用Jedis客戶端使用Redis服務與在服務器上通過redis-cli 使用命令 基本一樣，關於Redis命令請參考： http://www.redis.cn/commands.html、 http://www.runoob.com/redis/redis-commands.html

1.使用Jedis連接Redis服務

1. publicstaticvoid main(String[] args)
2. {
3. Jedis jedis =newJedis("192.168.110.101",6379);
4. String result = jedis.ping();// 測試連接
5. System.out.println(result);
6. jedis.close();
7. }

2.Jedis客戶端的基本使用

下面根據Redis命令划分，使用Jedis

1. //關鍵字（Keys）
2. System.out.println("exists :"+ jedis.exists("name"));
3. System.out.println("del :"+ jedis.del("name"));
5. //字符串（String）
6. System.out.println("set :"+ jedis.set("name","危常煥"));
7. System.out.println("get :"+ jedis.get("name"));
9. //哈希（Hashs）
10. for(int i =0; i <10; i++)
11. {
12. System.out.println("hset :"+ jedis.hset("hset","set-key"+ i,"set-value"+ i));
13. }
14. System.out.println("hkeys :"+ jedis.hkeys("hset"));
16. //列表（Lists）
17. System.out.println("rpush :"+ jedis.rpush("lset","lset001","lset002","lset003","lset004"));
18. System.out.println("lrange :"+ jedis.lrange("lset",0,2));
20. //集合（Sets）
21. System.out.println("sadd :"+ jedis.sadd("sadd","sadd001","sadd002","sadd003"));
22. System.out.println("scard :"+ jedis.scard("sadd"));
24. //有序集合（Sorted Sets）
25. Map<String,Double> scoreMembers =newHashMap<String,Double>();
26. scoreMembers.put("001",0.1D);
27. scoreMembers.put("002",0.2D);
28. scoreMembers.put("003",0.3D);
29. System.out.println("zadd :"+ jedis.zadd("zadd", scoreMembers));
30. System.out.println("zrange :"+ jedis.zrange("zadd",1L,2L));
32. //HyperLogLog
33. for(int i =0; i <10; i++)
34. {
35. System.out.println("pfadd :"+ jedis.pfadd("HyperLogLog", UUID.randomUUID().toString()));
36. }
37. System.out.println("pfcount :"+ jedis.pfcount("HyperLogLog"));
39. //發布/訂閱（Pub/Sub）
40. Thread thread =newThread(newRunnable()
41. {
42. @Override
43. publicvoid run()
44. {
45. finalJedis j =newJedis("192.168.110.101",6379);
46. j.subscribe(newJedisPubSub()
47. {
48. @Override
49. publicvoid onMessage(String channel,String message)
50. {
51. System.out.println("onMessage--channel:"+ channel +" message:"+ message);
52. this.unsubscribe();
53. }
54. },"channel001");
55. j.close();
56. System.out.println("連接已關閉");
57. }
58. });
59. thread.start();
60. Thread.sleep(10);
61. System.out.println("publish :"+ jedis.publish("channel001","發送一條消息"));
63. //事務（Transactions）
64. Transaction transaction = jedis.multi();
65. System.out.println("set :"+ transaction.set("multi001","123"));
66. System.out.println("incr :"+ transaction.incr("multi001"));
67. System.out.println("transaction.exec :"+ transaction.exec());
69. // 腳本（Scripting）
70. System.out.println("eval :"+ jedis.eval("local msg = \"Hello, world!\" return msg"));
72. //連接（Connection）
73. System.out.println("ping :"+ jedis.ping());
74. System.out.println("select :"+ jedis.select(0));
76. //服務（Server）
77. System.out.println("dbSize :"+ jedis.dbSize());
78. System.out.println("clientList :"+ jedis.clientList());

Redis支持執行Lua腳本，關於Lua腳本的基本使用可參考： http://www.oschina.net/translate/intro-to-lua-for-redis-programmers

2.Jedis深入使用

1.Jedis中常見類關系如下

2.JedisPool的使用

JedisPool只是提供基本的連接池而已

1. publicstaticvoid main(String[] args)
2. {
3. JedisPoolConfig config =newJedisPoolConfig();
4. // 連接池中最大連接數。高版本：maxTotal，低版本：maxActive
5. config.setMaxTotal(8);
6. // 連接池中最大空閑的連接數
7. config.setMaxIdle(4);
8. // 連接池中最少空閑的連接數
9. config.setMinIdle(1);
10. // 當連接池資源耗盡時，調用者最大阻塞的時間，超時將跑出異常。單位，毫秒數;默認為-1.表示永不超時。高版本：maxWaitMillis，低版本：maxWait
11. config.setMaxWaitMillis(15000);
12. // 連接空閑的最小時間，達到此值后空閑連接將可能會被移除。負值(-1)表示不移除
13. config.setMinEvictableIdleTimeMillis(300000);
14. // 對於“空閑鏈接”檢測線程而言，每次檢測的鏈接資源的個數。默認為3
15. config.setNumTestsPerEvictionRun(3);
16. // “空閑鏈接”檢測線程，檢測的周期，毫秒數。如果為負值，表示不運行“檢測線程”。默認為-1
17. config.setTimeBetweenEvictionRunsMillis(60000);// 一分鍾
18. // 向調用者輸出“鏈接”資源時，是否檢測是有有效，如果無效則從連接池中移除，並嘗試獲取繼續獲取。默認為false。建議保持默認值
19. config.setTestOnBorrow(false);
20. // 向連接池“歸還”鏈接時，是否檢測“鏈接”對象的有效性。默認為false。建議保持默認值
21. config.setTestOnReturn(false);
22. // 向調用者輸出“鏈接”對象時，是否檢測它的空閑超時；默認為false。如果“鏈接”空閑超時，將會被移除。建議保持默認值
23. config.setTestWhileIdle(false);
25. JedisPool pool =newJedisPool(config,"192.168.110.101",6379);
26. Jedis jedis = pool.getResource();// 從pool中獲取資源
27. try
28. {
29. jedis.set("k1","v1");
30. System.out.println(jedis.get("k1"));
31. }
32. catch(Exception e)
33. {
34. e.printStackTrace();
35. }
36. finally
37. {
38. jedis.close();
39. // pool.returnResource(jedis); // 此方法已過時
40. }
42. for(int i =0; i <10; i++)
43. {
44. jedis = pool.getResource();
45. // jedis.close(); // 去掉注釋觀察效果
46. System.out.println("NumActive:"+ pool.getNumActive());
47. System.out.println("NumIdle:"+ pool.getNumIdle());
48. System.out.println("NumWaiters:"+ pool.getNumWaiters());
49. }
50. pool.close();
51. pool.destroy();
52. }

3.JedisSentinelPool使用

JedisSentinelPool在有Sentinel集群服務時使用，他除了提供連接池功能之外還能夠在master服務宕機 Sentinel 集群選出新的 master 服務節點后連接池連接的Redis服務也會更新成新的 master 服務地址

1. publicstaticvoid main(String[] args)
2. {
3. String host =null;
4. int port =0;
6. Set<String> sentinels =newHashSet<String>();
7. sentinels.add("192.168.110.100:26379");
8. sentinels.add("192.168.110.100:36379");
9. sentinels.add("192.168.110.100:46379");
10. JedisSentinelPool jedisSentinelPool =newJedisSentinelPool("master001", sentinels);
12. host = jedisSentinelPool.getCurrentHostMaster().getHost();
13. port = jedisSentinelPool.getCurrentHostMaster().getPort();
14. System.out.println(host +":"+ port);
16. Jedis jedis = jedisSentinelPool.getResource();
17. jedis.set("001","ASDFG");
18. System.out.println(jedis.get("001"));
19. jedis.close();
21. // 關閉Redis Master服務
22. Scanner scanner =newScanner(System.in);
23. String input = scanner.nextLine();
24. System.out.println(input);
26. host = jedisSentinelPool.getCurrentHostMaster().getHost();
27. port = jedisSentinelPool.getCurrentHostMaster().getPort();
28. System.out.println(host +":"+ port);
30. jedis = jedisSentinelPool.getResource();
31. jedis.set("001","ZXCVB");
32. System.out.println(jedis.get("001"));
33. jedis.close();
35. jedisSentinelPool.close();
36. jedisSentinelPool.destroy();
37. }

注意： master服務宕機之后一段時間內(若干秒)方法返回的jedis客戶端還是以前的master服務地址，會導致連接池在一段時間內(若干秒)不能使用。但是很快就會回復正常連接到新的master服務上，需要注意的是這需要一段時間(若干秒)

運行以上程序輸出如下，注意中間打印的部分：

1. 192.168.110.102:6379
2. ASDFG
3. 2015-10-222:50:30 redis.clients.jedis.JedisSentinelPool initPool
4. 信息:CreatedJedisPool to master at 192.168.110.101:6379
7. 192.168.110.101:6379
8. ZXCVB

對於 Sentinel的特有操作Jedis類 就有方法支持：

4.ShardedJedisPool使用

ShardedJedisPool除了有連接池的功能，它可以根據key計算出這個key對應存儲的Redis服務器，實現多台Redis服務器擴容

1. publicstaticvoid main(String[] args)
2. {
3. JedisPoolConfig config =newJedisPoolConfig();
4. List<JedisShardInfo> shards =newArrayList<JedisShardInfo>();
5. shards.add(newJedisShardInfo("192.168.110.101","Redis001",6379,20*1000,1));
6. shards.add(newJedisShardInfo("192.168.110.102","Redis002",6379,20*1000,2));
7. shards.add(newJedisShardInfo("192.168.110.103","Redis003",6379,20*1000,4));
8. ShardedJedisPool shardedJedisPool =newShardedJedisPool(config, shards);
10. for(int i =0; i <10; i++)
11. {
12. ShardedJedis shardedJedis = shardedJedisPool.getResource();
13. String key ="shard"+ i;
14. shardedJedis.set(key,"v-"+ i);
15. System.out.println(shardedJedis.get(key));
16. JedisShardInfo shardInfo = shardedJedis.getShardInfo(key);
17. System.out.println("getHost:"+ shardInfo.getHost());
18. shardedJedis.close();
19. }
21. shardedJedisPool.close();
22. shardedJedisPool.destroy();
23. }

運行打印結果：

1. v-0
2. getHost:192.168.110.102
3. v-1
4. getHost:192.168.110.101
5. v-2
6. getHost:192.168.110.102
7. v-3
8. getHost:192.168.110.103
9. v-4
10. getHost:192.168.110.102
11. v-5
12. getHost:192.168.110.102
13. v-6
14. getHost:192.168.110.103
15. v-7
16. getHost:192.168.110.102
17. v-8
18. getHost:192.168.110.102
19. v-9
20. getHost:192.168.110.103

注意：計算key對應到Redis服務器的默認算法與Redis的IP和端口無關，只與 JedisShardInfo 的name屬性有關，所以可以好好使用這個特性！其具體實現如下：

1. //位置：redis.clients.util.Sharded<R, S extends ShardInfo<R>>
2. privatevoid initialize(List<S> shards)
3. {
4. nodes =newTreeMap<Long, S>();
6. for(int i =0; i != shards.size();++i)
7. {
8. final S shardInfo = shards.get(i);
9. if(shardInfo.getName()==null)
10. for(int n =0; n <160* shardInfo.getWeight(); n++)
11. {
12. nodes.put(this.algo.hash("SHARD-"+ i +"-NODE-"+ n), shardInfo);
13. }
14. else
15. for(int n =0; n <160* shardInfo.getWeight(); n++)
16. {
17. nodes.put(this.algo.hash(shardInfo.getName()+"*"+ shardInfo.getWeight()+ n), shardInfo);
18. }
19. resources.put(shardInfo, shardInfo.createResource());
20. }
21. }

-------------------------------------------------------------------------------------------------------------------------------

來自為知筆記(Wiz)