#30 웹소켓을 이용한 1:1 채팅 구현

src/main/java/com/market/server/controller/ChattingController.java

@@ -1,18 +1,11 @@
 package com.market.server.controller;
-
 import com.market.server.dto.RoomDTO;
 import com.market.server.service.ChattingService;
 import io.swagger.annotations.Api;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-import lombok.Setter;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.ModelAndView;
-
-import java.util.ArrayList;
-import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -22,8 +15,6 @@
 @Log4j2
 public class ChattingController {
 
-    static int roomNumber = 0;
-    private ChattingResponse chattingResponse;
     private final ChattingService chattingService;
 
     @Autowired
@@ -51,10 +42,11 @@ public ModelAndView room() {
      */
     @PostMapping("/rooms")
     public @ResponseBody
-    List<RoomDTO> createRoom(@RequestParam HashMap<Object, Object> params, ChattingRequest chattingRequest) {
+    List<RoomDTO> createRoom(@RequestParam HashMap<String, String> params) {
         String roomName = (String) params.get("roomName");
         RoomDTO roomDTO = null;
         if (roomName != null && !roomName.trim().equals("")) {
+            int roomNumber = chattingService.getLastRoomNumber();
             roomDTO = RoomDTO.builder()
                     .roomNumber(++roomNumber)
                     .roomName(roomName)
@@ -73,7 +65,7 @@ List<RoomDTO> createRoom(@RequestParam HashMap<Object, Object> params, ChattingR
      */
     @GetMapping("/rooms")
     public @ResponseBody
-    List<RoomDTO> getRoom(@RequestParam HashMap<Object, Object> params, @RequestBody RoomDTO roomDTO) {
+    List<RoomDTO> getRoom(@RequestBody RoomDTO roomDTO) {
         return chattingService.getRooms(roomDTO);
     }
 
@@ -83,37 +75,19 @@ List<RoomDTO> getRoom(@RequestParam HashMap<Object, Object> params, @RequestBody
      * @return
      */
     @GetMapping("/chatting")
-    public ModelAndView moveRoom(@RequestParam HashMap<Object, Object> params) {
+    public ModelAndView moveRoom(@RequestParam HashMap<String, String> params) {
         ModelAndView mv = new ModelAndView();
         int roomNumber = Integer.parseInt((String) params.get("roomNumber"));
 
-        List<RoomDTO> new_list = chattingService.getRooms(null).stream().filter(o->o.getRoomNumber()==roomNumber).collect(Collectors.toList());
-        if(new_list != null && new_list.size() > 0) {
+        List<RoomDTO> new_list = chattingService.getRooms(null).stream().filter(o -> o.getRoomNumber() == roomNumber).collect(Collectors.toList());
+        if (new_list != null && new_list.size() > 0) {
             mv.addObject("roomName", params.get("roomName"));
             mv.addObject("roomNumber", params.get("roomNumber"));
             mv.setViewName("chat");
-        }else {
+        } else {
             mv.setViewName("room");
         }
         return mv;
     }
 
-    // -------------- response 객체 --------------
-
-    @Getter
-    @AllArgsConstructor
-    private static class ChattingResponse {
-        private List<RoomDTO> roomDTOList;
-    }
-
-    // -------------- request 객체 --------------
-
-    @Setter
-    @Getter
-    private static class ChattingRequest {
-        private int roomNumber;
-        private String roomName;
-        private RoomDTO.Status status;
-        private Date updatetime;
-    }
 }

src/main/java/com/market/server/dto/RoomDTO.java

@@ -21,7 +21,6 @@ public enum SortStatus {
     private Status status;
     private Date createtime;
     private Date updatetime;
-    private List<RoomDTO> roomDTOList;
     private SortStatus sortStatus;
     private int searchCount;
     private int pagingStartOffset;
@@ -36,7 +35,6 @@ public RoomDTO(@NonNull int roomNumber, String roomName) {
         this.roomNumber = roomNumber;
         this.roomName = roomName;
         this.createtime = new Date();
-        roomDTOList = new ArrayList<RoomDTO>();
         SortStatus sortStatus = SortStatus.NEWEST;
         searchCount = 10;
         pagingStartOffset = 0;

src/main/java/com/market/server/mapper/ChattingMapper.java

@@ -8,5 +8,6 @@
 
 public interface ChattingMapper {
     public int register(RoomDTO roomDTO);
-    public List<RoomDTO> selectRooms(RoomDTO roomDTO);
+    public List<RoomDTO> selectRooms(String sortStatus, int searchCount, int pagingStartOffset);
+    public int getLastRoomNumber();
 }

src/main/java/com/market/server/service/ChattingService.java

@@ -1,9 +1,11 @@
 package com.market.server.service;
+
 import com.market.server.dto.RoomDTO;
 import com.market.server.mapper.ChattingMapper;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+
 import java.util.List;
 
 @Service
@@ -21,12 +23,20 @@ public void register(RoomDTO roomDTO) {
             throw new RuntimeException("register ERROR! 채팅방 등록 메서드를 확인해주세요\n" + "Params : " + roomDTO);
         }
     }
-    
+
     // 채팅방 목록 찾기
     public List<RoomDTO> getRooms(RoomDTO roomDTO) {
-        List<RoomDTO> roomDTOList = chattingMapper.selectRooms(roomDTO);
+        List<RoomDTO> roomDTOList = null;
+        if (roomDTO == null)
+            roomDTOList = chattingMapper.selectRooms("NEWEST", 20, 0);
+        else
+            roomDTOList = chattingMapper.selectRooms(roomDTO.getSortStatus().toString(), roomDTO.getSearchCount(), roomDTO.getPagingStartOffset());
         return roomDTOList;
     }
 
+    public int getLastRoomNumber() {
+        return chattingMapper.getLastRoomNumber();
+    }
+
 }
 

src/main/resources/application-dev.properties

@@ -0,0 +1,22 @@
+# mysql
+spring.datasource.url=jdbc:mysql://localhost:3307/market?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Seoul
+spring.datasource.username=root
+spring.datasource.password=wnstjr1026
+
+# message
+spring.messages.basename=i18n/exception
+spring.messages.encoding=UTF-8
+
+# redis
+spring.cache.type=redis
+spring.data.redis.repositories.enabled=true
+market.server.redis.host=localhost
+market.server.redis.port=6379
+market.server.redis.password=
+
+# expire
+expire.defaultTime=36288000
+
+#JSP, HTML ModelAndView Path Setting
+spring.mvc.view.prefix=/WEB-INF/jsp/
+spring.mvc.view.suffix=.jsp

src/main/resources/application-release.properties

@@ -0,0 +1,18 @@
+# mysql
+spring.datasource.url=jdbc:mysql://localhost:3307/market?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Seoul
+spring.datasource.username=root
+spring.datasource.password=wnstjr1026
+
+# message
+spring.messages.basename=i18n/exception
+spring.messages.encoding=UTF-8
+
+# redis
+spring.cache.type=redis
+spring.data.redis.repositories.enabled=true
+market.server.redis.host=localhost
+market.server.redis.port=6379
+market.server.redis.password=
+
+# expire
+expire.defaultTime=36288000

src/main/resources/application.properties

@@ -1,25 +1,8 @@
-# mysql
-spring.datasource.url=jdbc:mysql://localhost:3307/market?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Seoul
-spring.datasource.username=root
-spring.datasource.password=wnstjr1026
-
-# message
-spring.messages.basename=i18n/exception
-spring.messages.encoding=UTF-8
-
-# redis
-spring.cache.type=redis
-spring.data.redis.repositories.enabled=true
-market.server.redis.host=localhost
-market.server.redis.port=6379
-market.server.redis.password=
-
-# expire
-expire.defaultTime=36288000
-
-# tomcat
+# Server
 server.port=8888
 
-#JSP, HTML ModelAndView Path Setting
-spring.mvc.view.prefix=/WEB-INF/jsp/
-spring.mvc.view.suffix=.jsp
+# profile name = local, dev, prod
+spring.profiles.active=dev
+
+# session
+spring.session.store-type=redis

src/main/resources/mybatis/mapper/chattingMapper.xml

@@ -15,29 +15,22 @@
         `roomName`,
         `type`
         FROM `room`
-        LIMIT 100 OFFSET 0
+        <choose>
+            <when test="sortStatus == 'NEWEST'">
+                ORDER BY createtime DESC
+            </when>
+            <when test="sortStatus == 'OLDEST'">
+                ORDER BY createtime ASC
+            </when>
+        </choose>
+        LIMIT #{searchCount, jdbcType=INTEGER} OFFSET #{pagingStartOffset, jdbcType=INTEGER}
     </select>
 
-<!--    <select id="selectRooms" resultType="com.market.server.dto.RoomDTO">-->
-<!--            SELECT `id`,-->
-<!--            `title`,-->
-<!--            `type`,-->
-<!--            FROM `room`-->
-<!--        <choose>-->
-<!--            <when test="sortStatus.toString() == 'NEWEST'">-->
-<!--                ORDER BY createtime DESC-->
-<!--            </when>-->
-<!--            <when test="sortStatus.toString() == 'OLDEST'">-->
-<!--                ORDER BY createtime ASC-->
-<!--            </when>-->
-<!--            <when test="sortStatus.toString() == 'GRADE'">-->
-<!--                LEFT JOIN user-->
-<!--                ON product.accountId = user.accountId-->
-<!--                GROUP BY user.accountId-->
-<!--                ORDER BY user.grade DESC-->
-<!--            </when>-->
-<!--        </choose>-->
-<!--        LIMIT #{searchCount, jdbcType=INTEGER} OFFSET #{pagingStartOffset, jdbcType=INTEGER}-->
-<!--    </select>-->
+    <select id="getLastRoomNumber" resultType="int">
+        SELECT roomNumber
+        FROM room
+        ORDER BY roomNumber
+        DESC LIMIT 1;
+    </select>
 
 </mapper>