Java Swing 환경의 텍스트 채팅 애플리케이션으로, Socket 통신과 Multi Thread 프로그래밍으로 구현한 프로그램

• 개발 환경 및 사용 기술
• 실행화면과 기능설명
• 구현 방식
• 서버 애플리케이션
• 클라이언트 애플리케이션

• 개발 환경
  • macOS Monterey 12.4
  • IntelliJ IDEA
  • Java 11
• 사용 기술
  • Java Network Socket
  • AWT, Swing

• 로그인 화면

  • 사용자 아이디와 이름을 입력하는 화면
  • 사용자 아이디: 프로그램 내부에서 사용자를 식별하는 데이터
  • 이름: 사용자 목록과 채팅을 입력한 사람을 표시하는 데이터
  
  

  

  
  

• 로비 화면

  • 로비 채팅 (모든 사용자 채팅 가능)
  • 채팅 프로그램에 접속한 모든 사용자 리스트 출력
  • 채팅방 목록 출력

• 채팅방 생성 화면

  • 채팅방 이름 입력

  • 확인 버튼을 누르면 입력한 문자열을 바탕으로 새로운 채팅방 생성

    • 새로운 채팅 화면 출력
    
    

    

    
    

    • 생성된 채팅방 목록들은 로비에서 확인 가능

      
      

      

      
      

    • 채팅방 목록에서 채팅방 이름 클릭 하면, 해당 채팅 화면 출력

      
      

      

      
      

• 채팅방 화면

  • 해당 채팅방에 접속한 사용자 목록 출력

    
    

    

    
    

  • 나가기 버튼 클릭 하면 채팅창에 퇴장 메시지 출력되고, 사용자 목록 갱신

    
    

    

    
    

  • 모든 사용자가 채팅방에서 나간 경우, 채팅방 이름을 로비의 채팅 목록에서 제거

    • 채팅방 이름1 목록에서 제거

      
      

      

      
      

  • 이미 열려있는 채팅방을 다시 들어가려 할 경우 오류 팝업 출력

    
    

    

    
    

• 서버와 클라이언트는 Socket 으로 통신

• 클라이언트

  • Swing 을 이용해 화면을 구성
  • Thread 를 이용해 자신의 Socket InputSream 을 지속적으로 읽어와서 서버에서 보낸 메시지를 수신

• 서버

  • 각 클라이언트에 대한 Socket 을 Multi Thread 환경으로 관리
  • Multi Thread 를 이용해 모든 사용자들의 Socket InputSream 을 지속적으로 확인
  • 클라이언트가 보낸 메시지를 바탕으로 서버에 저장된 자료구조를 처리하고, 응답을 전송

• 클라이언트와 서버는 문자열 메시지를 주고 받으며, 주고 받는 자료구조는 형식에 따라 모두 문자열로 치환

  • 양쪽에서 동일한 Request Response DTO 를 가지고 있지만 클라이언트의 경우 Request DTO ➔ String 으로 변경해서 송신하고,

    서버는 이를 받아 파싱하여 String ➔ Request DTO 를 생성해 사용

    서버도 마찬가지로 클라이언트로 메시지를 보낼 경우 Response DTO 객체를 생성해 전달할 내용으로 인스턴스를 초기화하고

    Response DTO ➔ String 으로 변경해 클라이언트에게 전송

    클라이언트는 이를 받아 파싱하여 String ➔ Response DTO 를 생성해 사용

  • Request DTO : 클라이언트가 서버에 보내는 메시지 (객체 내용을 문자열로 생성)

  • Response DTO: 서버가 사용자에게 보내는 메시지 (객체 내용을 문자열로 생성)

    • 흐름도

      
      

      

      
      

    • 파싱 데이터 테이블

      DtoType:data 형식의 문자열로 메시지 송수신

      Request 의 전송 주체는 Client, Response 의 전송 주체는 Server

      
      

      

      
      

    • DtoType 에 따라 메시지 송수신부에서 분기 처리

        class enum DtoType {
          	INIT, // 로그인 후 초기 데이터 전송 관련 메시지 (사용자 리스트, 채팅방 리스트)
        
            LOGIN, // 로그인 메시지 (사용자 생성, 리스트에 추가)
            CREATE_CHAT, // 새로운 채팅방 생성 메시지
            ENTER_CHAT, EXIT_CHAT, // 채팅방 입장, 퇴장 메시지
            MESSAGE, // 채팅 메시지
        
            USER_LIST, CHAT_ROOM_LIST, // 사용자 리스트, 채팅방 리스트 메시지
        }

      class DTO {
        	DtoType type;
      
          public DTO(DtoType type) {
              this.type = type;
          }
      
          public DtoType getType() {
              return type;
          }
      
          @Override
          public String toString() {
              return type + ":";
          }
      }

    • 예시 코드

        /* Client Request */
        
        // Client Application
        public class LoginRequest extends DTO {
        
            String id;
        
            String name;
        
            public LoginRequest(String id, String name) {
                super(DtoType.LOGIN);
        
                this.id = id;
                this.name = name;
            }
        
          	// 데이터 보낼 때 객체 내용을 바탕으로 문자열로 바꿔서 전송
            @Override
            public String toString() {
                return super.toString() + id + "," + name;
            }
        }
        
        // Server Application
        public class LoginRequest {
        
            String id;
        
            String name;
        
          	// 스트링 메시지로 수신한 내용을 객체로 파싱해서 사용
            public LoginRequest(String message) {
                String[] value = message.split(",");
                id = value[0];
                name = value[1];
            }
        
            public String getId() {
                return id;
            }
        
            public String getName() {
                return name;
            }
        }		

      /* Server Response */
      
      // Server Application
      public class ChatRoomListResponse extends DTO {
      
          List<ChatRoom> chatRooms;
      
          public ChatRoomListResponse(List<ChatRoom> chatRooms) {
              super(DtoType.CHAT_ROOM_LIST);
      
              this.chatRooms = chatRooms;
          }
      
        	// Object to String
          @Override
          public String toString() {
              String str = super.toString();
      
              for (ChatRoom chatRoom : chatRooms) {
                  str += chatRoom.getName() + ",";
              }
              return (chatRooms.size() > 0) ? str.substring(0, str.length() - 1) : str + "empty";
          }
      }
      
      // Client Application
      public class ChatRoomListResponse {
      
          List<ChatRoom> chatRooms = new ArrayList<>();
      
        	// String to Object
          public ChatRoomListResponse(String message) {
              if (!message.equals("empty")) {
                  String[] names = message.split(",");
                  for(String name : names) {
                      chatRooms.add(new ChatRoom(name));
                  }
              }
          }
      
          public List<ChatRoom> getChatRooms() {
              return chatRooms;
          }
      }

