redis clients lettuce2 lettuce2_lists

Lettuce Lists

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

Lettuce Lists

Java Lettuce를 사용한 레디스 리스트(Lists) 명령 사용법입니다.

Lists 소스

Redis2_List.java
package com.redisgate.redis; import io.lettuce.core.KeyValue; import io.lettuce.core.RedisFuture; 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.ArrayList; import java.util.List; @RestController @Slf4j public class Redis2_List { private final RedisCommands<String, String> redisCommands; private final RedisAsyncCommands<String, String> redisAsyncCommands; public Redis2_List(RedisConfig redisConfig) { redisCommands = redisConfig.getRedisSyncCommands(); redisAsyncCommands = redisConfig.getRedisAsyncCommands(); } // 예제 1) LPUSH: 리스트의 왼쪽에 데이터를 저장, 리턴값은 리스트에 포함된 값의 개수이다. // LPUSH key value [value ...] // http://localhost:8080/lpush/mylist1 @GetMapping("/lpush/{key}") public String lpush(@PathVariable("key") String key) { String msg = "예제 1) LPUSH -> "; long result = 0; // list의 값의 총 개수를 리턴한다. redisCommands.lpush(key, "value1"); // 하나 입력 redisCommands.lpush(key, "value2", "value3"); // 여러 개 입력 String[] values = {"value4", "value5", "value6"}; // 배열로 입력 redisCommands.lpush(key, values); // 리스트를 입력하는 방법 ArrayList<String> list = new ArrayList<>(); list.add("value7"); list.add("value8"); list.add("value9"); for (String str : list) { redisCommands.lpush(key, str); // 값마다 호출하는 것은 성능에 좋지 않다. } // 배열로 한번에 저장한다. String[] array = list.toArray(new String[0]); // 배열로 변경 result += redisCommands.lpush(key, array); // 배열을 입력 System.out.println(msg+result); return msg+result; } // 예제 2) RPUSH: 리스트의 오른쪽에 데이터를 저장, 리턴값은 리스트에 포함된 값의 개수이다. // RPUSH key value [value ...] // http://localhost:8080/rpush/mylist1 @GetMapping("/rpush/{key}") public String rpush(@PathVariable("key") String key) { String msg = "예제 2) RPUSH -> "; long result = 0; // list의 값의 총 개수를 리턴한다. redisCommands.rpush(key, "Rvalue1"); // 하나 입력 redisCommands.rpush(key, "Rvalue2", "Rvalue3"); // 여러 개 입력 String[] values = {"Rvalue4", "Rvalue5", "Rvalue6"}; // 배열로 입력 result = redisCommands.rpush(key, values); msg += result; System.out.println(msg); return msg; } // 예제 3) LRANGE: 리스트 조회, 범위(인덱스) 지정, 전체를 조회할 경우 start에 0, stop에 -1을 입력한다. // LRANGE key start stop // http://localhost:8080/lrange/mylist1 @GetMapping("/lrange/{key}") public String lrange(@PathVariable("key") String key) { String msg = "예제 3) LRANGE -> "; List<String> result = redisCommands.lrange(key, 0, -1); System.out.println(msg+result); result = redisCommands.lrange(key, 0, 2); System.out.println(msg+result); result = redisCommands.lrange(key, -3, -1); System.out.println(msg+result); return msg+result; } // 예제 4) RPOP: 리스트 오른쪽에서 데이터(값)를 꺼내온다. // RPOP key [count] // http://localhost:8080/rpop/mylist1 @GetMapping("/rpop/{key}") public String rpop(@PathVariable("key") String key) { String msg = "예제 4) RPOP -> "; String result = redisCommands.rpop(key); msg += result; System.out.println(msg); return msg; } // 예제 5) LPOP: 리스트 왼쪽에서 데이터를 꺼내온다. // LPOP key [count] // http://localhost:8080/lpop/mylist1 @GetMapping("/lpop/{key}") public String lpop(@PathVariable("key") String key) { String msg = "예제 5) LPOP -> "; String result = redisCommands.lpop(key); msg += result; System.out.println(msg); return msg; } // 예제 6) LLEN: 리스트에서 value의 개수를 조회 // LLEN key // http://localhost:8080/llen/mylist1 @GetMapping("/llen/{key}") public String llen(@PathVariable("key") String key) { String msg = "예제 6) LLEN -> "; Long result = redisCommands.llen(key); msg += result; System.out.println(msg); return msg; } // 예제 7) RPOPLPUSH: 리스트 오른쪽에서 데이터를 꺼내서 왼쪽에 넣는다. // RPOPLPUSH source destination // http://localhost:8080/rpoplpush/mylist2 @GetMapping("/rpoplpush/{key}") public String rpoplpush(@PathVariable("key") String key) { String msg = "예제 7) RPOPLPUSH -> "; String result = redisCommands.rpoplpush("mylist1", key); msg += result; System.out.println(msg); return msg; } // 예제 8) BLPOP/BRPOP/BLMOVE/BRPOPLPUSH: Blocking(대기) 명령 // BLPOP: 데이터가 들어오면 리스트의 왼쪽에서 꺼내온다. // BLPOP key [key ...] timeout, BRPOP key [key ...] timeout // http://localhost:8080/blpop/mylist2 @GetMapping("/blpop/{key}") public String blpop(@PathVariable("key") String key) { String msg = "예제 8) BLPOP -> "; RedisFuture<KeyValue<String, String>> future = redisAsyncCommands.blpop(0, key); try { msg += future.get().getValue(); System.out.println(msg); return msg; } catch (Exception e) { log.info("Error -> "+e.getMessage()); } return msg+"Error"; } }

각 명령(메서드) 별 표시

LPUSH

// 예제 1) LPUSH: 리스트의 왼쪽에 데이터를 저장, 리턴값은 리스트에 포함된 값의 개수이다. // LPUSH key value [value ...] // http://localhost:8080/lpush/mylist1 @GetMapping("/lpush/{key}") public String lpush(@PathVariable("key") String key) { String msg = "예제 1) LPUSH -> "; long result = 0; // list의 값의 총 개수를 리턴한다. redisCommands.lpush(key, "value1"); // 하나 입력 redisCommands.lpush(key, "value2", "value3"); // 여러 개 입력 String[] values = {"value4", "value5", "value6"}; // 배열로 입력 redisCommands.lpush(key, values); // 리스트를 입력하는 방법 ArrayList<String> list = new ArrayList<>(); list.add("value7"); list.add("value8"); list.add("value9"); for (String str : list) { redisCommands.lpush(key, str); // 값마다 호출하는 것은 성능에 좋지 않다. } // 배열로 한번에 저장한다. String[] array = list.toArray(new String[0]); // 배열로 변경 result += redisCommands.lpush(key, array); // 배열을 입력 System.out.println(msg+result); return msg+result; }

RPOP

// 예제 4) RPOP: 리스트 오른쪽에서 데이터(값)를 꺼내온다. // RPOP key [count] // http://localhost:8080/rpop/mylist1 @GetMapping("/rpop/{key}") public String rpop(@PathVariable("key") String key) { String msg = "예제 4) RPOP -> "; String result = redisCommands.rpop(key); msg += result; System.out.println(msg); return msg; }

LPOP

// 예제 5) LPOP: 리스트 왼쪽에서 데이터를 꺼내온다. // LPOP key [count] // http://localhost:8080/lpop/mylist1 @GetMapping("/lpop/{key}") public String lpop(@PathVariable("key") String key) { String msg = "예제 5) LPOP -> "; String result = redisCommands.lpop(key); msg += result; System.out.println(msg); return msg; }

RPUSH

// 예제 2) RPUSH: 리스트의 오른쪽에 데이터를 저장, 리턴값은 리스트에 포함된 값의 개수이다. // RPUSH key value [value ...] // http://localhost:8080/rpush/mylist1 @GetMapping("/rpush/{key}") public String rpush(@PathVariable("key") String key) { String msg = "예제 2) RPUSH -> "; long result = 0; // list의 값의 총 개수를 리턴한다. redisCommands.rpush(key, "Rvalue1"); // 하나 입력 redisCommands.rpush(key, "Rvalue2", "Rvalue3"); // 여러 개 입력 String[] values = {"Rvalue4", "Rvalue5", "Rvalue6"}; // 배열로 입력 result = redisCommands.rpush(key, values); msg += result; System.out.println(msg); return msg; }

LRANGE

// 예제 3) LRANGE: 리스트 조회, 범위(인덱스) 지정, 전체를 조회할 경우 start에 0, stop에 -1을 입력한다. // LRANGE key start stop // http://localhost:8080/lrange/mylist1 @GetMapping("/lrange/{key}") public String lrange(@PathVariable("key") String key) { String msg = "예제 3) LRANGE -> "; List<String> result = redisCommands.lrange(key, 0, -1); System.out.println(msg+result); result = redisCommands.lrange(key, 0, 2); System.out.println(msg+result); result = redisCommands.lrange(key, -3, -1); System.out.println(msg+result); return msg+result; }

LLEN

// 예제 6) LLEN: 리스트에서 value의 개수를 조회 // LLEN key // http://localhost:8080/llen/mylist1 @GetMapping("/llen/{key}") public String llen(@PathVariable("key") String key) { String msg = "예제 6) LLEN -> "; Long result = redisCommands.llen(key); msg += result; System.out.println(msg); return msg; }

RPOPLPUSH

// 예제 7) RPOPLPUSH: 리스트 오른쪽에서 데이터를 꺼내서 왼쪽에 넣는다. // RPOPLPUSH source destination // http://localhost:8080/rpoplpush/mylist2 @GetMapping("/rpoplpush/{key}") public String rpoplpush(@PathVariable("key") String key) { String msg = "예제 7) RPOPLPUSH -> "; String result = redisCommands.rpoplpush("mylist1", key); msg += result; System.out.println(msg); return msg; }

BLPOP

// 예제 8) BLPOP/BRPOP/BLMOVE/BRPOPLPUSH: Blocking(대기) 명령 // BLPOP: 데이터가 들어오면 리스트의 왼쪽에서 꺼내온다. // BLPOP key [key ...] timeout, BRPOP key [key ...] timeout // http://localhost:8080/blpop/mylist2 @GetMapping("/blpop/{key}") public String blpop(@PathVariable("key") String key) { String msg = "예제 8) BLPOP -> "; RedisFuture<KeyValue<String, String>> future = redisAsyncCommands.blpop(0, key); try { msg += future.get().getValue(); System.out.println(msg); return msg; } catch (Exception e) { log.info("Error -> "+e.getMessage()); } return msg+"Error"; }