Merge pull request #78 from 28th-meetup/feat/chat-1201

feat: 메세지 저장과정 비동기 설정

README.md

@@ -1,3 +1,4 @@
+
 # 🍱 집밥도착 🍱
 
 <img width="1920" alt="1" src="https://github.com/kusitms-com/28th_Semi_README/assets/81168401/76e8c2f8-0e82-4d20-b5ff-66985d078208">

src/main/java/com/kusitms/jipbap/chat/service/MessageReleaseService.java

@@ -0,0 +1,41 @@
+package com.kusitms.jipbap.chat.service;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.kusitms.jipbap.chat.model.dto.MessageDto;
+import com.kusitms.jipbap.chat.model.entity.Message;
+import com.kusitms.jipbap.chat.model.entity.Room;
+import com.kusitms.jipbap.chat.repository.MessageRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class MessageReleaseService {
+
+    private final RedisTemplate<String, MessageDto> redisTemplateMessage;
+    private final MessageRepository messageRepository;
+    private final ObjectMapper objectMapper;
+
+    @Async
+    public void saveMessage(MessageDto messageDto, Room room) {
+        // DB 저장
+        Message message = messageRepository.save(new Message(messageDto.getSenderName(), room, messageDto.getMessage()));
+        message.updateSentTime(message.getCreatedAt().toString());
+
+        // 1. 직렬화
+        redisTemplateMessage.setValueSerializer(new GenericJackson2JsonRedisSerializer(objectMapper));
+
+        // 2. redis 저장
+        redisTemplateMessage.opsForList().rightPush(messageDto.getRoomId(), messageDto);
+
+        // 3. redistemplate의 expire() 을 이용해서, Key 를 만료시킬 수 있음
+        redisTemplateMessage.expire(messageDto.getRoomId(), 60, TimeUnit.MINUTES);
+    }
+}

src/main/java/com/kusitms/jipbap/chat/service/MessageService.java

@@ -1,23 +1,20 @@
 package com.kusitms.jipbap.chat.service;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
+import com.kusitms.jipbap.chat.exception.RoomNotExistsException;
 import com.kusitms.jipbap.chat.model.dto.MessageDto;
 import com.kusitms.jipbap.chat.model.entity.Message;
 import com.kusitms.jipbap.chat.model.entity.Room;
-import com.kusitms.jipbap.chat.exception.RoomNotExistsException;
 import com.kusitms.jipbap.chat.repository.MessageRepository;
 import com.kusitms.jipbap.chat.repository.RoomRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.concurrent.TimeUnit;
 
 @Slf4j
 @Service
@@ -26,7 +23,7 @@ public class MessageService {
     private final RedisTemplate<String, MessageDto> redisTemplateMessage;
     private final MessageRepository messageRepository;
     private final RoomRepository roomRepository;
-    private final ObjectMapper objectMapper;
+    private final MessageReleaseService messageReleaseService;
 
     // 메세지 저장
     @Transactional
@@ -35,18 +32,7 @@ public void saveMessage(MessageDto messageDto) {
                 ()->new RoomNotExistsException("채팅방이 더 이상 존재하지 않습니다.")
         );
 
-        // DB 저장
-        Message message = messageRepository.save(new Message(messageDto.getSenderName(), room, messageDto.getMessage()));
-        message.updateSentTime(message.getCreatedAt().toString());
-
-        // 1. 직렬화
-        redisTemplateMessage.setValueSerializer(new GenericJackson2JsonRedisSerializer(objectMapper));
-
-        // 2. redis 저장
-        redisTemplateMessage.opsForList().rightPush(messageDto.getRoomId(), messageDto);
-
-        // 3. redistemplate의 expire() 을 이용해서, Key 를 만료시킬 수 있음
-        redisTemplateMessage.expire(messageDto.getRoomId(), 60, TimeUnit.MINUTES);
+        messageReleaseService.saveMessage(messageDto, room);
     }
 
     // 6. 대화 조회 - Redis & DB (TLB 캐시전략 유사)