redis clients lettuce2 lettuce2_zsets

Lettuce ZSets

레디스 개발자 교육 신청	레디스 정기점검/기술지원 Redis Technical Support	레디스 엔터프라이즈 서버 Redis Enterprise Server

Lettuce ZSets

Java Lettuce를 사용한 레디스 정렬셋(ZSets) 명령 사용법입니다.

ZSets 소스

Redis4_ZSet.java
package com.redisgate.redis; import io.lettuce.core.*; import io.lettuce.core.api.async.RedisAsyncCommands; import io.lettuce.core.api.sync.RedisCommands; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import java.util.*; @RestController @Slf4j public class Redis4_ZSet { private final RedisCommands<String, String> redisCommands; private final RedisAsyncCommands<String, String> redisAsyncCommands; public Redis4_ZSet(RedisConfig redisConfig) { redisCommands = redisConfig.getRedisSyncCommands(); redisAsyncCommands = redisConfig.getRedisAsyncCommands(); // BZPOPMIN, BZPOPMAX } // 예제 1) ZADD: 집합에 데이터를 스코어와 함께 추가 // ZADD key [NX|XX] [GT|LT] [CH] [INCR] score member [score member ...] // http://localhost:8080/zadd/zset1 @GetMapping("/zadd/{key}") @SuppressWarnings("unchecked") public String zadd(@PathVariable("key") String key) { String msg = "예제 1) ZADD -> "; System.out.println(msg); Long result = 0L; result = redisCommands.zadd(key,1d,"user01"); // 추가된 맴버수를 리턴 System.out.println("ZADD 1 user01 -> "+result); result = redisCommands.zadd(key,2d,"user02",3d,"user03"); System.out.println("ZADD 2 user02 3 user03 -> "+result); redisCommands.zadd(key,ScoredValue.just(4d,"user04")); redisCommands.zadd(key,ScoredValue.just(5d,"user05")); redisCommands.zadd(key,ScoredValue.just(6d,"user06")); System.out.println("ZADD 4 user04"); System.out.println("ZADD 5 user05"); System.out.println("ZADD 6 user06"); // nx 옵션: 해당 맴버가 기존에 없을 경우에만 추가한다. // 대기열에 이미 있는지 확인 ZAddArgs args = ZAddArgs.Builder.nx(); result = redisCommands.zadd(key,args,4d,"user04"); System.out.println("ZADD NX user4 -> "+result); result = redisCommands.zadd(key,args,7d,"user07"); System.out.println("ZADD NX user7 -> "+result); // (대기열) 순서 조회 result = redisCommands.zrank(key,"user04"); System.out.println("user04 rank -> "+result); // 스코어를 현재 시작(millisecond)로 입력 result = redisCommands.zadd(key, System.currentTimeMillis(),"user08"); System.out.println("ZADD user08 -> "+result); result = redisCommands.zadd(key, System.currentTimeMillis(),"user09"); System.out.println("ZADD user09 -> "+result); // 테스트 데이터 입력 for (int i=10; i<=30; i++) { redisCommands.zadd(key,i,"user"+String.format("%02d",i)); } msg += result; return msg; } // 예제 2) ZCARD: 멤버 개수 조회 // ZCARD key // http://localhost:8080/zcard/zset1 @GetMapping("/zcard/{key}") public String zcard(@PathVariable("key") String key) { String msg = "예제 2) ZCARD -> "; Long result = redisCommands.zcard(key); msg += result; System.out.println(msg); return msg; } // 예제 3) ZRANGE: 멤버 리스트 조회(스코어 작은것 부터) // ZRANGE key start stop [REV] [[BYSCORE|BYLEX] [LIMIT offset count]] [withscores] // http://localhost:8080/zrange/zset1 @GetMapping("/zrange/{key}") public String zrange(@PathVariable("key") String key) { String msg = "예제 3) ZRANGE -> "; // 멤버 조회 List<String> result = redisCommands.zrange(key,0,-1); System.out.println(msg+result.toString()); // 멤버와 스코어 조회 List<ScoredValue<String>> result2 = redisCommands.zrangeWithScores(key,0,-1); for (ScoredValue<String> member: result2) { System.out.println(member.getValue()+" "+member.getScore()); } msg += result2.size(); System.out.println(msg); return msg; } // 예제 4) ZREVRANGE: 멤버 리스트 조회(스코어 큰것 부터) // ZREVRANGE key start stop [withscores] // http://localhost:8080/zrevrange/zset1 @GetMapping("/zrevrange/{key}") public String zrevrange(@PathVariable("key") String key) { String msg = "예제 4) ZREVRANGE -> "; // 멤버 조회 List<String> result = redisCommands.zrevrange(key,0,-1); System.out.println(msg+result.toString()); // 멤버와 스코어 조회 List<ScoredValue<String>> result2 = redisCommands.zrevrangeWithScores(key,0,-1); for (ScoredValue<String> member: result2) { System.out.println(member.getValue()+" "+member.getScore()); } msg += result2.size(); System.out.println(msg); return msg; } // 예제 5) ZRANGEBYSCORE: 스코어로 범위를 지정해서 조회 // ZRANGEBYSCORE key min max [withscores] [limit offset count] // http://localhost:8080/zrangebyscore/zset1 @GetMapping("/zrangebyscore/{key}") public String zrangebyscore(@PathVariable("key") String key) { String msg = "예제 5) ZRANGEBYSCORE -> "; System.out.println(msg); // 멤버 전체 조회 List<String> result = redisCommands.zrangebyscore(key, Range.unbounded()); System.out.println("모두 -> "+result.toString()); // 범위 지정 조회 (스코어 2, 5 포함) Range<Double> range = Range.create(2d,5d); List<String> result2 = redisCommands.zrangebyscore(key, range ); System.out.println("2,5 포함 -> "+result2.toString()); // 범위 지정 조회 (스코어 2, 5 제외) Range<Double> range2 = Range.from(Range.Boundary.excluding(2d),Range.Boundary.excluding(5d)); List<String> result3 = redisCommands.zrangebyscore(key,range2); System.out.println("2,5 제외 -> "+result3.toString()); // 멤버와 스코어 조회 List<ScoredValue<String>> result4 = redisCommands.zrangebyscoreWithScores(key, range); System.out.println("2,5 포함(with score)"); for (ScoredValue<String> member: result4) { System.out.println(member.getValue()+" "+member.getScore()); } msg += result4.size(); System.out.println(msg); return msg; } // 예제 6) ZRANGEBYLEX: 멤버로 범위를 지정해서 조회(스코어가 모두 0인 경우) // ZRANGEBYLEX key min max [limit offset count] // http://localhost:8080/zrangebylex/zset2 @GetMapping("/zrangebylex/{key}") public String zrangebylex(@PathVariable("key") String key) { String msg = "예제 6) ZRANGEBYLEX -> "; // 스코어가 0인 테스트 데이터 필요: 데이터가 없을 경우만 입력 Long card = redisCommands.zcard(key); if (card == 0) { for (int i=0; i<10; i++) { redisCommands.zadd(key,0d,"member"+String.format("%02d",i)); } } // 범위 지정 Range<String> range = Range.create("member03","member05"); // 데이터 조회 List<String> result = redisCommands.zrangebylex(key, range); msg += result.toString(); System.out.println(msg); return msg; } // 예제 7) ZCOUNT: 스코어로 범위를 지정해서 개수 조회 // ZCOUNT key min max // http://localhost:8080/zcount/zset1 @GetMapping("/zcount/{key}") public String zcount(@PathVariable("key") String key) { String msg = "예제 7) ZCOUNT -> "; Range<Double> range = Range.create(2d,5d); Long result = redisCommands.zcount(key, range); msg += result; System.out.println(msg); return msg; } // 예제 8) ZRANK: 순서(index) 조회, 0부터 시작. // ZRANK key member // http://localhost:8080/zrank/zset1 @GetMapping("/zrank/{key}") public String zrank(@PathVariable("key") String key) { String msg = "예제 8) ZRANK -> "; Long result = redisCommands.zrank(key,"user04"); msg += result; System.out.println(msg); return msg; } // 예제 9) ZREM: 멤버 삭제 // ZREM key member [member] // http://localhost:8080/zrem/zset1 @GetMapping("/zrem/{key}") public String zrem(@PathVariable("key") String key) { String msg = "예제 9) ZREM -> "; Long result = redisCommands.zrem(key, "user04"); msg += result; System.out.println(msg); return msg; } // 예제 10) ZPOPMIN: 스코어가 작은 멤버부터 꺼내온다. // ZPOPMIN key [count], ZPOPMAX key [count] // http://localhost:8080/zpopmin/zset1 @GetMapping("/zpopmin/{key}") public String zpopmin(@PathVariable("key") String key) { String msg = "예제 10) ZPOPMIN -> "; ScoredValue<String> result = redisCommands.zpopmin(key); msg += (result.getValue()+" "+result.getScore()); System.out.println(msg); return msg; } // 예제 11) BZPOPMIN: 데이터가 들어오면 스코어가 작은 멤버부터 꺼내온다. Async 사용. // BZPOPMIN key [key ...] timeout, BZPOPMAX key [key ...] timeout // http://localhost:8080/bzpopmin/zset1 @GetMapping("/bzpopmin/{key}") public String bzpopmin(@PathVariable("key") String key) { String msg = "예제 11) BZPOPMIN -> "; RedisFuture<KeyValue<String, ScoredValue<String>>> future = redisAsyncCommands.bzpopmin(0, key); try { // future.get().getKey(); key // future.get().getValue().getValue(); member // future.get().getValue().getScore(); score String result = future.get().getKey()+" "+future.get().getValue().getValue()+" "+future.get().getValue().getScore(); msg += result; System.out.println(msg); return msg; } catch (Exception e) { log.info("Error -> "+e.getMessage()); } msg += "Error"; System.out.println(msg); return msg; } // 예제 12) ZREMRANGEBYRANK: 순서(index) 범위로 멤버 삭제 // ZREMRANGEBYRANK key start stop // http://localhost:8080/zremrangebyrank/zset1 @GetMapping("/zremrangebyrank/{key}") public String zremrangebyrank(@PathVariable("key") String key) { String msg = "예제 12) ZREMRANGEBYRANK -> "; Long result = redisCommands.zremrangebyrank(key, 2,5); msg += result; System.out.println(msg); return msg; } // 예제 13) ZINCRBY: 조회수 증가, 좋아요 수 증가/감소, 상품A가 장바구니에 담긴 회수 // ZINCRBY key increment member // http://localhost:8080/zincrby/zset1 @GetMapping("/zincrby/{key}") public String zincrby(@PathVariable("key") String key) { String msg = "예제 13) ZINCRBY -> "; System.out.println(msg); Double result; result = redisCommands.zincrby(key, 1,"user90"); System.out.println(result); result = redisCommands.zincrby(key, 1,"user90"); System.out.println(result); result = redisCommands.zincrby(key, 1,"user90"); System.out.println(result); return msg+result; } // 예제 14) ZSCAN: 조회 // ZSCAN key cursor [MATCH pattern] [COUNT count] // http://localhost:8080/zscan/zset1 @GetMapping("/zscan/{key}") public String zscan(@PathVariable("key") String key) { String msg = "예제 14) ZSCAN -> "; int size = 0; // member 개수 // Cursor 설정 ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 // COUNT(limit)와 MATCH(pattern) 설정 String pattern = "*"; ScanArgs args = ScanArgs.Builder.limit(20).match(pattern); ScoredValueScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.zscan(key,cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; size += result.getValues().size(); for (ScoredValue<String> value: result.getValues()) { // 키 System.out.println(" "+ (i++) +") "+value.getScore()+" "+value.getValue()); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 msg += size; // member 개수 System.out.println(msg); return msg; } }

각 명령(메서드) 별 표시

ZADD

// 예제 1) ZADD: 집합에 데이터를 스코어와 함께 추가 // ZADD key [NX|XX] [GT|LT] [CH] [INCR] score member [score member ...] // http://localhost:8080/zadd/zset1 @GetMapping("/zadd/{key}") @SuppressWarnings("unchecked") public String zadd(@PathVariable("key") String key) { String msg = "예제 1) ZADD -> "; System.out.println(msg); Long result = 0L; result = redisCommands.zadd(key,1d,"user01"); // 추가된 맴버수를 리턴 System.out.println("ZADD 1 user01 -> "+result); result = redisCommands.zadd(key,2d,"user02",3d,"user03"); System.out.println("ZADD 2 user02 3 user03 -> "+result); redisCommands.zadd(key,ScoredValue.just(4d,"user04")); redisCommands.zadd(key,ScoredValue.just(5d,"user05")); redisCommands.zadd(key,ScoredValue.just(6d,"user06")); System.out.println("ZADD 4 user04"); System.out.println("ZADD 5 user05"); System.out.println("ZADD 6 user06"); // nx 옵션: 해당 맴버가 기존에 없을 경우에만 추가한다. // 대기열에 이미 있는지 확인 ZAddArgs args = ZAddArgs.Builder.nx(); result = redisCommands.zadd(key,args,4d,"user04"); System.out.println("ZADD NX user4 -> "+result); result = redisCommands.zadd(key,args,7d,"user07"); System.out.println("ZADD NX user7 -> "+result); // (대기열) 순서 조회 result = redisCommands.zrank(key,"user04"); System.out.println("user04 rank -> "+result); // 스코어를 현재 시작(millisecond)로 입력 result = redisCommands.zadd(key, System.currentTimeMillis(),"user08"); System.out.println("ZADD user08 -> "+result); result = redisCommands.zadd(key, System.currentTimeMillis(),"user09"); System.out.println("ZADD user09 -> "+result); // 테스트 데이터 입력 for (int i=10; i<=30; i++) { redisCommands.zadd(key,i,"user"+String.format("%02d",i)); } msg += result; return msg; }

ZREM

// 예제 9) ZREM: 멤버 삭제 // ZREM key member [member] // http://localhost:8080/zrem/zset1 @GetMapping("/zrem/{key}") public String zrem(@PathVariable("key") String key) { String msg = "예제 9) ZREM -> "; Long result = redisCommands.zrem(key, "user04"); msg += result; System.out.println(msg); return msg; }

ZRANGE

// 예제 3) ZRANGE: 멤버 리스트 조회(스코어 작은것 부터) // ZRANGE key start stop [REV] [[BYSCORE|BYLEX] [LIMIT offset count]] [withscores] // http://localhost:8080/zrange/zset1 @GetMapping("/zrange/{key}") public String zrange(@PathVariable("key") String key) { String msg = "예제 3) ZRANGE -> "; // 멤버 조회 List<String> result = redisCommands.zrange(key,0,-1); System.out.println(msg+result.toString()); // 멤버와 스코어 조회 List<ScoredValue<String>> result2 = redisCommands.zrangeWithScores(key,0,-1); for (ScoredValue<String> member: result2) { System.out.println(member.getValue()+" "+member.getScore()); } msg += result2.size(); System.out.println(msg); return msg; }

ZCARD

// 예제 2) ZCARD: 멤버 개수 조회 // ZCARD key // http://localhost:8080/zcard/zset1 @GetMapping("/zcard/{key}") public String zcard(@PathVariable("key") String key) { String msg = "예제 2) ZCARD -> "; Long result = redisCommands.zcard(key); msg += result; System.out.println(msg); return msg; }

ZCOUNT

// 예제 7) ZCOUNT: 스코어로 범위를 지정해서 개수 조회 // ZCOUNT key min max // http://localhost:8080/zcount/zset1 @GetMapping("/zcount/{key}") public String zcount(@PathVariable("key") String key) { String msg = "예제 7) ZCOUNT -> "; Range<Double> range = Range.create(2d,5d); Long result = redisCommands.zcount(key, range); msg += result; System.out.println(msg); return msg; }

ZRANGEBYSCORE

// 예제 5) ZRANGEBYSCORE: 스코어로 범위를 지정해서 조회 // ZRANGEBYSCORE key min max [withscores] [limit offset count] // http://localhost:8080/zrangebyscore/zset1 @GetMapping("/zrangebyscore/{key}") public String zrangebyscore(@PathVariable("key") String key) { String msg = "예제 5) ZRANGEBYSCORE -> "; System.out.println(msg); // 멤버 전체 조회 List<String> result = redisCommands.zrangebyscore(key, Range.unbounded()); System.out.println("모두 -> "+result.toString()); // 범위 지정 조회 (스코어 2, 5 포함) Range<Double> range = Range.create(2d,5d); List<String> result2 = redisCommands.zrangebyscore(key, range ); System.out.println("2,5 포함 -> "+result2.toString()); // 범위 지정 조회 (스코어 2, 5 제외) Range<Double> range2 = Range.from(Range.Boundary.excluding(2d),Range.Boundary.excluding(5d)); List<String> result3 = redisCommands.zrangebyscore(key,range2); System.out.println("2,5 제외 -> "+result3.toString()); // 멤버와 스코어 조회 List<ScoredValue<String>> result4 = redisCommands.zrangebyscoreWithScores(key, range); System.out.println("2,5 포함(with score)"); for (ScoredValue<String> member: result4) { System.out.println(member.getValue()+" "+member.getScore()); } msg += result4.size(); System.out.println(msg); return msg; }

ZRANGEBYLEX

// 예제 6) ZRANGEBYLEX: 멤버로 범위를 지정해서 조회(스코어가 모두 0인 경우) // ZRANGEBYLEX key min max [limit offset count] // http://localhost:8080/zrangebylex/zset2 @GetMapping("/zrangebylex/{key}") public String zrangebylex(@PathVariable("key") String key) { String msg = "예제 6) ZRANGEBYLEX -> "; // 스코어가 0인 테스트 데이터 필요: 데이터가 없을 경우만 입력 Long card = redisCommands.zcard(key); if (card == 0) { for (int i=0; i<10; i++) { redisCommands.zadd(key,0d,"member"+String.format("%02d",i)); } } // 범위 지정 Range<String> range = Range.create("member03","member05"); // 데이터 조회 List<String> result = redisCommands.zrangebylex(key, range); msg += result.toString(); System.out.println(msg); return msg; }

ZREMRANGEBYRANK

// 예제 12) ZREMRANGEBYRANK: 순서(index) 범위로 멤버 삭제 // ZREMRANGEBYRANK key start stop // http://localhost:8080/zremrangebyrank/zset1 @GetMapping("/zremrangebyrank/{key}") public String zremrangebyrank(@PathVariable("key") String key) { String msg = "예제 12) ZREMRANGEBYRANK -> "; Long result = redisCommands.zremrangebyrank(key, 2,5); msg += result; System.out.println(msg); return msg; }

ZREVRANGE

// 예제 4) ZREVRANGE: 멤버 리스트 조회(스코어 큰것 부터) // ZREVRANGE key start stop [withscores] // http://localhost:8080/zrevrange/zset1 @GetMapping("/zrevrange/{key}") public String zrevrange(@PathVariable("key") String key) { String msg = "예제 4) ZREVRANGE -> "; // 멤버 조회 List<String> result = redisCommands.zrevrange(key,0,-1); System.out.println(msg+result.toString()); // 멤버와 스코어 조회 List<ScoredValue<String>> result2 = redisCommands.zrevrangeWithScores(key,0,-1); for (ScoredValue<String> member: result2) { System.out.println(member.getValue()+" "+member.getScore()); } msg += result2.size(); System.out.println(msg); return msg; }

ZRANK

// 예제 8) ZRANK: 순서(index) 조회, 0부터 시작. // ZRANK key member // http://localhost:8080/zrank/zset1 @GetMapping("/zrank/{key}") public String zrank(@PathVariable("key") String key) { String msg = "예제 8) ZRANK -> "; Long result = redisCommands.zrank(key,"user04"); msg += result; System.out.println(msg); return msg; }

ZINCRBY

// 예제 13) ZINCRBY: 조회수 증가, 좋아요 수 증가/감소, 상품A가 장바구니에 담긴 회수 // ZINCRBY key increment member // http://localhost:8080/zincrby/zset1 @GetMapping("/zincrby/{key}") public String zincrby(@PathVariable("key") String key) { String msg = "예제 13) ZINCRBY -> "; System.out.println(msg); Double result; result = redisCommands.zincrby(key, 1,"user90"); System.out.println(result); result = redisCommands.zincrby(key, 1,"user90"); System.out.println(result); result = redisCommands.zincrby(key, 1,"user90"); System.out.println(result); return msg+result; }

ZPOPMIN

// 예제 10) ZPOPMIN: 스코어가 작은 멤버부터 꺼내온다. // ZPOPMIN key [count], ZPOPMAX key [count] // http://localhost:8080/zpopmin/zset1 @GetMapping("/zpopmin/{key}") public String zpopmin(@PathVariable("key") String key) { String msg = "예제 10) ZPOPMIN -> "; ScoredValue<String> result = redisCommands.zpopmin(key); msg += (result.getValue()+" "+result.getScore()); System.out.println(msg); return msg; }

BZPOPMIN

// 예제 11) BZPOPMIN: 데이터가 들어오면 스코어가 작은 멤버부터 꺼내온다. Async 사용. // BZPOPMIN key [key ...] timeout, BZPOPMAX key [key ...] timeout // http://localhost:8080/bzpopmin/zset1 @GetMapping("/bzpopmin/{key}") public String bzpopmin(@PathVariable("key") String key) { String msg = "예제 11) BZPOPMIN -> "; RedisFuture<KeyValue<String, ScoredValue<String>>> future = redisAsyncCommands.bzpopmin(0, key); try { // future.get().getKey(); key // future.get().getValue().getValue(); member // future.get().getValue().getScore(); score String result = future.get().getKey()+" "+future.get().getValue().getValue()+" "+future.get().getValue().getScore(); msg += result; System.out.println(msg); return msg; } catch (Exception e) { log.info("Error -> "+e.getMessage()); } msg += "Error"; System.out.println(msg); return msg; }

ZSCAN

// 예제 14) ZSCAN: 조회 // ZSCAN key cursor [MATCH pattern] [COUNT count] // http://localhost:8080/zscan/zset1 @GetMapping("/zscan/{key}") public String zscan(@PathVariable("key") String key) { String msg = "예제 14) ZSCAN -> "; int size = 0; // member 개수 // Cursor 설정 ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 // COUNT(limit)와 MATCH(pattern) 설정 String pattern = "*"; ScanArgs args = ScanArgs.Builder.limit(20).match(pattern); ScoredValueScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.zscan(key,cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; size += result.getValues().size(); for (ScoredValue<String> value: result.getValues()) { // 키 System.out.println(" "+ (i++) +") "+value.getScore()+" "+value.getValue()); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 msg += size; // member 개수 System.out.println(msg); return msg; }