refactor: redis를 활용한 조회 성능 최적화

docker-compose.yml

@@ -19,6 +19,11 @@ services:
       caddy.log.output: stdout
       caddy.log.format: json
       caddy.log.include: http.log.access.localhost
+    logging:
+      driver: "json-file"
+      options:
+        max-size: "10m"
+        max-file: "10"
 
   swagger:
     image: swaggerapi/swagger-ui
@@ -42,9 +47,23 @@ services:
     labels:
       caddy.route: /docs*
       caddy.route.reverse_proxy: "{{ upstreams 8080 }}"
+    logging:
+      driver: "json-file"
+      options:
+        max-size: "10m"
+        max-file: "10"
+
+  redis:
+    image: redis:alpine
+    container_name: redis
+    hostname: redis
+    ports:
+      - 6379:6379
+    networks:
+      - caddy
 
   nestjs-green:
-    image: makerscrew/server:latest
+    image: makerscrew/server:develop
     container_name: nestjs-green
     ports:
       - 3001:3000
@@ -107,17 +126,28 @@ services:
       caddy.route_14.reverse_proxy: "{{ upstreams 3000 }}"
 
   spring-green:
-    image: makerscrew/main:latest
+    image: makerscrew/main:develop
     environment:
-      - TZ=Asia/Seoul
+      TZ: Asia/Seoul
     container_name: spring-green
     ports:
       - 4001:4000
+      - 5556:5555
     restart: unless-stopped
     depends_on:
       - nestjs-green
+      - pinpoint-agent
+      - redis
+    logging:
+      driver: "json-file"
+      options:
+        max-size: "10m"
+        max-file: "100"
     networks:
       - caddy
+    volumes:
+      - data-volume:/pinpoint-agent
+
     labels:
       caddy.log: "localhost"
       # for Swagger spec
