클라이언트 측의 코드를 수정하여 송/수신 기능을 하는 각 메소드를 선언하고 쓰레드 2개를 적용하여 병행처리하도록 수정함
클라이언트측 코드
import java.net.*;
import java.io.*;
/* 서버측으로 데이터를 전송하는 부분과 수신하는 부분을 쓰레드로 분리하여 병행처리하도록 수정함*/
class ChatClient {
static PrintWriter pw;
static BufferedInputStream bin;
static BufferedReader keyboard;
public static void main(String[] args) throws Exception {
Socket soc = new Socket("localhost", 1234);
pw = new PrintWriter(new OutputStreamWriter(soc.getOutputStream()));
bin = new BufferedInputStream(soc.getInputStream());
keyboard = new BufferedReader(new InputStreamReader(System.in));
new SendThread().start(); // 키보드로부터 입력을 받아서 서버에 전송한다
new ReceiveThread().start(); // 서버에서 데이터를 수신하여 모니터에 출력한다.
}
/* 송신기능 메소드*/
private static void send() {
String dan = null;
while(true) {
System.out.print("서버로 전송할 숫자를 입력해 주세요 ");
try{
dan = keyboard.readLine();
pw.println(dan);
pw.flush();
Thread.sleep(20);
}catch(Exception e){e.printStackTrace();}
}
}
/* 수신기능 메소드*/
private static void receive() {
int count = 0;
byte[] buf = null;
int read = 0;
while(true) {
try{
Thread.sleep(20);
count = bin.available();
if(count==0) continue;
buf = new byte[count];
read=bin.read(buf, 0, buf.length);
System.out.println();
System.out.println(new String(buf, 0, read));
}catch(Exception e){e.printStackTrace();}
}
}
/* 내부 클래스로 선언한 송신 쓰레드*/
static class SendThread extends Thread {
public void run() {
ChatClient.send();
}
}
/* 내부 클래스로 선언한 수신 쓰레드*/
static class ReceiveThread extends Thread {
public void run() {
ChatClient.receive();
}
}
}
서버측 코드 (변경없음)
import java.net.*;
import java.io.*;
/* 클라이언트가 종료되면 서버는 계속 다른 클라이언트를 대기하는 상태로 전환되도록 한다*/
class ChatServer {
public static void main(String[] args) throws Exception {
ServerSocket ss = new ServerSocket(1234);
System.out.println("서버 실행중....");
while(true) {
Socket soc = ss.accept();
BufferedReader br = new BufferedReader(new InputStreamReader(soc.getInputStream()));
PrintWriter pw = new PrintWriter(new OutputStreamWriter(soc.getOutputStream()));
String line = null;
try{
while((line=br.readLine())!= null) {
int dan = Integer.parseInt(line);
String str = "";
for(int i=1;i<=9;i++) {
str += dan + " x " + i + " = " + (dan*i) + "\n";
}
pw.println(str);
pw.flush();
}
}catch(Exception soce){
System.err.println("클라이언트 나감");
}
} // 바깥 while()
}
}