redis clients lettuce2 lettuce2_hashes

Lettuce Hashs

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

Lettuce Hashes

Java Lettuce를 사용한 레디스 해시(Hashes) 명령 사용법입니다.

Hashes 소스

Redis5_Hash.java
package com.redisgate.redis; import io.lettuce.core.*; 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.HashMap; import java.util.List; import java.util.Map; @RestController @Slf4j public class Redis5_Hash { private final RedisCommands<String, String> redisCommands; public Redis5_Hash(RedisConfig redisConfig) { redisCommands = redisConfig.getRedisSyncCommands(); } // 예제 1) HSET: field 와 value를 저장 // HSET key field value [field value ...] // http://localhost:8080/hset/myhash1 @GetMapping("/hset/{key}") public String hset(@PathVariable("key") String key) { String msg = "예제 1) HSET -> "; // 하나 입력: return Boolean Boolean result = redisCommands.hset(key, "field01", "value01"); System.out.println(msg+result); // 맵을 구성해서 여러 개 입력: return Long Map<String, String> map = new HashMap<>(); for (int i=2; i<=10; i++) { map.put("field"+String.format("%02d",i),"value"+String.format("%02d",i)); } Long result2 = redisCommands.hset(key, map); msg += result2; System.out.println(msg); return msg; } // 예제 2) HGET: field로 value를 조회 // HGET key field // http://localhost:8080/hget/myhash1:field01 @GetMapping("/hget/{key}") public String hget(@PathVariable("key") String key) { String msg = "예제 2) HGET -> "; String[] keyField = key.split(":"); String result = redisCommands.hget(keyField[0],keyField[1]); msg += result; System.out.println(msg); return msg; } // 예제 3) HMGET: 여러 개의 value를 조회 // HMGET key field [field ...] // http://localhost:8080/hmget/myhash1 @GetMapping("/hmget/{key}") public String hmget(@PathVariable("key") String key) { String msg = "예제 3) HMGET -> "; // List<KeyValue<K, V>> hmget(K key, K... fields); List<KeyValue<String, String>> keyValues; keyValues = redisCommands.hmget(key,"field02"); System.out.println(msg+keyValues.toString()); String[] fields = {"field03","field04","field05"}; keyValues = redisCommands.hmget(key,fields); keyValues.forEach(System.out::println); keyValues.forEach(item -> System.out.println(item.getKey()+" "+item.getValue())); msg += keyValues.toString(); System.out.println(msg); return msg; } // 예제 4) HLEN: field의 개수를 조회 // HLEN key // http://localhost:8080/hlen/myhash1 @GetMapping("/hlen/{key}") public String hlen(@PathVariable("key") String key) { String msg = "예제 4) HLEN -> "; Long result = redisCommands.hlen(key); msg += result; System.out.println(msg); return msg; } // 예제 5) HKEYS: key에 속한 모든 field name을 조회 // HKEYS key // http://localhost:8080/hkeys/myhash1 @GetMapping("/hkeys/{key}") public String hkeys(@PathVariable("key") String key) { String msg = "예제 5) HKEYS -> "; List<String> result = redisCommands.hkeys(key); msg += result.toString(); System.out.println(msg); return msg; } // 예제 6) HVALS: key에 속한 모든 value를 조회 // HVALS key // http://localhost:8080/hvals/myhash1 @GetMapping("/hvals/{key}") public String hvals(@PathVariable("key") String key) { String msg = "예제 6) HVALS -> "; List<String> result = redisCommands.hvals(key); msg += result.toString(); System.out.println(msg); return msg; } // 예제 7) HGETALL: key에 속한 모든 field와 value를 조회 // HGETALL key // http://localhost:8080/hgetall/myhash1 @GetMapping("/hgetall/{key}") public String hgetall(@PathVariable("key") String key) { String msg = "예제 7) HGETALL -> "; System.out.println(msg); Map<String,String> result = redisCommands.hgetall(key); int i = 1; for ( Map.Entry<String,String> kv : result.entrySet()) { System.out.println((i++) + ") "+kv.getKey()+" "+kv.getValue()); } return msg+result; } // 예제 8) HDEL: field와 value를 삭제 // HDEL key field [field ...] // http://localhost:8080/hdel/myhash1 @GetMapping("/hdel/{key}") public String hdel(@PathVariable("key") String key) { String msg = "예제 8) HDEL -> "; Long result = 0L; result += redisCommands.hdel(key,"field01"); result += redisCommands.hdel(key,"field02","field03"); msg += result; System.out.println(msg); return msg; } // 예제 9) HEXISTS: field가 있는지 조회 // HEXISTS key field // http://localhost:8080/hexists/myhash1 @GetMapping("/hexists/{key}") public String hexists(@PathVariable("key") String key) { Boolean result; String msg; result = redisCommands.hexists(key,"field01"); msg = "예제 9) HEXISTS field01 -> "+result; System.out.println(msg); result = redisCommands.hexists(key,"field04"); msg = "예제 9) HEXISTS field04 -> "+result; System.out.println(msg); return msg; } // 예제 10) HSETNX: field가 기존에 없으면 저장 // HSETNX key field value // http://localhost:8080/hsetnx/myhash1 @GetMapping("/hsetnx/{key}") public String hsetnx(@PathVariable("key") String key) { Boolean result; String msg; result = redisCommands.hsetnx(key,"field01","value01"); msg = "예제 10) HSETNX field01 -> "+result; System.out.println(msg); result = redisCommands.hsetnx(key,"field04","value04"); msg = "예제 10) HSETNX field04 -> "+result; System.out.println(msg); return msg; } // 예제 11) HINCRBY: value를 increment 만큼 증가 또는 감소 // HINCRBY key field increment, HINCRBYFLOAT key field increment // http://localhost:8080/hincrby/myhash1 @GetMapping("/hincrby/{key}") public String hincrby(@PathVariable("key") String key) { String msg; Long result; result = redisCommands.hincrby(key,"field90",1); msg = "예제 11) HINCRBY -> "+result; System.out.println(msg); result = redisCommands.hincrby(key,"field90",1); msg = "예제 11) HINCRBY -> "+result; System.out.println(msg); result = redisCommands.hincrby(key,"field90",1); msg = "예제 11) HINCRBY -> "+result; System.out.println(msg); return msg; } // 예제 12) HSCAN: field, member를 일정 단위 개수 만큼씩 조회 // HSCAN key cursor [MATCH pattern] [COUNT count] // http://localhost:8080/hscan/myhash1 @GetMapping("/hscan/{key}") public String hscan(@PathVariable("key") String key) { String msg = "예제 12) HSCAN -> "; System.out.println(msg); 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); MapScanCursor<String, String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.hscan(key,cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; size += result.getMap().size(); for ( Map.Entry<String,String> kv : result.getMap().entrySet()) { System.out.println((i++) + ") "+kv.getKey()+" "+kv.getValue()); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 msg += size; System.out.println(msg); return msg; } }

각 명령(메서드) 별 표시

HSET

// 예제 1) HSET: field 와 value를 저장 // HSET key field value [field value ...] // http://localhost:8080/hset/myhash1 @GetMapping("/hset/{key}") public String hset(@PathVariable("key") String key) { String msg = "예제 1) HSET -> "; // 하나 입력: return Boolean Boolean result = redisCommands.hset(key, "field01", "value01"); System.out.println(msg+result); // 맵을 구성해서 여러 개 입력: return Long Map<String, String> map = new HashMap<>(); for (int i=2; i<=10; i++) { map.put("field"+String.format("%02d",i),"value"+String.format("%02d",i)); } Long result2 = redisCommands.hset(key, map); msg += result2; System.out.println(msg); return msg; }

HDEL

// 예제 8) HDEL: field와 value를 삭제 // HDEL key field [field ...] // http://localhost:8080/hdel/myhash1 @GetMapping("/hdel/{key}") public String hdel(@PathVariable("key") String key) { String msg = "예제 8) HDEL -> "; Long result = 0L; result += redisCommands.hdel(key,"field01"); result += redisCommands.hdel(key,"field02","field03"); msg += result; System.out.println(msg); return msg; }

HGET

// 예제 2) HGET: field로 value를 조회 // HGET key field // http://localhost:8080/hget/myhash1:field01 @GetMapping("/hget/{key}") public String hget(@PathVariable("key") String key) { String msg = "예제 2) HGET -> "; String[] keyField = key.split(":"); String result = redisCommands.hget(keyField[0],keyField[1]); msg += result; System.out.println(msg); return msg; }

HLEN

// 예제 4) HLEN: field의 개수를 조회 // HLEN key // http://localhost:8080/hlen/myhash1 @GetMapping("/hlen/{key}") public String hlen(@PathVariable("key") String key) { String msg = "예제 4) HLEN -> "; Long result = redisCommands.hlen(key); msg += result; System.out.println(msg); return msg; }

HMSET

// 예제 5) HKEYS: key에 속한 모든 field name을 조회 // HKEYS key // http://localhost:8080/hkeys/myhash1 @GetMapping("/hkeys/{key}") public String hkeys(@PathVariable("key") String key) { String msg = "예제 5) HKEYS -> "; List<String> result = redisCommands.hkeys(key); msg += result.toString(); System.out.println(msg); return msg; }

HMGET

// 예제 3) HMGET: 여러 개의 value를 조회 // HMGET key field [field ...] // http://localhost:8080/hmget/myhash1 @GetMapping("/hmget/{key}") public String hmget(@PathVariable("key") String key) { String msg = "예제 3) HMGET -> "; // List<KeyValue<K, V>> hmget(K key, K... fields); List<KeyValue<String, String>> keyValues; keyValues = redisCommands.hmget(key,"field02"); System.out.println(msg+keyValues.toString()); String[] fields = {"field03","field04","field05"}; keyValues = redisCommands.hmget(key,fields); keyValues.forEach(System.out::println); keyValues.forEach(item -> System.out.println(item.getKey()+" "+item.getValue())); msg += keyValues.toString(); System.out.println(msg); return msg; }

HKEYS

// 예제 5) HKEYS: key에 속한 모든 field name을 조회 // HKEYS key // http://localhost:8080/hkeys/myhash1 @GetMapping("/hkeys/{key}") public String hkeys(@PathVariable("key") String key) { String msg = "예제 5) HKEYS -> "; List<String> result = redisCommands.hkeys(key); msg += result.toString(); System.out.println(msg); return msg; }

HVALS

// 예제 6) HVALS: key에 속한 모든 value를 조회 // HVALS key // http://localhost:8080/hvals/myhash1 @GetMapping("/hvals/{key}") public String hvals(@PathVariable("key") String key) { String msg = "예제 6) HVALS -> "; List<String> result = redisCommands.hvals(key); msg += result.toString(); System.out.println(msg); return msg; }

HGETALL

// 예제 7) HGETALL: key에 속한 모든 field와 value를 조회 // HGETALL key // http://localhost:8080/hgetall/myhash1 @GetMapping("/hgetall/{key}") public String hgetall(@PathVariable("key") String key) { String msg = "예제 7) HGETALL -> "; System.out.println(msg); Map<String,String> result = redisCommands.hgetall(key); int i = 1; for ( Map.Entry<String,String> kv : result.entrySet()) { System.out.println((i++) + ") "+kv.getKey()+" "+kv.getValue()); } return msg+result; }

HINCRBY

// 예제 11) HINCRBY: value를 increment 만큼 증가 또는 감소 // HINCRBY key field increment, HINCRBYFLOAT key field increment // http://localhost:8080/hincrby/myhash1 @GetMapping("/hincrby/{key}") public String hincrby(@PathVariable("key") String key) { String msg; Long result; result = redisCommands.hincrby(key,"field90",1); msg = "예제 11) HINCRBY -> "+result; System.out.println(msg); result = redisCommands.hincrby(key,"field90",1); msg = "예제 11) HINCRBY -> "+result; System.out.println(msg); result = redisCommands.hincrby(key,"field90",1); msg = "예제 11) HINCRBY -> "+result; System.out.println(msg); return msg; }

HEXISTS

// 예제 9) HEXISTS: field가 있는지 조회 // HEXISTS key field // http://localhost:8080/hexists/myhash1 @GetMapping("/hexists/{key}") public String hexists(@PathVariable("key") String key) { Boolean result; String msg; result = redisCommands.hexists(key,"field01"); msg = "예제 9) HEXISTS field01 -> "+result; System.out.println(msg); result = redisCommands.hexists(key,"field04"); msg = "예제 9) HEXISTS field04 -> "+result; System.out.println(msg); return msg; }

HSETNX

// 예제 10) HSETNX: field가 기존에 없으면 저장 // HSETNX key field value // http://localhost:8080/hsetnx/myhash1 @GetMapping("/hsetnx/{key}") public String hsetnx(@PathVariable("key") String key) { Boolean result; String msg; result = redisCommands.hsetnx(key,"field01","value01"); msg = "예제 10) HSETNX field01 -> "+result; System.out.println(msg); result = redisCommands.hsetnx(key,"field04","value04"); msg = "예제 10) HSETNX field04 -> "+result; System.out.println(msg); return msg; }

HSCAN

// 예제 12) HSCAN: field, member를 일정 단위 개수 만큼씩 조회 // HSCAN key cursor [MATCH pattern] [COUNT count] // http://localhost:8080/hscan/myhash1 @GetMapping("/hscan/{key}") public String hscan(@PathVariable("key") String key) { String msg = "예제 12) HSCAN -> "; System.out.println(msg); 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); MapScanCursor<String, String> result; // 조회 결과: next cursor 있음. do { result = redisCommands.hscan(key,cursor,args); System.out.println("Next cursor: "+result.getCursor()); int i = 1; size += result.getMap().size(); for ( Map.Entry<String,String> kv : result.getMap().entrySet()) { System.out.println((i++) + ") "+kv.getKey()+" "+kv.getValue()); } cursor.setCursor(result.getCursor()); // 다음 커서를 다시 설정한다. } while (!result.isFinished()); // 끝날 때까지 msg += size; System.out.println(msg); return msg; }