redis clients lettuce2 lettuce2_sets

Lettuce Sets

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

Lettuce Sets

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

Sets 소스

Redis3_Set.java
package com.redisgate.redis; import io.lettuce.core.ScanArgs; import io.lettuce.core.ScanCursor; import io.lettuce.core.ValueScanCursor; 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.Set; @RestController @Slf4j public class Redis3_Set { private final RedisCommands<String, String> redisCommands; public Redis3_Set(RedisConfig redisConfig) { redisCommands = redisConfig.getRedisSyncCommands(); } // 예제 1) SADD: 집합에 데이터를 추가 // SADD key member [member ...] // http://localhost:8080/sadd/myset1 @GetMapping("/sadd/{key}") public String sadd(@PathVariable("key") String key) { String msg = "예제 1) SADD -> "; Long result = 0L; redisCommands.sadd(key, "member1","member2","member3"); String[] members = {"member4", "member5", "member6"}; // 배열로 입력 result = redisCommands.sadd(key, members); msg += result; System.out.println(msg); return msg; } // 예제 2) SMEMBERS: 데이터 조회 // SMEMBERS key // http://localhost:8080/smembers/myset1 @GetMapping("/smembers/{key}") public String smembers(@PathVariable("key") String key) { String msg = "예제 2) SMEMBERS -> "; Set<String> result = redisCommands.smembers(key); msg += result; System.out.println(msg); return msg; } // 예제 3) SREM: 데이터 삭제 // SREM key member [member ...] // http://localhost:8080/srem/myset1 @GetMapping("/srem/{key}") public String srem(@PathVariable("key") String key) { String msg = "예제 3) SREM -> "; Long result = redisCommands.srem(key, "member1"); msg += result; System.out.println(msg); return msg; } // 예제 4) SCARD: 데이터 개수 조회 // SCARD key // http://localhost:8080/scard/myset1 @GetMapping("/scard/{key}") public String scard(@PathVariable("key") String key) { String msg = "예제 4) SCARD -> "; Long result = redisCommands.scard(key); msg += result; System.out.println(msg); return msg; } // 예제 5) SUNION: 합집합을 구함, SINTER(교집합)/SDIFF(차집합) // SUNION key [key ...] // > sadd myset2 member10 member11 member12 -> 테스트 데이터 입력 // http://localhost:8080/sunion/myset1:myset2 @GetMapping("/sunion/{key}") public String sunion(@PathVariable("key") String key) { String msg = "예제 5) SUNION -> "; String[] keys = key.split(":"); Set<String> result = redisCommands.sunion(keys[0], keys[1]); msg += result; System.out.println(msg); return msg; } // 예제 6) SUNIONSTORE: 합집합을 구해서 새로운 집합(키)에 저장, SINTERSTORE(교집합)/SDIFFSTORE(차집합) // UNIONSTORE destination_key source_key [source_key ...] // http://localhost:8080/sunionstore/myset3 @GetMapping("/sunionstore/{key}") public String sunionstore(@PathVariable("key") String key) { String msg = "예제 6) SUNIONSTORE -> "; Long result = redisCommands.sunionstore(key,"myset1","myset2"); msg += result; System.out.println(msg); return msg; } // 예제 7) SISMEMBER: 집합에 데이터(멤버)가 존재하는지 확인, SMISMEMBER(여러 개) // SISMEMBER key member // http://localhost:8080/sismember/myset1:member2 -> true // http://localhost:8080/sismember/myset1:member9 -> false @GetMapping("/sismember/{key}") public String sismember(@PathVariable("key") String key) { String msg = "예제 7) SISMEMBER -> "; String[] members = key.split(":"); Boolean result = redisCommands.sismember(members[0],members[1]); msg += result; System.out.println(msg); return msg; } // 예제 8) SPOP: 집합에서 무작위로 데이터(멤버)를 가져옴 // SPOP key [count] // http://localhost:8080/spop/myset1 @GetMapping("/spop/{key}") public String spop(@PathVariable("key") String key) { String msg = "예제 8) SPOP -> "; String result = redisCommands.spop(key); msg += result; System.out.println(msg); return msg; } // 예제 9) SSCAN: 일정 단위 개수 만큼씩 조회 // SSCAN key cursor [MATCH pattern] [COUNT count] // http://localhost:8080/sscan/myset5, myset5:*, myset5:member, myset5:value @GetMapping("/sscan/{key}") public String sscan(@PathVariable("key") String key) { String msg = "예제 9) SSCAN -> "; System.out.println(msg); // key와 pattern을 나눈다. pattern을 입력하지 않았을 경우를 고려 String[] keyPattern = key.split(":"); String key1 = null; String pattern = null; if (keyPattern.length == 1) { key1 = keyPattern[0]; } else { key1 = keyPattern[0]; pattern = keyPattern[1]; } // 테스트 데이터 입력 (키가 없을 경우에만 데이터를 입력) Long card = redisCommands.scard(key1); if (card == 0) { for (int i = 1; i <= 100; i++) { redisCommands.sadd(key1, "member" + i); } for (int i = 1; i <= 100; i++) { redisCommands.sadd(key1, "value" + i); } } ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 ScanArgs args; // COUNT(limit)와 MATCH(pattern) 설정 if (pattern == null) { args = ScanArgs.Builder.limit(20); } else { args = ScanArgs.Builder.limit(20).match(pattern); } ValueScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.sscan(key1,cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; for (String member: result.getValues()) { // 값 System.out.println(" "+ (i++) +") "+member); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 return msg+"OK"; } }

각 명령(메서드) 별 표시

SADD

// 예제 1) SADD: 집합에 데이터를 추가 // SADD key member [member ...] // http://localhost:8080/sadd/myset1 @GetMapping("/sadd/{key}") public String sadd(@PathVariable("key") String key) { String msg = "예제 1) SADD -> "; Long result = 0L; redisCommands.sadd(key, "member1","member2","member3"); String[] members = {"member4", "member5", "member6"}; // 배열로 입력 result = redisCommands.sadd(key, members); msg += result; System.out.println(msg); return msg; }

SREM

// 예제 3) SREM: 데이터 삭제 // SREM key member [member ...] // http://localhost:8080/srem/myset1 @GetMapping("/srem/{key}") public String srem(@PathVariable("key") String key) { String msg = "예제 3) SREM -> "; Long result = redisCommands.srem(key, "member1"); msg += result; System.out.println(msg); return msg; }

SMEMBERS

// 예제 2) SMEMBERS: 데이터 조회 // SMEMBERS key // http://localhost:8080/smembers/myset1 @GetMapping("/smembers/{key}") public String smembers(@PathVariable("key") String key) { String msg = "예제 2) SMEMBERS -> "; Set<String> result = redisCommands.smembers(key); msg += result; System.out.println(msg); return msg; }

SCARD

// 예제 4) SCARD: 데이터 개수 조회 // SCARD key // http://localhost:8080/scard/myset1 @GetMapping("/scard/{key}") public String scard(@PathVariable("key") String key) { String msg = "예제 4) SCARD -> "; Long result = redisCommands.scard(key); msg += result; System.out.println(msg); return msg; }

SUNION

// 예제 5) SUNION: 합집합을 구함, SINTER(교집합)/SDIFF(차집합) // SUNION key [key ...] // > sadd myset2 member10 member11 member12 -> 테스트 데이터 입력 // http://localhost:8080/sunion/myset1:myset2 @GetMapping("/sunion/{key}") public String sunion(@PathVariable("key") String key) { String msg = "예제 5) SUNION -> "; String[] keys = key.split(":"); Set<String> result = redisCommands.sunion(keys[0], keys[1]); msg += result; System.out.println(msg); return msg; }

SUNIONSTORE

// 예제 6) SUNIONSTORE: 합집합을 구해서 새로운 집합(키)에 저장, SINTERSTORE(교집합)/SDIFFSTORE(차집합) // UNIONSTORE destination_key source_key [source_key ...] // http://localhost:8080/sunionstore/myset3 @GetMapping("/sunionstore/{key}") public String sunionstore(@PathVariable("key") String key) { String msg = "예제 6) SUNIONSTORE -> "; Long result = redisCommands.sunionstore(key,"myset1","myset2"); msg += result; System.out.println(msg); return msg; }

SISMEMBER

// 예제 7) SISMEMBER: 집합에 데이터(멤버)가 존재하는지 확인, SMISMEMBER(여러 개) // SISMEMBER key member // http://localhost:8080/sismember/myset1:member2 -> true // http://localhost:8080/sismember/myset1:member9 -> false @GetMapping("/sismember/{key}") public String sismember(@PathVariable("key") String key) { String msg = "예제 7) SISMEMBER -> "; String[] members = key.split(":"); Boolean result = redisCommands.sismember(members[0],members[1]); msg += result; System.out.println(msg); return msg; }

SPOP

// 예제 8) SPOP: 집합에서 무작위로 데이터(멤버)를 가져옴 // SPOP key [count] // http://localhost:8080/spop/myset1 @GetMapping("/spop/{key}") public String spop(@PathVariable("key") String key) { String msg = "예제 8) SPOP -> "; String result = redisCommands.spop(key); msg += result; System.out.println(msg); return msg; }

SSCAN

// 예제 9) SSCAN: 일정 단위 개수 만큼씩 조회 // SSCAN key cursor [MATCH pattern] [COUNT count] // http://localhost:8080/sscan/myset5, myset5:*, myset5:member, myset5:value @GetMapping("/sscan/{key}") public String sscan(@PathVariable("key") String key) { String msg = "예제 9) SSCAN -> "; System.out.println(msg); // key와 pattern을 나눈다. pattern을 입력하지 않았을 경우를 고려 String[] keyPattern = key.split(":"); String key1 = null; String pattern = null; if (keyPattern.length == 1) { key1 = keyPattern[0]; } else { key1 = keyPattern[0]; pattern = keyPattern[1]; } // 테스트 데이터 입력 (키가 없을 경우에만 데이터를 입력) Long card = redisCommands.scard(key1); if (card == 0) { for (int i = 1; i <= 100; i++) { redisCommands.sadd(key1, "member" + i); } for (int i = 1; i <= 100; i++) { redisCommands.sadd(key1, "value" + i); } } ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 ScanArgs args; // COUNT(limit)와 MATCH(pattern) 설정 if (pattern == null) { args = ScanArgs.Builder.limit(20); } else { args = ScanArgs.Builder.limit(20).match(pattern); } ValueScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.sscan(key1,cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; for (String member: result.getValues()) { // 값 System.out.println(" "+ (i++) +") "+member); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 return msg+"OK"; }