java操做redis。jedis使用api
1 package com.wujintao.redis; 2 3 import java.util.Date; 4 import java.util.HashMap; 5 import java.util.Iterator; 6 import java.util.List; 7 import java.util.Map; 8 import java.util.Set; 9 10 import org.junit.Test; 11 12 import redis.clients.jedis.Jedis; 13 import redis.clients.jedis.Pipeline; 14 import redis.clients.jedis.SortingParams; 15 16 import com.wujintao.redis.util.RedisUtil; 17 18 19 public class TestCase 20 { 21 22 /** 23 * 在不一樣的線程中使用相同的Jedis實例會發生奇怪的錯誤。可是建立太多的實現也很差由於這意味着會創建不少sokcet鏈接， 24 * 也會致使奇怪的錯誤發生。單一Jedis實例不是線程安全的。爲了不這些問題，可使用JedisPool, 25 * JedisPool是一個線程安全的網絡鏈接池。能夠用JedisPool建立一些可靠Jedis實例，能夠從池中拿到Jedis的實例。 26 * 這種方式能夠解決那些問題而且會實現高效的性能 27 */ 28 29 public static void main(String[] args) 30 { 31 // ...when closing your application: 32 RedisUtil.getPool().destroy(); 33 } 34 35 public static void Hello() 36 { 37 Jedis jedis = RedisUtil.getJedis(); 38 try 39 { 40 // 向key-->name中放入了value-->minxr 41 jedis.set("name", "minxr"); 42 String ss = jedis.get("name"); 43 System.out.println(ss); 44 45 // 很直觀，相似map 將jintao append到已經有的value以後 46 jedis.append("name", "jintao"); 47 ss = jedis.get("name"); 48 System.out.println(ss); 49 50 // 二、直接覆蓋原來的數據 51 jedis.set("name", "jintao"); 52 System.out.println(jedis.get("jintao")); 53 54 // 刪除key對應的記錄 55 jedis.del("name"); 56 System.out.println(jedis.get("name"));// 執行結果：null 57 58 /** 59 * mset至關於 jedis.set("name","minxr"); jedis.set("jarorwar","aaa"); 60 */ 61 jedis.mset("name", "minxr", "jarorwar", "aaa"); 62 System.out.println(jedis.mget("name", "jarorwar")); 63 } 64 catch (Exception e) 65 { 66 e.printStackTrace(); 67 } 68 finally 69 { 70 RedisUtil.getPool().returnResource(jedis); 71 } 72 73 } 74 75 private void testKey() 76 { 77 Jedis jedis = RedisUtil.getJedis(); 78 System.out.println("=============key=========================="); 79 // 清空數據 80 System.out.println(jedis.flushDB()); 81 System.out.println(jedis.echo("foo")); 82 // 判斷key否存在 83 System.out.println(jedis.exists("foo")); 84 jedis.set("key", "values"); 85 System.out.println(jedis.exists("key")); 86 } 87 88 public static void testString() 89 { 90 System.out.println("==String=="); 91 Jedis jedis = RedisUtil.getJedis(); 92 try 93 { 94 // String 95 jedis.set("key", "Hello World!"); 96 String value = jedis.get("key"); 97 System.out.println(value); 98 } 99 catch (Exception e) 100 { 101 e.printStackTrace(); 102 } 103 finally 104 { 105 RedisUtil.getPool().returnResource(jedis); 106 } 107 108 System.out.println("=============String=========================="); 109 // 清空數據 110 System.out.println(jedis.flushDB()); 111 // 存儲數據 112 jedis.set("foo", "bar"); 113 System.out.println(jedis.get("foo")); 114 // 若key不存在，則存儲 115 jedis.setnx("foo", "foo not exits"); 116 System.out.println(jedis.get("foo")); 117 // 覆蓋數據 118 jedis.set("foo", "foo update"); 119 System.out.println(jedis.get("foo")); 120 // 追加數據 121 jedis.append("foo", " hello, world"); 122 System.out.println(jedis.get("foo")); 123 // 設置key的有效期，並存儲數據 124 jedis.setex("foo", 2, "foo not exits"); 125 System.out.println(jedis.get("foo")); 126 try 127 { 128 Thread.sleep(3000); 129 } 130 catch (InterruptedException e) 131 { 132 } 133 System.out.println(jedis.get("foo")); 134 // 獲取並更改數據 135 jedis.set("foo", "foo update"); 136 System.out.println(jedis.getSet("foo", "foo modify")); 137 // 截取value的值 138 System.out.println(jedis.getrange("foo", 1, 3)); 139 System.out.println(jedis.mset("mset1", "mvalue1", "mset2", "mvalue2", 140 "mset3", "mvalue3", "mset4", "mvalue4")); 141 System.out.println(jedis.mget("mset1", "mset2", "mset3", "mset4")); 142 System.out.println(jedis.del(new String[] { "foo", "foo1", "foo3" })); 143 } 144 145 public static void testList() 146 { 147 System.out.println("==List=="); 148 Jedis jedis = RedisUtil.getJedis(); 149 try 150 { 151 // 開始前，先移除全部的內容 152 jedis.del("messages"); 153 jedis.rpush("messages", "Hello how are you?"); 154 jedis.rpush("messages", "Fine thanks. I'm having fun with redis."); 155 jedis.rpush("messages", "I should look into this NOSQL thing ASAP"); 156 157 // 再取出全部數據jedis.lrange是按範圍取出， 158 // 第一個是key，第二個是起始位置，第三個是結束位置，jedis.llen獲取長度 -1表示取得全部 159 List<String> values = jedis.lrange("messages", 0, -1); 160 System.out.println(values); 161 } 162 catch (Exception e) 163 { 164 e.printStackTrace(); 165 } 166 finally 167 { 168 RedisUtil.getPool().returnResource(jedis); 169 } 170 171 // 清空數據 172 System.out.println(jedis.flushDB()); 173 // 添加數據 174 jedis.lpush("lists", "vector"); 175 jedis.lpush("lists", "ArrayList"); 176 jedis.lpush("lists", "LinkedList"); 177 // 數組長度 178 System.out.println(jedis.llen("lists")); 179 // 排序 180 System.out.println(jedis.sort("lists")); 181 // 字串 182 System.out.println(jedis.lrange("lists", 0, 3)); 183 // 修改列表中單個值 184 jedis.lset("lists", 0, "hello list!"); 185 // 獲取列表指定下標的值 186 System.out.println(jedis.lindex("lists", 1)); 187 // 刪除列表指定下標的值 188 System.out.println(jedis.lrem("lists", 1, "vector")); 189 // 刪除區間之外的數據 190 System.out.println(jedis.ltrim("lists", 0, 1)); 191 // 列表出棧 192 System.out.println(jedis.lpop("lists")); 193 // 整個列表值 194 System.out.println(jedis.lrange("lists", 0, -1)); 195 } 196 197 public static void testSet() 198 { 199 System.out.println("==Set=="); 200 Jedis jedis = RedisUtil.getJedis(); 201 try 202 { 203 jedis.sadd("myset", "1"); 204 jedis.sadd("myset", "2"); 205 jedis.sadd("myset", "3"); 206 jedis.sadd("myset", "4"); 207 Set<String> setValues = jedis.smembers("myset"); 208 System.out.println(setValues); 209 210 // 移除noname 211 jedis.srem("myset", "4"); 212 System.out.println(jedis.smembers("myset"));// 獲取全部加入的value 213 System.out.println(jedis.sismember("myset", "4"));// 判斷 minxr 214 // 是不是sname集合的元素 215 System.out.println(jedis.scard("sname"));// 返回集合的元素個數 216 } 217 catch (Exception e) 218 { 219 e.printStackTrace(); 220 } 221 finally 222 { 223 RedisUtil.getPool().returnResource(jedis); 224 } 225 226 // 清空數據 227 System.out.println(jedis.flushDB()); 228 // 添加數據 229 jedis.sadd("sets", "HashSet"); 230 jedis.sadd("sets", "SortedSet"); 231 jedis.sadd("sets", "TreeSet"); 232 // 判斷value是否在列表中 233 System.out.println(jedis.sismember("sets", "TreeSet")); 234 ; 235 // 整個列表值 236 System.out.println(jedis.smembers("sets")); 237 // 刪除指定元素 238 System.out.println(jedis.srem("sets", "SortedSet")); 239 // 出棧 240 System.out.println(jedis.spop("sets")); 241 System.out.println(jedis.smembers("sets")); 242 // 243 jedis.sadd("sets1", "HashSet1"); 244 jedis.sadd("sets1", "SortedSet1"); 245 jedis.sadd("sets1", "TreeSet"); 246 jedis.sadd("sets2", "HashSet2"); 247 jedis.sadd("sets2", "SortedSet1"); 248 jedis.sadd("sets2", "TreeSet1"); 249 // 交集 250 System.out.println(jedis.sinter("sets1", "sets2")); 251 // 並集 252 System.out.println(jedis.sunion("sets1", "sets2")); 253 // 差集 254 System.out.println(jedis.sdiff("sets1", "sets2")); 255 } 256 257 public static void sortedSet() 258 { 259 System.out.println("==SoretedSet=="); 260 Jedis jedis = RedisUtil.getJedis(); 261 try 262 { 263 jedis.zadd("hackers", 1940, "Alan Kay"); 264 jedis.zadd("hackers", 1953, "Richard Stallman"); 265 jedis.zadd("hackers", 1965, "Yukihiro Matsumoto"); 266 jedis.zadd("hackers", 1916, "Claude Shannon"); 267 jedis.zadd("hackers", 1969, "Linus Torvalds"); 268 jedis.zadd("hackers", 1912, "Alan Turing"); 269 Set<String> setValues = jedis.zrange("hackers", 0, -1); 270 System.out.println(setValues); 271 Set<String> setValues2 = jedis.zrevrange("hackers", 0, -1); 272 System.out.println(setValues2); 273 } 274 catch (Exception e) 275 { 276 e.printStackTrace(); 277 } 278 finally 279 { 280 RedisUtil.getPool().returnResource(jedis); 281 } 282 283 // 清空數據 284 System.out.println(jedis.flushDB()); 285 // 添加數據 286 jedis.zadd("zset", 10.1, "hello"); 287 jedis.zadd("zset", 10.0, ":"); 288 jedis.zadd("zset", 9.0, "zset"); 289 jedis.zadd("zset", 11.0, "zset!"); 290 // 元素個數 291 System.out.println(jedis.zcard("zset")); 292 // 元素下標 293 System.out.println(jedis.zscore("zset", "zset")); 294 // 集合子集 295 System.out.println(jedis.zrange("zset", 0, -1)); 296 // 刪除元素 297 System.out.println(jedis.zrem("zset", "zset!")); 298 System.out.println(jedis.zcount("zset", 9.5, 10.5)); 299 // 整個集合值 300 System.out.println(jedis.zrange("zset", 0, -1)); 301 } 302 303 public static void testHsh() 304 { 305 System.out.println("==Hash=="); 306 Jedis jedis = RedisUtil.getJedis(); 307 try 308 { 309 Map<String, String> pairs = new HashMap<String, String>(); 310 pairs.put("name", "Akshi"); 311 pairs.put("age", "2"); 312 pairs.put("sex", "Female"); 313 jedis.hmset("kid", pairs); 314 List<String> name = jedis.hmget("kid", "name");// 結果是個泛型的LIST 315 // jedis.hdel("kid","age"); //刪除map中的某個鍵值 316 System.out.println(jedis.hmget("kid", "pwd")); // 由於刪除了，因此返回的是null 317 System.out.println(jedis.hlen("kid")); // 返回key爲user的鍵中存放的值的個數 318 System.out.println(jedis.exists("kid"));// 是否存在key爲user的記錄 319 System.out.println(jedis.hkeys("kid"));// 返回map對象中的全部key 320 System.out.println(jedis.hvals("kid"));// 返回map對象中的全部value 321 322 Iterator<String> iter = jedis.hkeys("kid").iterator(); 323 while (iter.hasNext()) 324 { 325 String key = iter.next(); 326 System.out.println(key + ":" + jedis.hmget("kid", key)); 327 } 328 329 List<String> values = jedis.lrange("messages", 0, -1); 330 values = jedis.hmget("kid", new String[] { "name", "age", "sex" }); 331 System.out.println(values); 332 Set<String> setValues = jedis.zrange("hackers", 0, -1); 333 setValues = jedis.hkeys("kid"); 334 System.out.println(setValues); 335 values = jedis.hvals("kid"); 336 System.out.println(values); 337 pairs = jedis.hgetAll("kid"); 338 System.out.println(pairs); 339 } 340 catch (Exception e) 341 { 342 e.printStackTrace(); 343 } 344 finally 345 { 346 RedisUtil.getPool().returnResource(jedis); 347 } 348 349 // 清空數據 350 System.out.println(jedis.flushDB()); 351 // 添加數據 352 jedis.hset("hashs", "entryKey", "entryValue"); 353 jedis.hset("hashs", "entryKey1", "entryValue1"); 354 jedis.hset("hashs", "entryKey2", "entryValue2"); 355 // 判斷某個值是否存在 356 System.out.println(jedis.hexists("hashs", "entryKey")); 357 // 獲取指定的值 358 System.out.println(jedis.hget("hashs", "entryKey")); // 批量獲取指定的值 359 System.out.println(jedis.hmget("hashs", "entryKey", "entryKey1")); 360 // 刪除指定的值 361 System.out.println(jedis.hdel("hashs", "entryKey")); 362 // 爲key中的域 field 的值加上增量 increment 363 System.out.println(jedis.hincrBy("hashs", "entryKey", 123l)); 364 // 獲取全部的keys 365 System.out.println(jedis.hkeys("hashs")); 366 // 獲取全部的values 367 System.out.println(jedis.hvals("hashs")); 368 } 369 370 public static void testOther() throws InterruptedException 371 { 372 Jedis jedis = RedisUtil.getJedis(); 373 374 try 375 { 376 // keys中傳入的能夠用通配符 377 System.out.println(jedis.keys("*")); // 返回當前庫中全部的key [sose, sanme, 378 // name, jarorwar, foo, 379 // sname, java framework, 380 // user, braand] 381 System.out.println(jedis.keys("*name"));// 返回的sname [sname, name] 382 System.out.println(jedis.del("sanmdde"));// 刪除key爲sanmdde的對象 刪除成功返回1 383 // 刪除失敗（或者不存在）返回 0 384 System.out.println(jedis.ttl("sname"));// 返回給定key的有效時間，若是是-1則表示永遠有效 385 jedis.setex("timekey", 10, "min");// 經過此方法，能夠指定key的存活（有效時間） 時間爲秒 386 Thread.sleep(5000);// 睡眠5秒後，剩餘時間將爲<=5 387 System.out.println(jedis.ttl("timekey")); // 輸出結果爲5 388 jedis.setex("timekey", 1, "min"); // 設爲1後，下面再看剩餘時間就是1了 389 System.out.println(jedis.ttl("timekey")); // 輸出結果爲1 390 System.out.println(jedis.exists("key"));// 檢查key是否存在 391 System.out.println(jedis.rename("timekey", "time")); 392 System.out.println(jedis.get("timekey"));// 由於移除，返回爲null 393 System.out.println(jedis.get("time")); // 由於將timekey 重命名爲time 394 // 因此能夠取得值 min 395 // jedis 排序 396 // 注意，此處的rpush和lpush是List的操做。是一個雙向鏈表（但從表現來看的） 397 jedis.del("a");// 先清除數據，再加入數據進行測試 398 jedis.rpush("a", "1"); 399 jedis.lpush("a", "6"); 400 jedis.lpush("a", "3"); 401 jedis.lpush("a", "9"); 402 System.out.println(jedis.lrange("a", 0, -1));// [9, 3, 6, 1] 403 System.out.println(jedis.sort("a")); // [1, 3, 6, 9] //輸入排序後結果 404 System.out.println(jedis.lrange("a", 0, -1)); 405 } 406 catch (Exception e) 407 { 408 e.printStackTrace(); 409 } 410 finally 411 { 412 RedisUtil.getPool().returnResource(jedis); 413 } 414 415 } 416 417 @org.junit.Test 418 public void testUnUsePipeline() 419 { 420 long start = new Date().getTime(); 421 422 Jedis jedis = RedisUtil.getJedis(); 423 for (int i = 0; i < 10000; i++) 424 { 425 jedis.set("age1" + i, i + ""); 426 jedis.get("age1" + i);// 每一個操做都發送請求給redis-server 427 } 428 long end = new Date().getTime(); 429 430 System.out.println("unuse pipeline cost:" + (end - start) + "ms"); 431 432 RedisUtil.getPool().returnResource(jedis); 433 } 434 435 @org.junit.Test 436 /** 437 * 參考:http://blog.csdn.net/freebird_lb/article/details/7778919 438 */ 439 public void testUsePipeline() 440 { 441 long start = new Date().getTime(); 442 443 Jedis jedis = RedisUtil.getJedis(); 444 jedis.flushDB(); 445 Pipeline p = jedis.pipelined(); 446 for (int i = 0; i < 10000; i++) 447 { 448 p.set("age2" + i, i + ""); 449 System.out.println(p.get("age2" + i)); 450 } 451 p.sync();// 這段代碼獲取全部的response 452 453 long end = new Date().getTime(); 454 455 System.out.println("use pipeline cost:" + (end - start) + "ms"); 456 457 RedisUtil.getPool().returnResource(jedis); 458 } 459 460 461 @org.junit.Test 462 /** 463 * 時間複雜度： 464 O(N+M*log(M))， N 爲要排序的列表或集合內的元素數量， M 爲要返回的元素數量。 465 若是隻是使用 SORT 命令的 GET 選項獲取數據而沒有進行排序，時間複雜度 O(N)。 466 */ 467 public void testSort1() 468 { 469 // 排序默認以數字做爲對象，值被解釋爲雙精度浮點數，而後進行比較 470 Jedis redis = RedisUtil.getJedis(); 471 // 通常SORT用法 最簡單的SORT使用方法是SORT key。 472 redis.lpush("mylist", "1"); 473 redis.lpush("mylist", "4"); 474 redis.lpush("mylist", "6"); 475 redis.lpush("mylist", "3"); 476 redis.lpush("mylist", "0"); 477 // List<String> list = redis.sort("sort");// 默認是升序 478 SortingParams sortingParameters = new SortingParams(); 479 sortingParameters.desc(); 480 // sortingParameters.alpha();//當數據集中保存的是字符串值時，你能夠用 ALPHA 481 // 修飾符(modifier)進行排序。 482 sortingParameters.limit(0, 2);// 可用於分頁查詢 483 List<String> list = redis.sort("mylist", sortingParameters);// 默認是升序 484 for (int i = 0; i < list.size(); i++) 485 { 486 System.out.println(list.get(i)); 487 } 488 redis.flushDB(); 489 RedisUtil.closeJedis(redis); 490 } 491 492 @org.junit.Test 493 /** 494 * sort list 495 * LIST結合hash的排序 496 */ 497 public void testSort2() 498 { 499 Jedis jedis = RedisUtil.getJedis(); 500 jedis.del("user:66", "user:55", "user:33", "user:22", "user:11", 501 "userlist"); 502 jedis.lpush("userlist", "33"); 503 jedis.lpush("userlist", "22"); 504 jedis.lpush("userlist", "55"); 505 jedis.lpush("userlist", "11"); 506 507 jedis.hset("user:66", "name", "66"); 508 jedis.hset("user:55", "name", "55"); 509 jedis.hset("user:33", "name", "33"); 510 jedis.hset("user:22", "name", "79"); 511 jedis.hset("user:11", "name", "24"); 512 jedis.hset("user:11", "add", "beijing"); 513 jedis.hset("user:22", "add", "shanghai"); 514 jedis.hset("user:33", "add", "guangzhou"); 515 jedis.hset("user:55", "add", "chongqing"); 516 jedis.hset("user:66", "add", "xi'an"); 517 518 SortingParams sortingParameters = new SortingParams(); 519 // 符號 "->" 用於分割哈希表的鍵名(key name)和索引域(hash field)，格式爲 "key->field" 。 520 sortingParameters.get("user:*->name"); 521 sortingParameters.get("user:*->add"); 522 //sortingParameters.by("user:*->name"); 523 //sortingParameters.get("#"); 524 List<String> result = jedis.sort("userlist", sortingParameters); 525 for (String item : result) 526 { 527 System.out.println("item...." + item); 528 } 529 /** 530 * 對應的redis客戶端命令是：sort ml get user*->name sort ml get user:*->name get 531 * user:*->add 532 */ 533 } 534 535 @org.junit.Test 536 /** 537 * sort set 538 * SET結合String的排序 539 */ 540 public void testSort3() 541 { 542 Jedis jedis = RedisUtil.getJedis(); 543 jedis.del("tom:friend:list", "score:uid:123", "score:uid:456", 544 "score:uid:789", "score:uid:101", "uid:123", "uid:456", 545 "uid:789", "uid:101"); 546 547 jedis.sadd("tom:friend:list", "123"); // tom的好友列表 548 jedis.sadd("tom:friend:list", "456"); 549 jedis.sadd("tom:friend:list", "789"); 550 jedis.sadd("tom:friend:list", "101"); 551 552 jedis.set("score:uid:123", "1000"); // 好友對應的成績 553 jedis.set("score:uid:456", "6000"); 554 jedis.set("score:uid:789", "100"); 555 jedis.set("score:uid:101", "5999"); 556 557 jedis.set("uid:123", "{'uid':123,'name':'lucy'}"); // 好友的詳細信息 558 jedis.set("uid:456", "{'uid':456,'name':'jack'}"); 559 jedis.set("uid:789", "{'uid':789,'name':'jay'}"); 560 jedis.set("uid:101", "{'uid':101,'name':'jolin'}"); 561 562 SortingParams sortingParameters = new SortingParams(); 563 564 sortingParameters.desc(); 565 // sortingParameters.limit(0, 2); 566 // 注意GET操做是有序的，GET user_name_* GET user_password_* 567 // 和 GET user_password_* GET user_name_*返回的結果位置不一樣 568 sortingParameters.get("#");// GET 還有一個特殊的規則—— "GET #" 569 // ，用於獲取被排序對象(咱們這裏的例子是 user_id )的當前元素。 570 sortingParameters.get("uid:*"); 571 sortingParameters.get("score:uid:*"); 572 sortingParameters.by("score:uid:*"); 573 // 對應的redis 命令是./redis-cli sort tom:friend:list by score:uid:* get # get 574 // uid:* get score:uid:* 575 List<String> result = jedis.sort("tom:friend:list", sortingParameters); 576 for (String item : result) 577 { 578 System.out.println("item..." + item); 579 } 580 581 } 582 583 /** 584 * 585 * 只獲取對象而不排序 BY 修飾符能夠將一個不存在的 key 看成權重，讓 SORT 跳過排序操做。 586 * 該方法用於你但願獲取外部對象而又不但願引發排序開銷時使用。 # 確保fake_key不存在 redis> EXISTS fake_key 587 * (integer) 0 # 以fake_key做BY參數，不排序，只GET name 和 GET password redis> SORT 588 * user_id BY fake_key GET # GET user_name_* GET user_password_* 1) "222" # 589 * id 2) "hacker" # user_name 3) "hey,im in" # password 4) "59230" 5) "jack" 590 * 6) "jack201022" 7) "2" 8) "huangz" 9) "nobodyknows" 10) "1" 11) "admin" 591 * 12) "a_long_long_password" 592 */ 593 public void testSort4() 594 { 595 } 596 597 /** 598 * 599 保存排序結果 默認狀況下， SORT 操做只是簡單地返回排序結果，若是你但願保存排序結果，能夠給 STORE 選項指定一個 key 600 * 做爲參數，排序結果將以列表的形式被保存到這個 key 上。(若指定 key 已存在，則覆蓋。) redis> EXISTS 601 * user_info_sorted_by_level # 確保指定key不存在 (integer) 0 redis> SORT user_id BY 602 * user_level_* GET # GET user_name_* GET user_password_* STORE 603 * user_info_sorted_by_level # 排序 (integer) 12 # 顯示有12條結果被保存了 redis> LRANGE 604 * user_info_sorted_by_level 0 11 # 查看排序結果 1) "59230" 2) "jack" 3) 605 * "jack201022" 4) "2" 5) "huangz" 6) "nobodyknows" 7) "222" 8) "hacker" 9) 606 * "hey,im in" 10) "1" 11) "admin" 12) "a_long_long_password" 一個有趣的用法是將 SORT 607 * 結果保存，用 EXPIRE 爲結果集設置生存時間，這樣結果集就成了 SORT 操做的一個緩存。 這樣就沒必要頻繁地調用 SORT 608 * 操做了，只有當結果集過時時，才須要再調用一次 SORT 操做。 609 * 有時候爲了正確實現這一用法，你可能須要加鎖以免多個客戶端同時進行緩存重建(也就是多個客戶端，同一時間進行 SORT 610 * 操做，並保存爲結果集)，具體參見 SETNX 命令。 611 */ 612 @Test 613 public void testSort5() 614 { 615 // 排序默認以數字做爲對象，值被解釋爲雙精度浮點數，而後進行比較 616 Jedis jedis = RedisUtil.getJedis(); 617 // 通常SORT用法 最簡單的SORT使用方法是SORT key。 618 jedis.lpush("mylist", "1"); 619 jedis.lpush("mylist", "4"); 620 jedis.lpush("mylist", "6"); 621 jedis.lpush("mylist", "3"); 622 jedis.lpush("mylist", "0"); 623 // List<String> list = redis.sort("sort");// 默認是升序 624 SortingParams sortingParameters = new SortingParams(); 625 sortingParameters.desc(); 626 // sortingParameters.alpha();//當數據集中保存的是字符串值時，你能夠用 ALPHA 627 // 修飾符(modifier)進行排序。 628 // sortingParameters.limit(0, 2);//可用於分頁查詢 629 630 // 沒有使用 STORE 參數，返回列表形式的排序結果. 使用 STORE 參數，返回排序結果的元素數量。 631 632 jedis.sort("mylist", sortingParameters, "mylist");// 排序後指定排序結果到一個KEY中，這裏講結果覆蓋原來的KEY 633 634 List<String> list = jedis.lrange("mylist", 0, -1); 635 for (int i = 0; i < list.size(); i++) 636 { 637 System.out.println(list.get(i)); 638 } 639 640 jedis.sadd("tom:friend:list", "123"); // tom的好友列表 641 jedis.sadd("tom:friend:list", "456"); 642 jedis.sadd("tom:friend:list", "789"); 643 jedis.sadd("tom:friend:list", "101"); 644 645 jedis.set("score:uid:123", "1000"); // 好友對應的成績 646 jedis.set("score:uid:456", "6000"); 647 jedis.set("score:uid:789", "100"); 648 jedis.set("score:uid:101", "5999"); 649 650 jedis.set("uid:123", "{'uid':123,'name':'lucy'}"); // 好友的詳細信息 651 jedis.set("uid:456", "{'uid':456,'name':'jack'}"); 652 jedis.set("uid:789", "{'uid':789,'name':'jay'}"); 653 jedis.set("uid:101", "{'uid':101,'name':'jolin'}"); 654 655 sortingParameters = new SortingParams(); 656 // sortingParameters.desc(); 657 sortingParameters.get("#");// GET 還有一個特殊的規則—— "GET #" 658 // ，用於獲取被排序對象(咱們這裏的例子是 user_id )的當前元素。 659 sortingParameters.by("score:uid:*"); 660 jedis.sort("tom:friend:list", sortingParameters, "tom:friend:list"); 661 List<String> result = jedis.lrange("tom:friend:list", 0, -1); 662 for (String item : result) 663 { 664 System.out.println("item..." + item); 665 } 666 667 jedis.flushDB(); 668 RedisUtil.closeJedis(jedis); 669 } 670 671 672 public void testMore() 673 { 674 //ZRANGE取出最新的10個項目。 675 //使用LPUSH + LTRIM，確保只取出最新的1000條項目。 676 //HINCRBY key field increment,爲哈希表 key 中的域 field 的值加上增量 increment 677 //INCRBY,HINCRBY等等，redis有了原子遞增（atomic increment），你能夠放心的加上各類計數，用GETSET重置，或者是讓它們過時。 678 // LREM greet 2 morning # 移除從表頭到表尾，最早發現的兩個 morning,這個能夠用來刪除特定評論 679 // zrevrank test a 查看a在sorted set中倒排序時排在第幾名，查詢結果按照INDEX，因此INDEX是3表示排在第四名 680 // zrank test a 相反，表示正排序時候的名次 681 // zscore test one表示one這個元素在sorted set中的score爲多少 682 // zrevrange test 0 -1 表示sorted set倒排序,zrange test 0 -1表示正排序 683 //將一個或多個 member 元素及其 score 值加入到有序集 key 當中。若是某個 member 已是有序集的成員，那麼更新這個 member 的 score 值，並經過從新插入這個 member 元素，來保證該 member 在正確的位置上。 684 //zrem test one刪除sorted set中某個元素 685 } 686 687 public List<String> get_latest_comments(int start, int num_items) 688 { 689 //獲取最新評論 690 //LPUSH latest.comments <ID> 691 //-咱們將列表裁剪爲指定長度，所以Redis只須要保存最新的5000條評論： 692 //LTRIM latest.comments 0 5000 693 //們作了限制不能超過5000個ID，所以咱們的獲取ID函數會一直詢問Redis。只有在start/count參數超出了這個範圍的時候，才須要去訪問數據庫。 694 Jedis jedis = RedisUtil.getJedis(); 695 List<String> id_list = jedis.lrange("latest.comments",start,start+num_items-1) ; 696 697 if(id_list.size()<num_items) 698 { 699 //id_list = SQL.EXECUTE("SELECT ... ORDER BY time LIMIT ..."); 700 } 701 return id_list; 702 } 703 704 705 706 @Test 707 public void testDB() 708 { 709 Jedis jedis = RedisUtil.getJedis(); 710 System.out.println(jedis.select(0));// select db-index 711 // 經過索引選擇數據庫，默認鏈接的數據庫全部是0,默認數據庫數是16個。返回1表示成功，0失敗 712 System.out.println(jedis.dbSize());// dbsize 返回當前數據庫的key數量 713 System.out.println(jedis.keys("*")); // 返回匹配指定模式的全部key 714 System.out.println(jedis.randomKey()); 715 jedis.flushDB();// 刪除當前數據庫中全部key,此方法不會失敗。慎用 716 jedis.flushAll();// 刪除全部數據庫中的全部key，此方法不會失敗。更加慎用 717 } 718 719 @Test 720 public void testMget() 721 { 722 Jedis jedis = RedisUtil.getJedis(); 723 jedis.flushDB();// 刪除當前數據庫中全部key,此方法不會失敗。慎用 724 725 jedis.rpush("ids", "aa"); 726 jedis.rpush("ids", "bb"); 727 jedis.rpush("ids", "cc"); 728 729 List<String> ids = jedis.lrange("ids", 0, -1); 730 731 jedis.set("aa", "{'name':'zhoujie','age':20}"); 732 jedis.set("bb", "{'name':'yilin','age':28}"); 733 jedis.set("cc", "{'name':'lucy','age':21}"); 734 List<String> list = jedis.mget(ids.toArray(new String[ids.size()])); 735 System.out.println(list); 736 } 737 738 /** 739 * 能夠利用lrange對list進行分頁操做 740 */ 741 @Test 742 public void queryPageBy() 743 { 744 int pageNo = 6; 745 int pageSize = 6; 746 Jedis jedis = RedisUtil.getJedis(); 747 jedis.del("a"); 748 for (int i = 1; i <= 30; i++) 749 { 750 jedis.rpush("a", i + ""); 751 } 752 753 int start = pageSize * (pageNo - 1);// 由於redis中list元素位置基數是0 754 int end = start + pageSize - 1; 755 756 List<String> results = jedis.lrange("a", start, end);// 從start算起，start算一個元素，到結束那個元素 757 for (String str : results) 758 { 759 System.out.println(str); 760 } 761 762 } 763 764 @Test 765 /** 766 * [向Redis list壓入ID而不是實際的數據] 767 在上面的例子裏 ，咱們將「對象」（此例中是簡單消息）直接壓入Redis list，但一般不該這麼作， 768 因爲對象可能被屢次引用：例如在一個list中維護其時間順序，在一個集合中保存它的類別，只要有必要，它還會出如今其餘list中，等等。 769 讓咱們回到reddit.com的例子，將用戶提交的連接（新聞）添加到list中，有更可靠的方法以下所示： 770 $ redis-cli incr next.news.id 771 (integer) 1 772 $ redis-cli set news:1:title "Redis is simple" 773 OK 774 $ redis-cli set news:1:url "http://code.google.com/p/redis" 775 OK 776 $ redis-cli lpush submitted.news 1 777 OK 778 咱們自增一個key，很容易獲得一個獨一無二的自增ID，而後經過此ID建立對象–爲對象的每一個字段設置一個key。最後將新對象的ID壓入submitted.news list。 779 這只是牛刀小試。在命令參考文檔中能夠讀到全部和list有關的命令。你能夠刪除元素，旋轉list，根據索引獲取和設置元素，固然也能夠用LLEN獲得list的長度。 780 */ 781 public void testListStrUsage() 782 { 783 String title = "太陽能是綠色能源4"; 784 String url = "http://javacreazyer.iteye.com"; 785 Jedis jedis = RedisUtil.getJedis(); 786 787 long adInfoId = jedis.incr("ad:adinfo:next.id"); 788 jedis.set("ad:adinfo:" + adInfoId + ":title", title); 789 jedis.set("ad:adinfo:" + adInfoId + ":url", url); 790 jedis.lpush("ad:adinfo", String.valueOf(adInfoId)); 791 792 String resultTitle = jedis.get("ad:adinfo:" + adInfoId + ":title"); 793 String resultUrl = jedis.get("ad:adinfo:" + adInfoId + ":url"); 794 List<String> ids = jedis.lrange("ad:adinfo", 0, -1); 795 System.out.println(resultTitle); 796 System.out.println(resultUrl); 797 System.out.println(ids); 798 799 /** 800 * dbsize返回的是全部key的數目，包括已通過期的， 而redis-cli keys "*"查詢獲得的是有效的key數目 801 */ 802 System.out.println(jedis.dbSize()); 803 804 jedis.flushAll(); 805 } 806 807 /** 808 * 下面是一個簡單的方案：對每一個想加標籤的對象，用一個標籤ID集合與之關聯，而且對每一個已有的標籤，一組對象ID與之關聯。 例如假設咱們的新聞ID 809 * 1000被加了三個標籤tag 1,2,5和77，就能夠設置下面兩個集合： $ redis-cli sadd news:1000:tags 1 810 * (integer) 1 $ redis-cli sadd news:1000:tags 2 (integer) 1 $ redis-cli 811 * sadd news:1000:tags 5 (integer) 1 $ redis-cli sadd news:1000:tags 77 812 * (integer) 1 $ redis-cli sadd tag:1:objects 1000 (integer) 1 $ redis-cli 813 * sadd tag:2:objects 1000 (integer) 1 $ redis-cli sadd tag:5:objects 1000 814 * (integer) 1 $ redis-cli sadd tag:77:objects 1000 (integer) 1 815 * 要獲取一個對象的全部標籤，如此簡單： $ redis-cli smembers news:1000:tags 1. 5 2. 1 3. 77 4. 816 * 2 而有些看上去並不簡單的操做仍然能使用相應的Redis命令輕鬆實現。例如咱們也許想得到一份同時擁有標籤1, 2, 817 * 10和27的對象列表。這能夠用SINTER命令來作，他能夠在不一樣集合之間取出交集。所以爲達目的咱們只需： $ redis-cli sinter 818 * tag:1:objects tag:2:objects tag:10:objects tag:27:objects ... no result 819 * in our dataset composed of just one object ... 820 * 在命令參考文檔中能夠找到和集合相關的其餘命令，使人感興趣的一抓一大把。必定要留意SORT命令，Redis集合和list都是可排序的。 821 */ 822 @Test 823 public void testSetUsage() 824 { 825 Jedis jedis = RedisUtil.getJedis(); 826 jedis.sadd("zhongsou:news:1000:tags", "1"); 827 jedis.sadd("zhongsou:news:1000:tags", "2"); 828 jedis.sadd("zhongsou:news:1000:tags", "5"); 829 jedis.sadd("zhongsou:news:1000:tags", "77"); 830 jedis.sadd("zhongsou:news:2000:tags", "1"); 831 jedis.sadd("zhongsou:news:2000:tags", "2"); 832 jedis.sadd("zhongsou:news:2000:tags", "5"); 833 jedis.sadd("zhongsou:news:2000:tags", "77"); 834 jedis.sadd("zhongsou:news:3000:tags", "2"); 835 jedis.sadd("zhongsou:news:4000:tags", "77"); 836 jedis.sadd("zhongsou:news:5000:tags", "1"); 837 jedis.sadd("zhongsou:news:6000:tags", "5"); 838 839 jedis.sadd("zhongsou:tag:1:objects", 1000 + ""); 840 jedis.sadd("zhongsou:tag:2:objects", 1000 + ""); 841 jedis.sadd("zhongsou:tag:5:objects", 1000 + ""); 842 jedis.sadd("zhongsou:tag:77:objects", 1000 + ""); 843 844 jedis.sadd("zhongsou:tag:1:objects", 2000 + ""); 845 jedis.sadd("zhongsou:tag:2:objects", 2000 + ""); 846 jedis.sadd("zhongsou:tag:5:objects", 2000 + ""); 847 jedis.sadd("zhongsou:tag:77:objects", 2000 + ""); 848 849 Set<String> sets = jedis.sinter("zhongsou:tag:1:objects", 850 "zhongsou:tag:2:objects", "zhongsou:tag:5:objects", 851 "zhongsou:tag:77:objects"); 852 System.out.println(sets); 853 jedis.flushAll(); 854 } 855 856 @Test 857 public void testSortedSetUsage() 858 { 859 Jedis jedis = RedisUtil.getJedis(); 860 jedis.zadd("zhongsou:hackers", 1940, "Alan Kay"); 861 jedis.zadd("zhongsou:hackers", 1953, "Richard Stallman"); 862 jedis.zadd("zhongsou:hackers", 1943, "Jay"); 863 jedis.zadd("zhongsou:hackers", 1920, "Jellon"); 864 jedis.zadd("zhongsou:hackers", 1965, "Yukihiro Matsumoto"); 865 jedis.zadd("zhongsou:hackers", 1916, "Claude Shannon"); 866 jedis.zadd("zhongsou:hackers", 1969, "Linus Torvalds"); 867 jedis.zadd("zhongsou:hackers", 1912, "Alan Turing"); 868 869 Set<String> hackers = jedis.zrange("zhongsou:hackers", 0, -1); 870 System.out.println(hackers); 871 872 Set<String> hackers2 = jedis.zrevrange("zhongsou:hackers", 0, -1); 873 System.out.println(hackers2); 874 875 // 區間操做,咱們請求Redis返回score介於負無窮到1920年之間的元素（兩個極值也包含了）。 876 Set<String> hackers3 = jedis.zrangeByScore("zhongsou:hackers", "-inf", 877 "1920"); 878 System.out.println(hackers3); 879 880 // ZREMRANGEBYSCORE 這個名字雖然不算好，但他卻很是有用，還會返回已刪除的元素數量。 881 long num = jedis.zremrangeByScore("zhongsou:hackers", "-inf", "1920"); 882 System.out.println(num); 883 884 jedis.flushAll(); 885 } 886 887 }
1 /** 2 * 獲取鏈接池. 3 * @return 鏈接池實例 4 */ 5 private static JedisPool getPool(String ip,int port) 6 { 7 JedisPoolConfig config = new JedisPoolConfig(); 8 config.setMaxActive(RedisConfig.getMaxactive()); 9 config.setMaxIdle(RedisConfig.getMaxidle()); 10 config.setMaxWait(RedisConfig.getMaxwait()); 11 config.setTestOnBorrow(true); 12 config.setTestOnReturn(true); 13 try{ 14 /** 15 *若是你遇到 java.net.SocketTimeoutException: Read timed out exception的異常信息 16 *請嘗試在構造JedisPool的時候設置本身的超時值. JedisPool默認的超時時間是2秒(單位毫秒) 17 */ 18 pool = new JedisPool(config, ip, port,RedisConfig.getTimeout()); 19 } catch(Exception e) { 20 e.printStackTrace(); 21 } 22 return pool; 23 }
1 package com.zhongsou.vertportal.util; 2 3 import java.util.HashMap; 4 import java.util.Map; 5 6 import org.slf4j.Logger; 7 import org.slf4j.LoggerFactory; 8 9 import redis.clients.jedis.Jedis; 10 import redis.clients.jedis.JedisPool; 11 import redis.clients.jedis.JedisPoolConfig; 12 13 import com.zhongsou.vertportal.conf.BaseConfig; 14 import com.zhongsou.vertportal.conf.RedisConfig; 15 16 /** 17 * Redis工具類,用於獲取RedisPool. 18 * 參考官網說明以下： 19 * You shouldn't use the same instance from different threads because you'll have strange errors. 20 * And sometimes creating lots of Jedis instances is not good enough because it means lots of sockets and connections, 21 * which leads to strange errors as well. A single Jedis instance is not threadsafe! 22 * To avoid these problems, you should use JedisPool, which is a threadsafe pool of network connections. 23 * This way you can overcome those strange errors and achieve great performance. 24 * To use it, init a pool: 25 * JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost"); 26 * You can store the pool somewhere statically, it is thread-safe. 27 * JedisPoolConfig includes a number of helpful Redis-specific connection pooling defaults. 28 * For example, Jedis with JedisPoolConfig will close a connection after 300 seconds if it has not been returned. 29 * @author wujintao 30 */ 31 public class JedisUtil 32 { 33 protected Logger log = LoggerFactory.getLogger(getClass()); 34 35 /** 36 * 私有構造器. 37 */ 38 private JedisUtil() 39 { 40 41 } 42 private static Map<String,JedisPool> maps = new HashMap<String,JedisPool>(); 43 44 45 /** 46 * 獲取鏈接池. 47 * @return 鏈接池實例 48 */ 49 private static JedisPool getPool(String ip,int port) 50 { 51 String key = ip+":" +port; 52 JedisPool pool = null; 53 if(!maps.containsKey(key)) 54 { 55 JedisPoolConfig config = new JedisPoolConfig(); 56 config.setMaxActive(RedisConfig.getMaxactive()); 57 config.setMaxIdle(RedisConfig.getMaxidle()); 58 config.setMaxWait(RedisConfig.getMaxwait()); 59 config.setTestOnBorrow(true); 60 config.setTestOnReturn(true); 61 try 62 { 63 /** 64 *若是你遇到 java.net.SocketTimeoutException: Read timed out exception的異常信息 65 *請嘗試在構造JedisPool的時候設置本身的超時值. JedisPool默認的超時時間是2秒(單位毫秒) 66 */ 67 pool = new JedisPool(config, ip, port,RedisConfig.getTimeout()); 68 maps.put(key, pool); 69 } 70 catch(Exception e) 71 { 72 e.printStackTrace(); 73 } 74 } 75 else 76 { 77 pool = maps.get(key); 78 } 79 return pool; 80 } 81 82 /** 83 *類級的內部類，也就是靜態的成員式內部類，該內部類的實例與外部類的實例 84 *沒有綁定關係，並且只有被調用到時纔會裝載，從而實現了延遲加載。 85 */ 86 private static class RedisUtilHolder 87 { 88 /** 89 * 靜態初始化器，由JVM來保證線程安全 90 */ 91 private static JedisUtil instance = new JedisUtil(); 92 } 93 94 /** 95 *當getInstance方法第一次被調用的時候，它第一次讀取 96 *RedisUtilHolder.instance，致使RedisUtilHolder類獲得初始化；而這個類在裝載並被初始化的時候，會初始化它的靜 97 *態域，從而建立RedisUtil的實例，因爲是靜態的域，所以只會在虛擬機裝載類的時候初始化一次，並由虛擬機來保證它的線程安全性。 98 *這個模式的優點在於，getInstance方法並無被同步，而且只是執行一個域的訪問，所以延遲初始化並無增長任何訪問成本。 99 */ 100 public static JedisUtil getInstance() 101 { 102 return RedisUtilHolder.instance; 103 } 104 105 /** 106 * 獲取Redis實例. 107 * @return Redis工具類實例 108 */ 109 public Jedis getJedis(String ip,int port) 110 { 111 Jedis jedis = null; 112 int count =0; 113 do 114 { 115 try 116 { 117 jedis = getPool(ip,port).getResource(); 118 //log.info("get redis master1!"); 119 } 120 catch (Exception e) 121 { 122 log.error("get redis master1 failed!", e); 123 // 銷燬對象 124 getPool(ip,port).returnBrokenResource(jedis); 125 } 126 count++; 127 } 128 while(jedis==null&&count<BaseConfig.getRetryNum()); 129 return jedis; 130 } 131 132 /** 133 * 釋放redis實例到鏈接池. 134 * @param jedis redis實例 135 */ 136 public void closeJedis(Jedis jedis,String ip,int port) 137 { 138 if(jedis != null) 139 { 140 getPool(ip,port).returnResource(jedis); 141 } 142 } 143 }
開發參考資料：html
redis官方文檔：http://redis.io/documentationjava
redis命令參考中文版：http://redis.readthedocs.org/en/2.4/index.htmlredis
相關文章
- 1. 【Redis】使用Jedis操做Redis
- 2. 使用jedis操做redis
- 3. 使用 Jedis操做Redis
- 4. 使用Jedis操做Redis
- 5. 使用Jedis操做redis
- 6. Java中使用Jedis操做Redis
- 7. java中使用Jedis操做Redis實例
- 8. 【轉載】Java中使用Jedis操做Redis
- 9. JAVA中使用Jedis操做Redis
- 10. Redis之java操做篇（Jedis）
- 更多相關文章...
- • 在Java程序中使用Redis - Redis教程
- • 在Spring中使用Redis - Redis教程
- • Java Agent入門實戰（一）-Instrumentation介紹與使用
- • Java Agent入門實戰（三）-JVM Attach原理與使用
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
