...

src/main/java/kr/co/swh/lecture/opensource/project/drawing/ChattingClientOutputThread.java

@@ -0,0 +1,46 @@
+package kr.co.swh.lecture.opensource.project.drawing;
+
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+import java.util.Scanner;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.chat.client 
+ * ChattingClientOutputThread.java
+ *
+ * 설명 :클라이언트 출력 스레드
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ChattingClientOutputThread extends Thread{
+	private Socket socket;
+	private String nick;
+	
+	public ChattingClientOutputThread(Socket socket, String nick) {
+		this.socket = socket;
+		this.nick = String.format("[%s] ", nick);
+	}
+	
+	public void run() {
+		DataOutputStream dos = null;
+		Scanner scn = null;
+		try {
+			dos = new DataOutputStream(socket.getOutputStream());
+			scn = new Scanner(System.in);
+			String line;
+			while((line = scn.nextLine())!=null) {
+				dos.writeUTF(nick + line);
+			}
+			socket.close();
+		}catch(IOException e) {
+			e.printStackTrace();
+		}finally {
+			try{ dos.close(); scn.close(); }catch(Exception e) {}
+		}
+	}
+}

src/main/java/kr/co/swh/lecture/opensource/project/drawing/DrawingServer.java

@@ -0,0 +1,56 @@
+package kr.co.swh.lecture.opensource.project.drawing;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Set;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.chat 
+ * ChattingServer.java
+ *
+ * 설명 :채팅 서버 프로그램, 소켓을 관리
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class DrawingServer extends Thread{
+    Set<ServerThread> sockets = new HashSet<>();
+    
+    public void run(){
+        ServerSocket serverSocket = null;
+        try{
+            serverSocket = new ServerSocket(9998);
+            System.out.println("클라이언트 연결을 기다립니다.");
+            while(true){
+                Socket s = serverSocket.accept();
+                ServerThread t = new ServerThread(this, s);
+                t.start();
+                sockets.add(t);
+            }
+        }catch(IOException e){
+            System.err.println("서버 에러");
+            e.printStackTrace();
+        }finally{
+            try{ serverSocket.close(); } catch(Exception e) {}
+        }
+    }
+    
+    public void broadcast(String message){
+        Iterator<ServerThread> it = sockets.iterator();
+        while(it.hasNext()){
+            ServerThread peer = it.next();
+            peer.sendMessage(message);
+        }
+    }
+    
+    public static void main(String[] args) {
+    	DrawingServer server = new DrawingServer();
+    	server.start();
+    }
+}

src/main/java/kr/co/swh/lecture/opensource/project/drawing/LineDraw.java

@@ -0,0 +1,125 @@
+package kr.co.swh.lecture.opensource.project.drawing;
+
+
+import java.awt.BasicStroke;
+import java.awt.Color;
+import java.awt.Graphics;
+import java.awt.Graphics2D;
+import java.awt.Point;
+import java.awt.event.MouseAdapter;
+import java.awt.event.MouseEvent;
+import java.awt.event.MouseMotionAdapter;
+import java.awt.geom.Line2D;
+import java.io.BufferedWriter;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.swing.JFrame;
+import javax.swing.JPanel;
+
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+
+public class LineDraw extends JPanel {
+	private List<List<Point>> point = new ArrayList<List<Point>>();
+	private List<List<Point>> drawingPoint = new ArrayList<List<Point>>();
+	DataOutputStream dos;
+	
+	class ChattingClientInputThread extends Thread{
+		private Socket socket;
+
+		public ChattingClientInputThread(Socket socket) {
+			this.socket = socket;
+		}
+
+		public void run() {
+			DataInputStream dis = null;
+			try {
+				dis = new DataInputStream(socket.getInputStream());
+				String line = dis.readUTF();
+				Gson gson = new Gson();
+				drawingPoint = gson.fromJson(line, new TypeToken<List<List<Point>>>(){}.getType());
+				System.out.println(drawingPoint);
+				repaint();
+			}catch(IOException e) {
+				e.printStackTrace();
+			}finally{
+				try{ dis.close(); }catch(Exception e) {}
+			}
+		}
+	}
+	
+	public LineDraw(Socket socket) {
+		ChattingClientInputThread thread = new ChattingClientInputThread(socket);
+		thread.start();
+		try {
+			dos = new DataOutputStream(socket.getOutputStream());
+		} catch (IOException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+		
+		addMouseListener(new MouseAdapter() {
+			public void mousePressed(MouseEvent event) {
+				List<Point> list = new ArrayList<Point>();
+				point.add(list);
+			}
+			
+			@Override
+			public void mouseClicked(MouseEvent e) {
+				// TODO Auto-generated method stub
+
+			}
+			
+		});
+
+		addMouseMotionListener(new MouseMotionAdapter() {
+			public void mouseDragged(MouseEvent event) {
+				Point p = event.getPoint();
+				Gson gg = new Gson();
+				point.get(point.size()-1).add(event.getPoint());
+//				repaint();
+				
+				
+				try {
+					dos.writeUTF(gg.toJson(point));
+				} catch (IOException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+			
+		});
+		
+	}
+
+	public void paintComponent(Graphics g) {
+		super.paintComponent(g);
+		Graphics2D g2 = (Graphics2D) g;
+		g2.setColor(new Color(0, 0, 128));
+		g2.setStroke(new BasicStroke(15f,
+				BasicStroke.CAP_ROUND,
+				BasicStroke.JOIN_ROUND));
+		for (int i = 0; i < drawingPoint.size(); i++) {
+			List<Point> l = drawingPoint.get(i);
+			for (int j = 1; j < l.size(); j++) {
+				g2.draw(new Line2D.Float(l.get(j-1), l.get(j)));
+			}
+		}
+	}
+
+	public static void main(String[] args) throws UnknownHostException, IOException {
+//		Thread.currentThread().getContextClassLoader().getResourceAsStream("db.pro")
+		Socket socket = new Socket("127.0.0.1", 9998);
+		JFrame f = new JFrame();
+		f.add(new LineDraw(socket));
+		f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
+		f.setSize(800, 600);
+		f.setVisible(true);
+	}
+}

src/main/java/kr/co/swh/lecture/opensource/project/drawing/ServerThread.java

@@ -0,0 +1,63 @@
+package kr.co.swh.lecture.opensource.project.drawing; 
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.Socket;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.chat 
+ * ServerThread.java
+ *
+ * 설명 :채팅 서버 메세지 전송 스레드
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ServerThread extends Thread{
+    private Socket socket;
+    private DrawingServer server;
+    private OutputStream os;
+    
+    public ServerThread(DrawingServer server, Socket s){
+        this.server = server;
+        this.socket = s;
+        System.out.println("클라이언트 연결 : " + s.getInetAddress().getHostAddress());
+    }
+    
+    public void run(){
+        InputStream is = null;
+        DataInputStream dis = null;
+        
+        try{
+            is = socket.getInputStream();
+            dis = new DataInputStream(is);
+            String line;
+            while(true){
+                line = dis.readUTF();
+                //	서버로 들어온 메세지는 접속된 모든 클라이언트에게 전송
+                server.broadcast(line);
+            }
+        }catch(IOException e){
+            e.printStackTrace();
+        }finally{
+            try{ is.close(); } catch(IOException e) {}
+            try{ socket.close(); } catch(IOException e) {}
+        }
+    }
+    
+    public void sendMessage(String message){
+        try {
+            os = socket.getOutputStream();
+            DataOutputStream dos = new DataOutputStream(os);
+            dos.writeUTF(message);
+        }catch(IOException e) {
+            e.printStackTrace();
+        }
+    }
+}