(38) [JAVA] 22일

 

package ch16.unit02;

import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;

public class ServerChat extends JFrame implements ActionListener, Runnable {

    private static final long serialVersionUID = 1L;

    private JTextField tf = new JTextField();
    private JTextArea ta = new JTextArea();

    private ServerSocket ss = null;
    private int port = 8000;
    private Socket sc = null;

    public ServerChat() {
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

        ta.setEditable(false);
        JScrollPane sp = new JScrollPane(ta);
        add(sp, BorderLayout.CENTER);

        tf.addActionListener(this);
        add(tf, BorderLayout.SOUTH);

        setTitle("채팅");
        setSize(500, 500);
        setResizable(false);
        setVisible(true);
    }

    @Override
    public void actionPerformed(ActionEvent e) {
        if (e.getSource() == tf) {
            String s = tf.getText().trim();

            if (s.length() == 0) {
                return;
            }
            try {
                if (sc != null) {
                    PrintStream out = new PrintStream(sc.getOutputStream());
                    out.println("서버->" + s);
                    out.flush();
                    ta.append("나->" + s + "\n");
                    tf.setText("");
                    tf.requestFocus();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        ServerChat serverChat = new ServerChat();
        serverChat.serverStart();
    }

    public void serverStart() {
        try {
            ss = new ServerSocket(port);
            ta.setText("서버 시작\n");
            sc = ss.accept();
            Thread t = new Thread(this);
            t.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        String str;
        String ip = null;

        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(sc.getInputStream()));
            ip = sc.getInetAddress().getHostAddress();
            ta.append("[" + ip + "] 접속\n");

            while ((str = br.readLine()) != null) {
                ta.append(str + "\n");
                ta.setCaretPosition(ta.getDocument().getLength());
            }
        } catch (IOException e) {
            str = "[" + ip + "] 님이 퇴장 했습니다.";
            ta.append(str + "\n");
            sc = null;
        }
    }
}

 

 

package ch16.unit02;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;

//1:다 채팅
public class ServerChat2 {
	private Vector<Socket> client=new Vector<Socket>();
	private ServerSocket ss=null;
	private int port=8000;
	
	public ServerChat2() {
		
	}
	
	// 내부 클래스 
	class WorkerThread extends Thread{
		private Socket sc=null;
		
		public WorkerThread(Socket sc) {
			this.sc=sc; // 접속한 클라이언트를 나타냄 
			
		}
		
		//다른 클라이언트에게 메시지 전달 
		public void sendMsg(String msg) {
			for(Socket s:client) {
				
				try {
					if(s==sc) {
						continue;
					}
					
					//다른 클라이언트에게 메시지 전달 
					
					PrintStream ps=new PrintStream(s.getOutputStream());
					ps.println(msg);
					
				} catch (Exception e) {
				}
			}
		}
		
		
		@Override
		public void run() {
			String ip=null;
			String msg=null;
			
			try {
				//접속한 클라이언트의 입력 스트림(수신용)
				BufferedReader br=new BufferedReader(new InputStreamReader(sc.getInputStream()));
				
				ip=sc.getInetAddress().getHostAddress();
			
				//클라이언트의 소켓을 백터에 저장
				client.add(sc);
				
				//다른 클라이언트에게 접속 사실을 알림
				 msg="["+ip+"]입장..ServerChat2.";
				 sendMsg(msg);
				 
				 System.out.println(msg);
				 
				 //클라이언트가 보낸 정보 받기
				 while((msg=br.readLine())!=null) {
					 //다른 클라이언트에게 전송 
					 sendMsg(msg);
				} 
			} catch (IOException e) { 
				//클라이언트가 접속을 해제한 경우 다른 클라이언트에게 해제 사실을 알림  
				msg ="["+ip+"] 퇴장~~~~~";
				sendMsg(msg);
				
				//백터에서 접속 해제한 소켓 삭제
				client.remove(sc);
				sc=null;
				System.out.println(msg);
			}
		
			super.run();
		}
		
	}
	
	public void serverStart() {
		try {
			ss=new ServerSocket(port);
			System.out.println("서버 시작!!!");
			
			while(true) {
				//클라이언트가 접속하기를 기다림 
				
				Socket sc=ss.accept();
				
				//스레드 객체 생성
				WorkerThread t=new WorkerThread(sc);
				t.start(); // 클라이언트가 접속한 갯수 만큼 생성 
				
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	
	public static void main(String[] args) {
		ServerChat2 obj =new ServerChat2(); // 서버의 객체 생성
		obj.serverStart(); // serverStart 실행 
		
		

	}

}

 

package ch16.unit02;

import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;

import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;


public class ClientChat extends JFrame implements ActionListener, Runnable {
	private static final long serialVersionUID = 1L;

	private JTextField tf = new JTextField();
	private JTextArea ta = new JTextArea();

	private Socket sc = null;
	private String host = "127.0.0.1";
	//private String host = "192.168.0.93";
	private int prot = 8000;
	private String nickname = "애";

	
	public ClientChat() {
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

		ta.setEditable(false);
		JScrollPane sp = new JScrollPane(ta);
		add(sp, BorderLayout.CENTER);

		tf.addActionListener(this);
		add(tf, BorderLayout.SOUTH);

		setTitle("채팅-클라이언트");
		setSize(500, 500);
		setResizable(false);
		setVisible(true);

	}

	@Override
	public void run() {
		String s;
		
		try {
			if(sc==null) {
				return;
			}
			
			BufferedReader br=new BufferedReader(new InputStreamReader(sc.getInputStream()));
			
			while((s=br.readLine())!=null) {
				ta.append(s+"\n");
				ta.setCaretPosition(ta.getDocument().getLength());
				
			}
		} catch (Exception e) {
			ta.append("서버가 종료되었습니다.\n");
			sc=null;
		}

	}
	
	

	@Override
	public void actionPerformed(ActionEvent e) {
		if (e.getSource() == tf) {
			String s = tf.getText().trim();

			if (s.length() == 0) {
				return;
			}
			try {
				if(sc==null) {
					return;
				}
				
				PrintStream ps=new PrintStream(sc.getOutputStream());
				ps.println(nickname + ">" +s);

				
				ta.append("보냄>" + s + "\n");
				ta.setCaretPosition(ta.getDocument().getLength());

				tf.setText("");
				tf.requestFocus();

			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}

	public void connect() {

		try {
			sc = new Socket(host, prot);
			ta.setText("서버 접속 완료...\n");

			Thread t = new Thread(this);
			t.start();

		} catch (Exception e) {
			sc = null;
			e.printStackTrace();
		}

	}

	public static void main(String[] args) {
		new ClientChat().connect();
		;

	}

}