• 클래스 멤버

  class Application {
    
    public static List<Sockets> sockets; // 클라이언트 소켓 리스트
  
    ChatService chatService; // 채팅 데이터 처리 인스턴스 (ServerThread 인스턴스 생성 시 파라미터로 전달)
  
    ChatDao chatDao; // 채팅 데이터 관리 인스턴스 (ChatService 인스턴스 생성 시 파라미터로 전달)
    
  }
  
  ➔ Application 인스턴스는 main 함수 실행 시 한 번만 생성하므로, 애플리케이션에서 사용하는 인스턴스들을 생성해주는 역할
    
  ➔ Application 에서 클라이언트들의 Socket 연결을 대기하며 통신을 위한 소켓을 생성하므로 Socket List 도 함께 관리
    
  
  
  class ServerThread {
    
    Socket socket; // 클라이언트 소켓
  
  	ChatService chatService;
    
  }
  ➔ 각 클라이언트마다 ServerThread 인스턴스를 생성하여 스레드를 동작시켜 메시지 수신
  
    
  class User {
    
    String id; // 아이디
  
    String name; // 이름
  
    Socket socket; // 자신의 소켓 (클라이언트 소켓)
    
  }
  ➔ 사용자 클래스는 자신의 소켓 정보를 저장
  
  ➔ 사용자 인스턴스를 채팅방 사용자 리스트에 추가/삭제하며 메시지 송신 관리
  
    
  class ChatRoom {
    
    String name; // 채팅명
  
  	List<User> users; // 채팅방 내의 사용자 리스트
    
  }
  ➔ 채팅방 입장/퇴장에 따라 사용자 리스트에 User 인스턴스를 삽입 또는 삭제
    
  ➔ 각 채팅방에 관리되고있는 사용자 리스트를 바탕으로 서버에서 메시지 송신
  
  ➔ User 인스턴스 안에 Socket 정보가 있으므로 개별적인 채팅방 처리가 가능
    
    
    
  class ChatService {
    
    ChatDao chatDao;
    
  }
  ➔ DAO 에서 제공하는 메서드를 이용해, 채팅 프로그램에서 사용하는 데이터를 가져와서 처리
    
  
  class ChatDao {
    
    List<User> users; // 접속 중인 모든 사용자 리스트
  
    List<ChatRoom> chatRooms;
  
    ChatRoom lobby; // 로비 채팅방 정보 (로비를 계속 거쳐 다니니 로비 정보 저장)
  
    String LOBBY_CHAT_NAME = "Lobby";
    
  }
  ➔ ChatService 인스턴스에서 요청하는 채팅 데이터를 제공
    
  ➔ 다른 채팅방에 들어가 있어도 로비 채팅방은 계속 갱신하기 위해 lobby 로 따로 관리

• 애플리케이션 구조

  • 클래스 다이어그램

• 인스턴스 다이어그램

  • 클라이언트 소켓 연결

    
    

    

    
    

  • 사용자 정보 생성 (아이디, 이름 입력 후)

    
    

    

    
    

  • 새로운 채팅방 생성

    
    

    

    
    

​

​

• 클래스 멤버

  class Application {
    
      public static Socket socket;
  
      public static MessageSender sender;
  
      public static MessageReceiver receiver;
  
      public static LobbyFrame lobbyFrame;
  
      public static User me;
  
      public static List<User> users = new ArrayList<>(); // 현재 접속 중인 모든 사용자 리스트
  
      public static List<ChatRoom> chatRooms = new ArrayList<>(); 
  
    	// 채팅방 프레임 관리, 메시지 왔을 때 어떤 채팅방 레이블을 갱신해야 하는지 확인
    	// [key] 채팅방 이름
      public static Map<String, ChatPanel> chatPanelMap = new HashMap<>();
  
      public static Map<String, ChatRoomUserListPanel> chatRoomUserListPanelMap = new HashMap<>();
  
      public static final String LOBBY_CHAT_NAME = "Lobby"; // 로비 채팅방 이름
  
  }
  ➔ 서버와 소켓 연결 후 소켓 정보를 저장하고 관리
    
  ➔ 주기적으로 소켓 메시지를 읽기 위한 스레드 생성
  
    
    
  class MessageReader {
    
    Socket socket;
    
  }
  
  class MessageSender {
    
    Socekt socket;
    
  }

• 화면 프레임