@@ -152,9 +182,17 @@ services:
       caddy.route_13.reverse_proxy: "{{ upstreams 4000 }}"
       caddy.route_14: /auth/v2/*
       caddy.route_14.reverse_proxy: "{{ upstreams 4000 }}"
+      caddy.route_15: /8da2d7e6-72aa-4120-9e84-8f459a2584a1/*
+      caddy.route_15.reverse_proxy: "{{ upstreams 5555 }}"
+      caddy.route_16: /internal/*
+      caddy.route_16.reverse_proxy: "{{ upstreams 4000 }}"
 
   nestjs-blue:
-    image: makerscrew/server:latest
+    image: makerscrew/server:develop
+    container_name: nestjs-blue
+    ports:
+      - 3002:3000
+    restart: unless-stopped
     env_file:
       - ./.env
     environment:
@@ -170,10 +208,11 @@ services:
       - AWS_SECRET_ACCESS_KEY=${AWS_SECRET_ACCESS_KEY}
       - AWS_REGION=${AWS_REGION}
       - JWT_SECRET=${JWT_SECRET}
-    container_name: nestjs-blue
-    ports:
-      - 3002:3000
-    restart: unless-stopped
+    logging:
+      driver: "json-file"
+      options:
+        max-size: "10m"
+        max-file: "10"
     networks:
       - caddy
     labels:
@@ -212,17 +251,27 @@ services:
       caddy.route_14.reverse_proxy: "{{ upstreams 3000 }}"
 
   spring-blue:
-    image: makerscrew/main:latest
+    image: makerscrew/main:develop
     environment:
-      - TZ=Asia/Seoul
+      TZ: Asia/Seoul
     container_name: spring-blue
     ports:
       - 4002:4000
+      - 5557:5555
     restart: unless-stopped
     depends_on:
       - nestjs-blue
+      - pinpoint-agent
+      - redis
+    logging:
+      driver: "json-file"
+      options:
+        max-size: "10m"
+        max-file: "100"
     networks:
       - caddy
+    volumes:
+      - data-volume:/pinpoint-agent
     labels:
       caddy.log: "localhost"
       # for Swagger spec
@@ -257,7 +306,14 @@ services:
       caddy.route_13.reverse_proxy: "{{ upstreams 4000 }}"
       caddy.route_14: /auth/v2/*
       caddy.route_14.reverse_proxy: "{{ upstreams 4000 }}"
+      caddy.route_15: /8da2d7e6-72aa-4120-9e84-8f459a2584a1/*
+      caddy.route_15.reverse_proxy: "{{ upstreams 5555 }}"
+      caddy.route_16: /internal/*
+      caddy.route_16.reverse_proxy: "{{ upstreams 4000 }}"
+
+volumes:
+  data-volume:
 
 networks:
   caddy:
-    external: true
+    external: true

main/build.gradle

@@ -99,6 +99,13 @@ dependencies {
 
     // Slack Webhook
     implementation 'com.github.maricn:logback-slack-appender:1.4.0'
+
+    // redis
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+    implementation 'org.springframework.boot:spring-boot-starter-cache'
+    implementation 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310'
+    implementation 'com.fasterxml.jackson.datatype:jackson-datatype-hibernate6'
+
 }
 
 tasks.named('test') {

main/src/main/java/org/sopt/makers/crew/main/auth/v2/service/AuthV2ServiceImpl.java

@@ -1,15 +1,16 @@
 package org.sopt.makers.crew.main.auth.v2.service;
 
-import java.util.Optional;
-
 import org.sopt.makers.crew.main.auth.v2.dto.request.AuthV2RequestDto;
 import org.sopt.makers.crew.main.auth.v2.dto.response.AuthV2ResponseDto;
+import org.sopt.makers.crew.main.entity.meeting.CoLeaderRepository;
 import org.sopt.makers.crew.main.global.jwt.JwtTokenProvider;
 import org.sopt.makers.crew.main.entity.user.User;
 import org.sopt.makers.crew.main.entity.user.UserRepository;
 import org.sopt.makers.crew.main.external.playground.PlaygroundService;
 import org.sopt.makers.crew.main.external.playground.dto.request.PlaygroundUserRequestDto;
 import org.sopt.makers.crew.main.external.playground.dto.response.PlaygroundUserResponseDto;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Caching;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -23,42 +24,69 @@
 public class AuthV2ServiceImpl implements AuthV2Service {
 
 	private final UserRepository userRepository;
+	private final CoLeaderRepository coLeaderRepository;
 
 	private final PlaygroundService playgroundService;
 	private final JwtTokenProvider jwtTokenProvider;
 
 	@Override
 	@Transactional
 	public AuthV2ResponseDto loginUser(AuthV2RequestDto requestDto) {
+		PlaygroundUserResponseDto responseDto = fetchPlaygroundUser(requestDto);
+		User curUser = userRepository.findByOrgId(responseDto.getId())
+			.orElseGet(() -> signUpNewUser(responseDto));
 
-		// 플그 서버로의 요청
-		PlaygroundUserResponseDto responseDto = playgroundService.getUser(PlaygroundUserRequestDto.of(requestDto.authToken()));
-		Optional<User> user = userRepository.findByOrgId(responseDto.getId());
-
-		/**
-		 * @note: 회원가입 경우
-		 *
-		 * */
-		if (user.isEmpty()) {
-			User newUser = responseDto.toEntity();
-			userRepository.save(newUser);
-
-			log.info("new user signup : {} {}", newUser.getId(), newUser.getName());
-			String accessToken = jwtTokenProvider.generateAccessToken(newUser.getId(), newUser.getName());
-			return AuthV2ResponseDto.of(accessToken);
+		if (updateUserIfChanged(curUser, responseDto)) {
+			clearCacheForUser(curUser.getId());
 		}
 
-		/**
-		 * @note: 로그인 경우 : 기존 정보에서 변화있는 부분은 업데이트 한다.
-		 *
-		 * */
-		User curUser = user.get();
-		curUser.updateUser(responseDto.getName(), responseDto.getId(), responseDto.getUserActivities(),
-			responseDto.getProfileImage(), responseDto.getPhone());
-
 		String accessToken = jwtTokenProvider.generateAccessToken(curUser.getId(), curUser.getName());
-		log.info("accessToken : {}", accessToken);
-
+		log.info("Access token generated for user {}: {}", curUser.getId(), accessToken);
 		return AuthV2ResponseDto.of(accessToken);
 	}
+
+	private PlaygroundUserResponseDto fetchPlaygroundUser(AuthV2RequestDto requestDto) {
+		return playgroundService.getUser(PlaygroundUserRequestDto.of(requestDto.authToken()));
+	}
+
+	private User signUpNewUser(PlaygroundUserResponseDto responseDto) {
+		User newUser = responseDto.toEntity();
+		User savedUser = userRepository.save(newUser);
+		log.info("New user signup: {} {}", savedUser.getId(), savedUser.getName());
+		return savedUser;
+	}
+
+	private boolean updateUserIfChanged(User curUser, PlaygroundUserResponseDto responseDto) {
+		User playgroundUser = responseDto.toEntity();
+		boolean isUpdated = curUser.updateIfChanged(playgroundUser);
+
+		if (isUpdated) {
+			log.info("User updated: {}", curUser.getId());
+		}
+
+		return isUpdated;
+	}
+
+	private void clearCacheForUser(Integer userId) {
+		clearCacheForLeader(userId);
+
+		coLeaderRepository.findAllByUserIdWithMeeting(userId).forEach(
+			coLeader -> clearCacheForCoLeader(coLeader.getMeeting().getId())
+		);
+		log.info("Cache cleared for user: {}", userId);
+	}
+
+	@Caching(evict = {
+		@CacheEvict(value = "meetingLeaderCache", key = "#userId")
+	})
+	public void clearCacheForLeader(Integer userId) {
+
+	}
+
+	@Caching(evict = {
+		@CacheEvict(value = "coLeadersCache", key = "#meetingId")
+	})
+	public void clearCacheForCoLeader(Integer meetingId) {
+
+	}
 }

main/src/main/java/org/sopt/makers/crew/main/entity/apply/Apply.java

