add examples for multi-thread.

eomjinyoung · eomjinyoung · commit da604ba5d33a · 2013-09-28T20:33:27.000+09:00
diff --git a/Lesson01/src/com/eomjinyoung/lesson01/exam02/multiserver/CalculatorServer.java b/Lesson01/src/com/eomjinyoung/lesson01/exam02/multiserver/CalculatorServer.java
@@ -0,0 +1,40 @@
+package com.eomjinyoung.lesson01.exam02.multiserver;
+
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class CalculatorServer {
+	private int port;
+	
+	public CalculatorServer(int port) {
+		this.port = port;
+	}
+	
+	public void service() throws Exception {
+		ServerSocket serverSocket = new ServerSocket(port);
+		System.out.println("CalculatorServer startup:");
+		
+		Socket socket = null;
+		
+		while(true) {
+			try {
+				System.out.println("waiting client...");
+				
+				socket = serverSocket.accept();
+				System.out.println("connected to client.");
+				
+				new CalculatorWorker(socket).start();
+				
+			} catch (Throwable e) {
+				System.out.println("connection error!");
+			}
+		}
+		
+	}
+	
+	public static void main(String[] args) throws Exception {
+		CalculatorServer app = new CalculatorServer(8888);
+		app.service();
+	}
+}
+
diff --git a/Lesson01/src/com/eomjinyoung/lesson01/exam02/multiserver/CalculatorWorker.java b/Lesson01/src/com/eomjinyoung/lesson01/exam02/multiserver/CalculatorWorker.java
@@ -0,0 +1,55 @@
+package com.eomjinyoung.lesson01.exam02.multiserver;
+
+import java.io.PrintStream;
+import java.net.Socket;
+import java.util.Scanner;
+
+public class CalculatorWorker extends Thread {
+	static int count;
+	
+	Socket socket;
+	Scanner in;
+	PrintStream out;
+	
+	public CalculatorWorker(Socket socket) throws Exception {
+		count++;
+		this.socket = socket;
+		in = new Scanner(socket.getInputStream());
+		out = new PrintStream(socket.getOutputStream());
+	}
+	
+	@Override
+	public void run() {
+		System.out.println("[thread-" + count + "] processing the client request.");
+		
+		String operator = in.nextLine();
+		double a = Double.parseDouble(in.nextLine());
+		double b = Double.parseDouble(in.nextLine());
+		double r = 0;
+		
+		try {
+			switch (operator) {
+			case "+": r = a + b; break;
+			case "-": r = a - b; break;
+			case "*": r = a * b; break;
+			case "/": 
+				if (b == 0) throw new Exception("0 &#51004;&#47196; &#45208;&#45580; &#49688; &#50630;&#49845;&#45768;&#45796;!");
+				r = a / b; break;
+			default:
+				throw new Exception("&#54644;&#45817; &#50672;&#49328;&#51012; &#51648;&#50896;&#54616;&#51648; &#50506;&#49845;&#45768;&#45796;!");
+			}
+			out.println("success");
+			out.println(r);
+			
+		} catch (Exception err) {
+			out.println("failure");
+			out.println(err.getMessage());
+		}
+		
+		try { out.close(); } catch (Exception e) {}
+		try { in.close(); } catch (Exception e) {}
+		try { socket.close(); } catch (Exception e) {}
+		
+		System.out.println("[thread-" + count + "] closed client.");
+	}
+}
