redis clients springboot spring_session_redis_cluster

Spring Session Redis Cluster

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Java Program Project Configuration

구성 소프트웨어 버전

Project 생성: start.spring.io

Project: Gradle-Groovy Language: Java Spring Boot 3.1.6 Group: com.redisgate Artifact: springSessionRedisCluster Name: Spring Session Redis Cluster Description: Redis Cluster project for Spring Session Package name: com.redisgate.springSessionRedisCluster Packaging: Jar Java: 17 Dependencies Spring Web Spring Session Lombok Spring Data Redis(Access+Driver)

build.gradle

dependencies에 spring-session-data-redis 가 있는지 확인한다.

application.properties

Standalone 설정에서 추가된 항목에서 중요한 것은 replicas.host, port와 readFrom이 추가되었다.
readFrom은 조회 명령을 복제(replica) 서버에서 실행하게 해서 부하분산을 하는 기능입니다.
Lettuce 설정에 있습니다. 여기서는 replicaPreferred으로 설정했습니다.
자세한 내용은 여기(readFrom)를 보세요. # Redis Cluster Config redis.cluster.nodes: 192.168.56.102:18530, 192.168.56.102:18531, 192.168.56.102:18532, 192.168.56.102:18533, 192.168.56.102:18534, 192.168.56.102:18535 redis.password: redisgate redis.readFrom: replicaPreferred redis.clientName: redisgate

참고

설정에서 spring.session.store-type:redis 이나 @EnableRedisHttpSession이 필요하다는 글도 있으나 현재 테스트 버전에서는 필요하지 않았다.

Java Program

Main Class: SpringSessionRedisClusterApplication

package com.redisgate.springSessionRedisCluster; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication @Slf4j public class SpringSessionRedisClusterApplication { public static void main(String[] args) { SpringApplication.run(SpringSessionRedisClusterApplication.class, args); log.info("SpringSessionRedisClusterApplication-시작"); } }

Class RedisClusterInfo

application.properties 설정 값을 읽어오는 클래스 package com.redisgate.springSessionRedisCluster; import java.util.Set; import lombok.Getter; import lombok.Setter; import lombok.NoArgsConstructor; import lombok.AllArgsConstructor; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Configuration; @Getter @Setter @NoArgsConstructor @AllArgsConstructor @ConfigurationProperties(prefix = "redis") @Configuration public class RedisClusterInfo { private Set<String> nodes; private String password; private String readFrom; private String clientName; private RedisClusterInfo cluster; }

Class RedisClusterConfig

