Feat: redis session storage

Author: skyeong42

src/main/java/cmf/commitField/domain/chat/chatRoom/service/ChatRoomServiceImpl.java

@@ -122,8 +122,8 @@ public List<ChatRoomDto> getRoomList(Pageable pageable) {
     @Override
     @Transactional(readOnly = true)
     public List<ChatRoomDto> roomsByCreatorUser(Long userId, Pageable pageable) {
-        Page<ChatRoom> all = chatRoomRepository.findAllByUserId(userId, pageable);
-        return getChatRoomDtos(all);
+        Page<ChatRoom> userCreateAll = chatRoomRepository.findAllByUserId(userId, pageable);
+        return getChatRoomDtos(userCreateAll);
     }
 
     // 자신이 참여한 방 리스트 조회

src/main/java/cmf/commitField/global/config/RedisConfig.java

@@ -0,0 +1,38 @@
+package cmf.commitField.global.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+    @Value("${spring.redis.host}")
+    public String host;
+
+    @Value("${spring.redis.port}")
+    public int port;
+
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
+        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setKeySerializer(new StringRedisSerializer()); // Redis 키를 문자열로 직렬화
+        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // 값의 직렬화를 위해 -> Redis (JSON)
+        redisTemplate.setConnectionFactory(connectionFactory); // 연결 다 된 Redis -> Factory와 연결
+        return redisTemplate;
+    }
+
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory() {
+        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration();
+        configuration.setHostName(host);
+        configuration.setPort(port);
+        return new LettuceConnectionFactory(configuration);
+    }
+}

src/main/java/cmf/commitField/global/websocket/ChatWebSocketHandler.java

@@ -16,7 +16,7 @@
 @Slf4j
 public class ChatWebSocketHandler implements WebSocketHandler {
 
-    private Map<Long, List<WebSocketSession>> chatRooms = new HashMap<>();
+    private final Map<Long, List<WebSocketSession>> chatRooms = new HashMap<>();
     // 방의 키값
 
 
@@ -92,8 +92,15 @@ private Long extractRoomId(WebSocketSession session) {
         String[] uriParts = uri.split("/");
         // EX_URL) /chat/room/{roomId} 일 때 roomId 추출
         // 늘어난다면 수 변경해주면.. (일단 임시로 설정)
-        if (uriParts.length >= 3 && uriParts[2].equals("room")) {
-            roomId = Long.valueOf(uriParts[3]);
+//        if (uriParts.length >= 3 && uriParts[2].equals("room")) {
+//            roomId = Long.valueOf(uriParts[3]);
+        if (uriParts.length >= 4 && uriParts[2].equals("msg")) {
+            return Long.valueOf(uriParts[3]);
+        }
+        // /chat/room/join/{roomId}, /chat/room/out/{roomId}, /chat/room/delete/{roomId} 일 때 roomId 추출
+        if (uriParts.length >= 5 && uriParts[2].equals("room") &&
+                (uriParts[3].equals("join") || uriParts[3].equals("out") || uriParts[3].equals("delete"))) {
+            roomId = Long.valueOf(uriParts[4]);
         }
         return roomId;
     }