@@ -1,41 +1,38 @@
 package org.sopt.makers.crew.main.entity.apply;
 
-import static jakarta.persistence.GenerationType.IDENTITY;
+import static jakarta.persistence.GenerationType.*;
 import static org.sopt.makers.crew.main.global.exception.ErrorStatus.*;
 
+import java.time.LocalDateTime;
+
+import org.sopt.makers.crew.main.entity.apply.enums.ApplyStatusConverter;
+import org.sopt.makers.crew.main.entity.apply.enums.ApplyTypeConverter;
+import org.sopt.makers.crew.main.entity.apply.enums.EnApplyStatus;
+import org.sopt.makers.crew.main.entity.apply.enums.EnApplyType;
+import org.sopt.makers.crew.main.entity.common.BaseTimeEntity;
+import org.sopt.makers.crew.main.entity.meeting.Meeting;
+import org.sopt.makers.crew.main.entity.user.User;
+import org.sopt.makers.crew.main.global.exception.BadRequestException;
+import org.springframework.data.annotation.CreatedDate;
+
 import jakarta.persistence.Column;
 import jakarta.persistence.Convert;
 import jakarta.persistence.Entity;
-import jakarta.persistence.EntityListeners;
 import jakarta.persistence.FetchType;
 import jakarta.persistence.GeneratedValue;
 import jakarta.persistence.Id;
 import jakarta.persistence.JoinColumn;
 import jakarta.persistence.ManyToOne;
 import jakarta.persistence.Table;
-
-import java.time.LocalDateTime;
-
 import lombok.AccessLevel;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
-import org.sopt.makers.crew.main.entity.common.BaseTimeEntity;
-import org.sopt.makers.crew.main.global.exception.BadRequestException;
-import org.sopt.makers.crew.main.entity.apply.enums.ApplyStatusConverter;
-import org.sopt.makers.crew.main.entity.apply.enums.ApplyTypeConverter;
-import org.sopt.makers.crew.main.entity.apply.enums.EnApplyStatus;
-import org.sopt.makers.crew.main.entity.apply.enums.EnApplyType;
-import org.sopt.makers.crew.main.entity.meeting.Meeting;
-import org.sopt.makers.crew.main.entity.user.User;
-import org.springframework.data.annotation.CreatedDate;
-import org.springframework.data.jpa.domain.support.AuditingEntityListener;
-
 @Entity
 @Getter
-@NoArgsConstructor(access = AccessLevel.PROTECTED)
 @Table(name = "apply")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
 public class Apply extends BaseTimeEntity {
 
 	/**

main/src/main/java/org/sopt/makers/crew/main/entity/common/BaseTimeEntity.java

@@ -6,6 +6,11 @@
 import org.springframework.data.annotation.LastModifiedDate;
 import org.springframework.data.jpa.domain.support.AuditingEntityListener;
 
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
+import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
+
 import jakarta.persistence.Column;
 import jakarta.persistence.EntityListeners;
 import jakarta.persistence.MappedSuperclass;
@@ -16,10 +21,14 @@ public abstract class BaseTimeEntity {
 
 	@CreatedDate
 	@Column(name = "createdTimestamp")
+	@JsonSerialize(using = LocalDateTimeSerializer.class)
+	@JsonDeserialize(using = LocalDateTimeDeserializer.class)
 	public LocalDateTime createdTimestamp;
 
 	@LastModifiedDate
 	@Column(name = "modifiedTimestamp")
+	@JsonSerialize(using = LocalDateTimeSerializer.class)
+	@JsonDeserialize(using = LocalDateTimeDeserializer.class)
 	public LocalDateTime modifiedTimestamp;
 
 }

main/src/main/java/org/sopt/makers/crew/main/entity/meeting/CoLeader.java

@@ -43,7 +43,7 @@ public class CoLeader extends BaseTimeEntity {
 
 	@Builder
 	private CoLeader(Meeting meeting, User user) {
-		if (Objects.equals(meeting.getUserId(), user.getId())) {
+		if (meeting != null && Objects.equals(meeting.getUserId(), user.getId())) {
 			throw new BadRequestException(LEADER_CANNOT_BE_CO_LEADER_APPLY.getErrorCode());
 		}
 		this.meeting = meeting;

main/src/main/java/org/sopt/makers/crew/main/entity/meeting/CoLeaderReader.java

@@ -0,0 +1,24 @@
+package org.sopt.makers.crew.main.entity.meeting;
+
+import java.util.List;
+
+import org.sopt.makers.crew.main.meeting.v2.dto.redis.CoLeadersRedisDto;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+
+import lombok.RequiredArgsConstructor;
+
+@Repository
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class CoLeaderReader {
+	private final CoLeaderRepository coLeaderRepository;
+
+	@Cacheable(value = "coLeadersCache", key = "#meetingId")
+	public CoLeadersRedisDto getCoLeaders(Integer meetingId) {
+		List<CoLeader> coLeaders = coLeaderRepository.findAllByMeetingId(meetingId);
+
+		return new CoLeadersRedisDto(coLeaders);
+	}
+}