redis clients lettuce2 lettuce2_common_keys

Lettuce Common Keys

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

Lettuce Common Keys

Java Lettuce를 사용한 레디스 키(Common Keys) 명령 사용법입니다.

Common Keys 소스

Redis7_Common.java
package com.redisgate.redis; import io.lettuce.core.KeyScanCursor; import io.lettuce.core.ScanArgs; import io.lettuce.core.ScanCursor; 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.io.IOException; import java.util.List; @RestController @Slf4j public class Redis7_Common { private final RedisCommands<String, String> redisCommands; public Redis7_Common(RedisConfig redisConfig) { redisCommands = redisConfig.getRedisSyncCommands(); } // 예제 1) KEYS: 키(key)들을 pattern으로 조회 // KEYS pattern // URL에 keys를 입력하면 오류 발생 -> Redis1_String과 충돌임. // http://localhost:8080/keys/* @GetMapping("/keys/{pattern}") public String keys(@PathVariable("pattern") String pattern) { String msg = "예제 1) KEYS -> "; System.out.println(msg); List<String> result = redisCommands.keys(pattern); int i = 0; for (String key: result) { System.out.println((++i) +") "+key); } msg += result; return msg; } // 예제 2) SCAN: 키(key)들을 일정 단위 개수 만큼씩 조회 // SCAN cursor [MATCH pattern] [COUNT count] // http://localhost:8080/scan/* @GetMapping("/scan/{pattern}") public String scan(@PathVariable("pattern") String pattern) throws IOException { String msg = "예제 2) SCAN -> "; ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 System.out.println(msg+cursor.getCursor()); // COUNT(limit)와 MATCH(pattern) 설정 ScanArgs args = ScanArgs.Builder.limit(20).match(pattern); KeyScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.scan(cursor,args); int i = 1; for (String key: result.getKeys()) { // 키 System.out.println(" "+ (i++) +") "+key); } System.out.println("Next cursor: "+result.getCursor()); cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 return msg+"OK"; } // 예제 3) EXISTS: 키(key)가 존재하는지 확인 // EXISTS key [key ...] // http://localhost:8080/exists/key-001, key-900 @GetMapping("/exists/{key}") public String exists(@PathVariable("key") String key) { String msg = "예제 3) EXISTS -> "; Long result = redisCommands.exists(key); msg += result; System.out.println(msg); return msg; } // 예제 4) RENAME: 키(key) 이름 변경, RENAMENX // RENAME key new_key, RENAMENX key new_key // http://localhost:8080/rename/key-100:key-900 @GetMapping("/rename/{key}") public String rename(@PathVariable("key") String key) { String msg = "예제 4) RENAME -> "; String[] keys = key.split(":"); String result = redisCommands.rename(keys[0], keys[1]); System.out.println(msg+result); // RENAMENX: 기존에 키가 없을 경우에만 이름 변경 String msg2 = "예제 4) RENAMENX -> "; Boolean result2 = redisCommands.renamenx("key-099", keys[1]); System.out.println(msg2+result2); return msg2+result2; } // 예제 5) EXPIRE: 지정된 시간(초) 후 키(key) 자동 삭제 // EXPIRE key seconds // http://localhost:8080/expire/key-900:180 @GetMapping("/expire/{key}") public String expire(@PathVariable("key") String key) { String msg = "예제 5) EXPIRE -> "; String[] keyExpire = key.split(":"); Boolean result = redisCommands.expire(keyExpire[0], Long.parseLong(keyExpire[1])); msg += result; System.out.println(msg); return msg; } // 예제 6) TTL: 남은 expire time(seconds)을 조회 // TTL key // http://localhost:8080/ttl/key-900 @GetMapping("/ttl/{key}") public String ttl(@PathVariable("key") String key) { String msg = "예제 6) TTL -> "; Long result = redisCommands.ttl(key); msg += result; System.out.println(msg); return msg; } // 예제 7) PERSIST: 설정된 Expire time을 삭제 // PERSIST key // http://localhost:8080/persist/key-900 @GetMapping("/persist/{key}") public String persist(@PathVariable("key") String key) { String msg = "예제 7) PERSIST -> "; Boolean result = redisCommands.persist(key); msg += result; System.out.println(msg); return msg; } // 예제 8) TYPE: 키(key)의 data type을 조회 // TYPE key // http://localhost:8080/persist/key-001 @GetMapping("/type/{key}") public String type(@PathVariable("key") String key) { String msg = "예제 8) TYPE -> "; String result = redisCommands.type(key); msg += result; System.out.println(msg); return msg; } // 예제 9) FLUSHDB: 현재 사용중인(선택된) DB의 모든 데이터(키와 값)를 삭제 // FLUSHDB [async], FLUSHALL [async] // http://localhost:8080/flushdb @GetMapping("/flushdb") public String flushdb() { String msg = "예제 9) FLUSHDB -> "; String result = redisCommands.flushdb(); msg += result; System.out.println(msg); return msg; } // 예제 10) 테스트 데이터 입력 // http://localhost:8080/input @GetMapping("/input") public String input() { String msg = "예제 10) 테스트 데이터 입력 -> "; // String: key* 100개, for (int i=1; i<=100; i++) { redisCommands.set("key-"+String.format("%03d",i), "value-"+String.format("%03d",i)); } msg += "OK"; System.out.println(msg); return msg; } // 예제 11) 패턴으로 키 삭제: SCAN 사용 // SCAN cursor [MATCH pattern] [COUNT count] // http://localhost:8080/dels/zset* @GetMapping("/dels/{pattern}") public String dels(@PathVariable("pattern") String pattern) throws IOException { // key와 pattern을 나눈다. pattern을 입력하지 않았을 경우를 고려 ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 // COUNT(limit)와 MATCH(pattern) 설정 ScanArgs args = ScanArgs.Builder.limit(20).match(pattern); KeyScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.scan(cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; for (String key: result.getKeys()) { // 키 long del = redisCommands.del(key); System.out.println(" "+ (i++) +") "+key+" deleted -> "+del); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 return "OK"; } }

각 명령(메서드) 별 표시

EXISTS

// 예제 3) EXISTS: 키(key)가 존재하는지 확인 // EXISTS key [key ...] // http://localhost:8080/exists/key-001, key-900 @GetMapping("/exists/{key}") public String exists(@PathVariable("key") String key) { String msg = "예제 3) EXISTS -> "; Long result = redisCommands.exists(key); msg += result; System.out.println(msg); return msg; }

KEYS

// 예제 1) KEYS: 키(key)들을 pattern으로 조회 // KEYS pattern // URL에 keys를 입력하면 오류 발생 -> Redis1_String과 충돌임. // http://localhost:8080/keys/* @GetMapping("/keys/{pattern}") public String keys(@PathVariable("pattern") String pattern) { String msg = "예제 1) KEYS -> "; System.out.println(msg); List<String> result = redisCommands.keys(pattern); int i = 0; for (String key: result) { System.out.println((++i) +") "+key); } msg += result; return msg; }

SCAN

// 예제 2) SCAN: 키(key)들을 일정 단위 개수 만큼씩 조회 // SCAN cursor [MATCH pattern] [COUNT count] // http://localhost:8080/scan/* @GetMapping("/scan/{pattern}") public String scan(@PathVariable("pattern") String pattern) throws IOException { String msg = "예제 2) SCAN -> "; ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 System.out.println(msg+cursor.getCursor()); // COUNT(limit)와 MATCH(pattern) 설정 ScanArgs args = ScanArgs.Builder.limit(20).match(pattern); KeyScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.scan(cursor,args); int i = 1; for (String key: result.getKeys()) { // 키 System.out.println(" "+ (i++) +") "+key); } System.out.println("Next cursor: "+result.getCursor()); cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 return msg+"OK"; }

RENAME

// 예제 4) RENAME: 키(key) 이름 변경, RENAMENX // RENAME key new_key, RENAMENX key new_key // http://localhost:8080/rename/key-100:key-900 @GetMapping("/rename/{key}") public String rename(@PathVariable("key") String key) { String msg = "예제 4) RENAME -> "; String[] keys = key.split(":"); String result = redisCommands.rename(keys[0], keys[1]); System.out.println(msg+result); // RENAMENX: 기존에 키가 없을 경우에만 이름 변경 String msg2 = "예제 4) RENAMENX -> "; Boolean result2 = redisCommands.renamenx("key-099", keys[1]); System.out.println(msg2+result2); return msg2+result2; }

EXPIRE

// 예제 5) EXPIRE: 지정된 시간(초) 후 키(key) 자동 삭제 // EXPIRE key seconds // http://localhost:8080/expire/key-900:180 @GetMapping("/expire/{key}") public String expire(@PathVariable("key") String key) { String msg = "예제 5) EXPIRE -> "; String[] keyExpire = key.split(":"); Boolean result = redisCommands.expire(keyExpire[0], Long.parseLong(keyExpire[1])); msg += result; System.out.println(msg); return msg; }

TTL

// 예제 6) TTL: 남은 expire time(seconds)을 조회 // TTL key // http://localhost:8080/ttl/key-900 @GetMapping("/ttl/{key}") public String ttl(@PathVariable("key") String key) { String msg = "예제 6) TTL -> "; Long result = redisCommands.ttl(key); msg += result; System.out.println(msg); return msg; }

PERSIST

// 예제 7) PERSIST: 설정된 Expire time을 삭제 // PERSIST key // http://localhost:8080/persist/key-900 @GetMapping("/persist/{key}") public String persist(@PathVariable("key") String key) { String msg = "예제 7) PERSIST -> "; Boolean result = redisCommands.persist(key); msg += result; System.out.println(msg); return msg; }

TYPE

// 예제 8) TYPE: 키(key)의 data type을 조회 // TYPE key // http://localhost:8080/persist/key-001 @GetMapping("/type/{key}") public String type(@PathVariable("key") String key) { String msg = "예제 8) TYPE -> "; String result = redisCommands.type(key); msg += result; System.out.println(msg); return msg; }

FLUSHDB

// 예제 9) FLUSHDB: 현재 사용중인(선택된) DB의 모든 데이터(키와 값)를 삭제 // FLUSHDB [async], FLUSHALL [async] // http://localhost:8080/flushdb @GetMapping("/flushdb") public String flushdb() { String msg = "예제 9) FLUSHDB -> "; String result = redisCommands.flushdb(); msg += result; System.out.println(msg); return msg; }

테스트 데이터 입력

// 예제 10) 테스트 데이터 입력 // http://localhost:8080/input @GetMapping("/input") public String input() { String msg = "예제 10) 테스트 데이터 입력 -> "; // String: key* 100개, for (int i=1; i<=100; i++) { redisCommands.set("key-"+String.format("%03d",i), "value-"+String.format("%03d",i)); } msg += "OK"; System.out.println(msg); return msg; }

패턴으로 키 삭제: SCAN 사용

// 예제 11) 패턴으로 키 삭제: SCAN 사용 // SCAN cursor [MATCH pattern] [COUNT count] // http://localhost:8080/dels/zset* @GetMapping("/dels/{pattern}") public String dels(@PathVariable("pattern") String pattern) throws IOException { // key와 pattern을 나눈다. pattern을 입력하지 않았을 경우를 고려 ScanCursor cursor = new ScanCursor(); cursor.setCursor("0"); // 시작 커서 설정 // COUNT(limit)와 MATCH(pattern) 설정 ScanArgs args = ScanArgs.Builder.limit(20).match(pattern); KeyScanCursor<String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.scan(cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; for (String key: result.getKeys()) { // 키 long del = redisCommands.del(key); System.out.println(" "+ (i++) +") "+key+" deleted -> "+del); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 return "OK"; }