인프런 커뮤니티 질문&답변

안녕하세요 강사님 좋은 강의 매번 잘 듣고 있습니다.

채팅 프로그램 직접 먼저 구현해보라고 하셔서 코드를 짜봤는데요, 이후 강사님이 짜신 채팅 프로그램 코드를 보며 많이 부족하다는 것을 다시 느꼈습니다.

두 코드를 비교하며 제가 짠 클라이언트 코드 중에 잘 이해가 되지 않는 부분이 있는데요,,

우선 코드는 다음과 같습니다.

package network.tcp.chat;

//...

import static util.MyLogger.log;

public class ChatClient {
    private static final int PORT = 12345;

    public static void main(String[] args) throws IOException, InterruptedException {

        try (Socket socket = new Socket("localhost", PORT);
             DataInputStream input = new DataInputStream(socket.getInputStream());
             DataOutputStream output = new DataOutputStream(socket.getOutputStream())) {
            log("채팅 소켓 연결: " + socket);
            // 채팅 메시지 송.수신 분리
            ReadHandler readHandler = new ReadHandler(input);
            WriterHandler writerHandler = new WriterHandler(output);
            Thread clientReadThread = new Thread(readHandler, "clientReadHandler");
            Thread clientWriteThread = new Thread(writerHandler, "clientWriteHandler");

            clientWriteThread.start();
            clientReadThread.start();

            clientWriteThread.join();
            clientReadThread.join();
        }
    }
}

package network.tcp.chat;

//..
import static util.MyLogger.log;

public class ReadHandler implements Runnable {
    private final DataInputStream input;
    public ReadHandler(DataInputStream input) {
        this.input = input;
    }

    @Override
    public void run() {
        while(true) {
            // 서버로부터 문자 받기
            String received = null;
            try {
                received = input.readUTF();
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
            log("server -> client: " + received);
        }
    }
}

package network.tcp.chat;

//..
import static util.MyLogger.log;

public class WriterHandler implements Runnable {
    private final DataOutputStream output;
    public WriterHandler(DataOutputStream output) {
        this.output = output;
    }

    @Override
    public void run() {
        Scanner scanner = new Scanner(System.in);
        while(true) {
            System.out.print("전송 문자: ");
            // 서버에 문자 보내기
            String toSend = scanner.nextLine();
            try {
                output.writeUTF(toSend);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
            log("client -> server: " + toSend);
            if (toSend.equals("exit")) {
                break;
            }
        }
    }
}

물론 제 코드를 작동시켜보면 1) EOFException도 발생하고 2) 자원 정리 코드도 따로 없습니다

다만 궁금한 것은 main 에 다음의 두 코드를 넣어야 채팅 프로그램이 동작한다는 것입니다.

clientWriteThread.join();
clientReadThread.join();

앞서 보여주신 간단한 server-client 예제, 강사님이 짜신 채팅 프로그램 코드 모두 Thread.join() 메소드를 전혀 사용하지 않았는데

왜 제 코드에서는 두 코드를 넣어야 채팅 프로그램이 끊기지 않고 동작하는 것인지 자문을 구해도 될까요?ㅠ

감사합니다..!