EchoThreadServer

package kr.co.smu.network;

import java.net.*;

import java.io.*;

public class EchoThreadServer {

public static void main(String[] args) {

try{

ServerSocket server = new ServerSocket(10001);

System.out.println("접속을 기다립니다.");

while(true){

Socket sock = server.accept();

EchoThread echothread = new EchoThread(sock);

echothread.start();

} // while

}catch(Exception e){

System.out.println(e);

}

} // main

}

class EchoThread extends Thread{

private Socket sock;

public EchoThread(Socket sock){

this.sock = sock;

} // 생성자

public void run(){

try{

InetAddress inetaddr = sock.getInetAddress();

System.out.println(inetaddr.getHostAddress() + " 로 부터 접속하였습니다.");

OutputStream out = sock.getOutputStream();

InputStream in = sock.getInputStream();

PrintWriter pw = new PrintWriter(new OutputStreamWriter(out));

BufferedReader br = new BufferedReader(new InputStreamReader(in));

String line = null;

while((line = br.readLine()) != null){

System.out.println("클라이언트로 부터 전송받은 문자열 : " + line);

pw.println(line);

pw.flush();

}

pw.close();

br.close();

sock.close();

}catch(Exception ex){

System.out.println(ex);

}

} // run

}