JAVA 기반 Echo Server 및 Client

◇소개

JAVA를 기반으로 한 다중채팅의 기반이 되는 Echo Server 및 Client 

◇소스코드

    EchoServer.java

/* * Client가 Server 로 메시지 전송(한번) * Client 는 접속 시 IP, Port번호 입력 후 접속 가능하며, 메시지 한번 보내고 종료 * Server 는 계속 실행상태, Client 가 보내온 메시지 Client 로 보내기 !!!!!! * EchoServer4 와 EchoClient4 가 한 묶음 */ import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.ServerSocket; import java.net.Socket; public class EchoServer { public static void main(String[] args) { ServerSocket serverSocket = null; BufferedReader br = null; BufferedWriter bw = null; Socket socket = null; int portNumber = 3000; // Port 번호 try { ///////////////////////////////////////////////////////////////////////////// // 1. portNumber 를 기반으로 하는 소켓 생성 // ///////////////////////////////////////////////////////////////////////////// serverSocket = new ServerSocket(portNumber); System.out.println("Server 준비 완료"); ///////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////////////////////// // 2. Client의 연결요청 대기, 연결되면 Client Socket 이 만들어짐 - 무한 대기 // //////////////////////////////////////////////////////////////////////////////////////////// while(true) { socket = serverSocket.accept(); System.out.println("Client가 연결되었습니다."); ////////////////////////////////////////////////////////////////////////// // 3. Client 에서 보내온 메시지 받기 // ////////////////////////////////////////////////////////////////////////// br = new BufferedReader(new InputStreamReader(socket.getInputStream())); ////////////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////// // 4. Client 에서 보내온 메시지 출력 // /////////////////////////////////////////////////////////////////// String msg = br.readLine(); System.out.println("Client 에서 보낸 메시지 : " + msg); /////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////////////// // 5. Client 에서 보내온 메시지 Client 로 보내기(Server->Client) // /////////////////////////////////////////////////////////////////////////// bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); bw.write(msg + "\n"); // \n : 줄바꿈 bw.flush(); // 출력 버퍼를 비우는 메서드 /////////////////////////////////////////////////////////////////////////// } ///////////////////////////////////////////////////////////////////////////// } catch (IOException e) { e.printStackTrace(); } finally { try { br.close(); } catch (IOException e) { e.printStackTrace(); } try { bw.close(); } catch (IOException e) { e.printStackTrace(); } try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }

    Client.java

import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.Socket; import java.net.UnknownHostException; public class Client01 { /** * @param args */ public static void main(String[] args) { Socket socket = null; BufferedWriter bw = null; // 데이터 쓰기 BufferedReader br = null; // 데이터 읽기 String ipNumber = ""; // 연결할 IP int portNumber = 0; // 연결할 Port 번호 String msg = ""; // BufferedReader 를 사용하여 받은 메시지 저장 try { //////////////////////////////////////////////////// // 1. IP 주소 입력 사항 확인 // //////////////////////////////////////////////////// if(args.length != 2) { System.out.println("Server IP, Port 입력 바랍니다."); System.out.println("잘못된 실행이여서 프로그램을 종료합니다."); System.exit(0); } else { ipNumber = args[0]; portNumber = Integer.parseInt(args[1]); } //////////////////////////////////////////////////// System.out.println(ipNumber + " Server 연결 중"); //////////////////////////////////////////////// // 2. Server 에서 열어놓은 Port 로 접속 // //////////////////////////////////////////////// socket = new Socket(ipNumber, portNumber); //////////////////////////////////////////// System.out.println("Server 연결 성공"); //////////////////////////////////////////////////////////////////////////// // 3. Server 로 데이터 전송 // //////////////////////////////////////////////////////////////////////////// bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); System.out.print("Client send message : "); br = new BufferedReader(new InputStreamReader(System.in)); msg = br.readLine(); bw.write(msg + "\n"); bw.flush(); // 출력 버퍼를 비우는 메서드(반드시 사용해 줘야 함) //////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////// // 4. Server 로 보낸 메시지 다시 받기(Server -> Client) // //////////////////////////////////////////////////////////////////////////// br = new BufferedReader(new InputStreamReader(socket.getInputStream())); System.out.print("Server send message : " + br.readLine()); //////////////////////////////////////////////////////////////////////////// System.out.println(""); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { br.close(); bw.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }

◇시연

좌측이 클라이언트이며, 우측이 서버입니다.

1. 서버의 실행

2. 클라이언트의 실행(연결할 서버의 IP와 PORT가 주어지지 않은 경우)

3. 클라이언트의 실행(잘못된 서버의 IP와 PORT가 주어진 경우)

서버소켓의 포트는 3000번으로 오픈되어있습니다.

4. 클라이언트의 실행(정상적으로 실행)

5. 클라이언트에서 메세지 보내기_1

메세지 '테스트 메세지'를 보냈습니다.

서버에서는 데이터를 받고 다시 클라이언트 측으로 보냅니다.

그 후 클라이언트는 종료됩니다.

6. 클라이언트에서 메세지 보내기_2

메세지 '두번째 연결_테스트 메세지'를 보냈습니다.

서버에서는 데이터를 받고 다시 클라이언트 측으로 보냅니다.

그 후 클라이언트는 종료됩니다.