서버-클라이언트 채팅 프로그램

서버 - 클라이언트가 번갈아서 채팅할 수 있는 프로그램이다.

 

 

클라이언트

package chat;

import java.io.*;
import java.net.*;
import java.util.*;

public class ClientEx {
    public static void main(String[] args){
        BufferedReader in =null; 
        BufferedWriter out =null;
        Socket socket = null; 
        Scanner sc = new Scanner(System.in);
        
        try {
            socket = new Socket("localhost",9999); // 클라이언트 소켓 생성 - 서버연결
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            while (true){
            	System.out.print("보내기>>"); 
                String outputMessage = sc.nextLine(); // 키보드 한행읽기
                if (outputMessage.equalsIgnoreCase("bye")){
                    out.write(outputMessage + "\n");
                    out.flush();
                    break;
                }
	            out.write(outputMessage + "\n");
	            out.flush(); // 스트림 버퍼 모두 전송
	            String inputMessage = in.readLine(); // 수신받기
	            System.out.println("서버: " + inputMessage);

            }
        } catch (IOException e){
            System.out.println(e.getMessage());
        }finally{
            try{
                sc.close();
                if(socket != null) socket.close(); // 클라이언트 소켓 닫기
            }catch(IOException e){
                System.out.println("클라이언트 채팅 중 오류가 발생했습니다.");
            }
        }
    }
}

 

 

 

서버

package chat;

import java.io.*;
import java.net.*;
import java.util.*;

public class ServerEx {
    public static void main(String[] args){
        BufferedReader in =null;
        BufferedWriter out =null;
        ServerSocket li = null;
        Socket socket = null;

        Scanner sc = new Scanner(System.in);
        
        try{
            li = new ServerSocket(9999);
            System.out.println("연결을 기다리는 중 .... ");
            socket = li.accept();
            System.out.println("연결 되었습니다 .... ");
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            while (true){
                String inputMessage = in.readLine();
                if (inputMessage.equalsIgnoreCase("bye")){
                    System.out.println("클라이언트에서 bye로 연결종료");
                    break;
                }
	            System.out.println("클라이언트: "+ inputMessage);
	            System.out.print("보내기 >> ");
	            String outputMessage = sc.nextLine();
	            out.write(outputMessage + "\n" );
	            out.flush();
            }
        } catch (IOException e){
            System.out.println(e.getMessage());
        }finally{
            try{
                sc.close();
                socket.close(); //통신용 소켓 닫기
                li.close(); // 서버 소켓 닫기
            }catch(IOException e){
                System.out.println("클라이언트 채팅 중 오류가 발생했습니다.");
            }
        }
    }
}