master.host, port, replicas.host, port, readFrom 등의 정보로 redisConnectionFactory를 만든다.
application.properties에 readFrom이 없을 경우 ANY로 설정하게 했다. package com.redisgate.springSessionRedisCluster; import io.lettuce.core.ReadFrom; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisClusterConfiguration; import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration; import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory; @Configuration @RequiredArgsConstructor @Slf4j public class RedisClusterConfig { private final RedisClusterInfo redisClusterInfo; @Bean public LettuceConnectionFactory redisConnectionFactory() { log.info("Step 1 - Redis Cluster Config"); log.info("Cluster Nodes: {}", redisClusterInfo.getCluster().getNodes()); RedisClusterConfiguration redisConfig = new RedisClusterConfiguration(redisClusterInfo.getCluster().getNodes()); redisConfig.setPassword(redisClusterInfo.getPassword()); // Redis Password ReadFrom readFrom = ReadFrom.valueOf(redisClusterInfo.getReadFrom()); if (readFrom == null) readFrom = ReadFrom.ANY; LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder() .readFrom(readFrom) .clientName(redisClusterInfo.getClientName()) .build(); log.info("Step 2 - Client Config"); return new LettuceConnectionFactory(redisConfig, clientConfig); } }

Class SessionController

• hello1(): session.setAttribute("hello1","Charlie");
• hello2(): session.setAttribute(); 2회 실행
• hello3(): ① 속성명 지정해서 값 가져오기. ② 모든 속성명, 값 가져오기. ③ Session ID, 생성일시, 마지막 액세스(접근) 일시 가져오기
• hello4(): Redis HGETALL 명령으로 세션 데이터 가져오기. 메서드 명은 redisHash.entries()

package com.redisgate.springSessionRedisCluster; import jakarta.servlet.http.HttpSession; import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.HashOperations; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import java.util.Date; import java.util.Enumeration; import java.util.Map; @RestController @Slf4j public class SessionController { private final HashOperations redisHash; public SessionController(StringRedisTemplate stringRedisTemplate) { this.redisHash = stringRedisTemplate.opsForHash(); } @GetMapping("/hello1") public String hello1(HttpSession session) { // 속성명: hello1, 값: Charlie session.setAttribute("hello1","Charlie"); log.info("hello1 Charlie"); return "hello1 Charlie"; } @GetMapping("/hello2") public String hello2(HttpSession session) { // 속성명: hello2-1, 값: Kwon-1 // 속성명: hello2-2, 값: Kwon-2 session.setAttribute("hello2-1","Kwon-1"); session.setAttribute("hello2-2","Kwon-2"); log.info("hello2 Kwon"); return "hello2 Kwon"; } @GetMapping("/hello3") public String hello3(HttpSession session) { // 속성명 지정해서 값 가져오기 String hello1Value = (String) session.getAttribute("hello1"); log.info("hello1 Value: {}",hello1Value); // 모든 속성명, 값 가져오기 Enumeration<?> attrName = session.getAttributeNames(); while (attrName.hasMoreElements()) { String attr = (String) attrName.nextElement(); log.info("{}:{}",attr,session.getAttribute(attr)); } // Session ID, 생성일시, 마지막 액세스(접근) 일시 가져오기 String sessionId = session.getId(); Date ctime = new Date(session.getCreationTime()); Date atime = new Date(session.getLastAccessedTime()); log.info("sessionId: {}",sessionId); log.info("CreationTime: {}",ctime); log.info("LastAccessedTime: {}",atime); return "hello3"; } @GetMapping("/hello4") @SuppressWarnings("unchecked") public String hello4(HttpSession session) { // Redis HGETALL 명령으로 데이터 가져오기. 메서드 명은 redisHash.entries() String prefix = "spring:session:sessions:"; String sessionId = session.getId(); String springSessionId = prefix + sessionId; log.info("springSessionId: {}",springSessionId); Map<String, String> entries = redisHash.entries(springSessionId); log.info("방법1: Lambda 사용"); entries.forEach((key, value) -> { log.info("key:{}, value:{}", key, value); }); log.info("방법2: entrySet()"); for(Map.Entry<String, String> entry : entries.entrySet()) { log.info("key:{}, value:{}", entry.getKey(), entry.getValue()); } log.info("방법3: keySet()"); for(String key : entries.keySet()) { String value = entries.get(key); log.info("key:{}, value:{}", key, value); } return "hello4"; } }

Redis Cluster 구성도

Redis Server에서 실행되는 명령과 클라이언트 로그

Redis Server에서 실행되는 명령 확인은 redis-cli의 monitor 기능을 사용했습니다.
방법: redis-cli -h ip -p port -a password monitor

http://localhost:8080/hello1

hello1() source

@GetMapping("/hello1") public String hello1(HttpSession session) { // 속성명: hello1, 값: Charlie session.setAttribute("hello1","Charlie"); log.info("hello1 Charlie"); return "hello1 Charlie"; }

레디스 서버에서 실행되는 명령

처음 실행: 새 브라우저에서 처음 실행할 때

Master1 (마스터1)

• 총 4 개 명령 실행: 레디스 서버 접속 관련 명령 4개 실행
• 세션 관련 명령은 마스터3에서 실행되었다.

Master2 (마스터2)

• 총 6 개 명령 실행: 레디스 서버 접속 관련 명령 6개 실행

Master3 (마스터3)

• 총 7 개 명령 실행: 레디스 서버 접속 관련 명령 5개 실행, Spring Session 명령 2개 실행.
• 세선 키가 Master3에 할당되었다.
• HMSET 명령은 4개 필드 lastAccessedTime, maxInactiveInterval, creationTime, sessionAttr를 저장한다.
• 가능한 한 줄에 보이게 하려고 'spring:session:sessions:c6c7eb8c-ddbe-4ce3-a9f4-65323791222e' 에서 'spring:session:sessions:' 부분을 삭제했다.

Replica1 (복제1)

• 총 11 개 명령 실행: 레디스 서버 접속 관련 명령 6개 실행, 조회 명령 3개, 마스터에서 전파된 Spring Session 명령 2개 실행.
• Client에서 실행된 명령 3개는 조회 명령은 복제서버에서 실행되도록 readFrom을 설정했기 때문이다.

Replica2 (복제2)

• 레디스 서버 접속 관련 명령 4개 실행

Replica3 (복제3)

• 레디스 서버 접속 관련 명령 4개 실행

두 번째 실행

Master (마스터)

Master2 (마스터2)

Master3 (마스터3)

• 세선 키가 Master3에 할당되었다.

Replica1 (복제1)

• 조회 명령 4개와 마스터에서 전파된 2개 명령이 실행되었다.

Replica2 (복제2)

Replica3 (복제3)

명령이 마스터와 복제에서 분산 실행되므로 문제가 발생할까?

마스터3과 복제1에서 분산되어서 실행되는 명령을 시간 순으로 살펴보자.

1. 137ms: 복제1 HGETALL 명령 실행
2. 154ms: 복제1 EXISTS 명령 실행, 17ms 차이
3. 167ms: 마스터3 HMSET 명령 실행, 13ms 차이
4. 167ms: 복제1 HMSET 명령 실행, 0ms 차이
5. 174ms: 마스터3 PEXPIREAT 명령 실행, 7ms 차이
6. 174ms: 복제1 PEXPIREAT 명령 실행, 0ms 차이
7. 188ms: 복제1 HGETALL 명령 실행, 14ms 차이
8. 205ms: 복제1 EXISTS 명령 실행, 17ms 차이

명령 사이의 시간 간격은 약 10ms이고, 마스터에서 복제서버로 전파되는 시간은 1ms 이내이다.
그러므로 일련의 명령이 복제서버와 마스터에서 나누어서(분산) 실행되어도 순서가 바뀌어서 문제가 될 확률은 거의 없다.
(이 측정치는 부하(load) 정도, 서버나 네트워크 상황에 따라서 다를 수 있습니다)

http://localhost:8080/hello2

hello2() source

@GetMapping("/hello2") public String hello2(HttpSession session) { // 속성명: hello2-1, 값: Kwon-1 // 속성명: hello2-2, 값: Kwon-2 session.setAttribute("hello2-1","Kwon-1"); session.setAttribute("hello2-2","Kwon-2"); log.info("hello2 Kwon"); return "hello2 Kwon"; }

레디스 서버에서 실행되는 명령

Master1 (마스터1)

Master2 (마스터2)

Master3 (마스터3)

• 마스터에서는 2개 명령이 실행된다. 마스터 서버의 부담이 줄었다.
• setAttribute()로 인해서 HMSET 명령에 sessionAttr:hello2-2, sessionAttr:hello2-1 필드와 값이 추가되었다.

Replica1 (복제1)

• 부하분산을 위한 readFrom 설정 효과로 조회 명령이 복제1에서 실행되었다.
• 클라이언트로 부터 조회 명령 4개와 마스터에서 전파된 2개 명령이 실행되었다.

Replica2 (복제2)

Replica3 (복제3)

http://localhost:8080/hello3

hello3() source

@GetMapping("/hello3") public String hello3(HttpSession session) { // 속성명 지정해서 값 가져오기 String hello1Value = (String) session.getAttribute("hello1"); log.info("hello1 Value: {}",hello1Value); // 모든 속성명, 값 가져오기 Enumeration<?> attrName = session.getAttributeNames(); while (attrName.hasMoreElements()) { String attr = (String) attrName.nextElement(); log.info("{}:{}",attr,session.getAttribute(attr)); } // Session ID, 생성일시, 마지막 액세스(접근) 일시 가져오기 String sessionId = session.getId(); Date ctime = new Date(session.getCreationTime()); Date atime = new Date(session.getLastAccessedTime()); log.info("sessionId: {}",sessionId); log.info("CreationTime: {}",ctime); log.info("LastAccessedTime: {}",atime); return "hello3"; }

레디스 서버에서 실행되는 명령

Master1 (마스터1)

Master2 (마스터2)

Master3 (마스터3)

• 마스터에서는 2개 명령이 실행된다. 마스터 서버의 부담이 줄었다.

Replica1 (복제1)

• 부하분산을 위한 readFrom 설정 효과로 조회 명령이 복제1에서 실행되었다.
• 클라이언트로 부터 조회 명령 4개와 마스터에서 전파된 2개 명령이 실행되었다.

Replica2 (복제2)

Replica3 (복제3)

http://localhost:8080/hello4

hello4() source

@GetMapping("/hello4") @SuppressWarnings("unchecked") public String hello4(HttpSession session) { // Redis HGETALL 명령으로 데이터 가져오기. 메서드 명은 redisHash.entries() String prefix = "spring:session:sessions:"; String sessionId = session.getId(); String springSessionId = prefix + sessionId; log.info("springSessionId: {}",springSessionId); Map<String, String> entries = redisHash.entries(springSessionId); log.info("방법1: Lambda 사용"); entries.forEach((key, value) -> { log.info("key:{}, value:{}", key, value); }); log.info("방법2: entrySet()"); for(Map.Entry<String, String> entry : entries.entrySet()) { log.info("key:{}, value:{}", entry.getKey(), entry.getValue()); } log.info("방법3: keySet()"); for(String key : entries.keySet()) { String value = entries.get(key); log.info("key:{}, value:{}", key, value); } return "hello4"; }

레디스 서버에서 실행되는 명령

Master1 (마스터1)

Master2 (마스터2)

Master3 (마스터3)

Replica1 (복제1)

• 부하분산을 위한 readFrom 설정 효과로 조회 명령이 복제2에서 실행되었다.
• 조회 명령 5개와 마스터에서 전파된 명령 2개가 순서대로 실행되었다.
• 소스 "Map entries = redisHash.entries(springSessionId);" 의 결과로 두 번째 HGETALL이 실행되었다.

Replica2 (복제2)

Replica3 (복제3)