멀티 채팅 샘플

 

1. 서버를 실행

2. 클라이언트1를 실행 : 대화명 입력. 입력

3. 클라이언트2를 실행 : 대화명 입력. 입력

4. 클라이언트3를 실행

..

1. server 

package test01.net;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

//클라이언트가 보내온 메시지를 수신하고 다른 클라이언트들에게 수신된 메시지를 다시 보내는 스레드 

class EchoThread extends Thread{

    //모든 클라이언트와 연결된 Socket객체를 담은 객체 배열

    private ArrayList<Socket> list;

    //클라이언트와 연결된 Socket객체

    private Socket sock;

    private String name;//대화명

    public EchoThread(ArrayList<Socket> list,Socket sock){

        this.list=list;

        this.sock=sock;

    }

    public void run(){

        try{

            //소켓을 통해 데이터를 읽기위한 스트림 얻어오기

            InputStream is=sock.getInputStream();

            //1바이트처리스트림을 2바이트처리스트림으로 변환하기

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

            //맨처음에 전송된 문자열은 무조건 대화명이 됨

            name=br.readLine();

            //다른 클라이언트들에게 입장 알리기

            sendMsg("["+ name+"]님이 입장하셨습니다.");

            while(true){

                //클라이언트가 보낸 메시지 읽어오기

                String msg=br.readLine();

                if(msg==null){//상대방이 종료한 경우

                    sendMsg("["+name+"]님이 퇴장하셨습니다.");

                    //ArrayList에서 클라이언트와 연결된 Socket제거하기

                    list.remove(sock);

                    //스트림닫기

                    br.close();

                    //소켓닫기

                    sock.close();

                    break;

                }

                //전달받은 메시지를 다른 클라이언트에 보냄

                sendMsg("["+name+"]"+msg);

            }

        }catch(IOException ie){

            System.out.println(ie.getMessage());

        }

    }

    public void sendMsg(String msg){

        for(int i=0;i<list.size();i++){

            //ArrayList에 담긴 Socket객체 꺼내오기

             Socket soc=list.get(i);

             //데이터를 수신받은 Socket객체가 아닌경우

             if(soc!=sock){

                 try{

                    //클라이언트에 데이터를 보내기 위한 출력스트림 얻어오기

                     PrintWriter pw=new PrintWriter(soc.getOutputStream());

 

                    //연결된 클라이언트에 데이터 보내기

                     pw.println(msg);

                     pw.flush();

                 }catch(IOException ie){

                     System.out.println(ie.getMessage());

                 }

             }

        }

    }

}

public class MultiChatServer{

    public static void main(String[] args) {

        ServerSocket server=null;

        //클라이언트와 연결된 Socket객체를 배열처럼 담기 위한 객체 생성

        ArrayList<Socket> list=new ArrayList<Socket>();

        try{

            server=new ServerSocket(3001);

            while(true){

                System.out.println("클라이언트 접속 대기중..");

                //클라인언트접속허용하기

                Socket sock=server.accept();

                //클라이언트의 아이피주소에 대한 정보를 갖는 객체 얻어오기

                InetAddress ia=sock.getInetAddress();

                //클라이언트의 아이피주소 출력하기

                System.out.println("ip주소["+ ia.getHostAddress() + "]가 접속함");

                //클라이언트와 연결된 Socket객체를 list에 담기

                list.add(sock);

                //데이터를 수신하는 스레드 실행하기

                new EchoThread(list, sock).start();

            }

        }catch(IOException ie){

            System.out.println(ie.getMessage());

        }

    }

}

 

2. client   

package test01.net;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import java.net.UnknownHostException;

//서버가 보내온 데이터를 읽어와 화면에 출력하는 스레드

class ReceiveThread extends Thread{

    private Socket sock;

    public ReceiveThread(Socket sock){

        this.sock=sock;

    }

    public void run(){

        try{

            //서버가 보내온 데이터를 읽어오기위한 스트림객체

            BufferedReader br=

              new BufferedReader(new InputStreamReader(sock.getInputStream()));

            while(true){

                //서버가 보내온 문자열 읽어오기

                String msg=br.readLine();

                if(msg==null){

                    System.out.println("접속이 종료되었어요..");

                    break;

                }

                System.out.println(msg);

            }

            br.close();

            sock.close();

        }catch(IOException ie){

            System.out.println(ie.getMessage());

        }

    }

}

//서버에 문자열을 보내는 스레드

class SendThread extends Thread{

    private Socket sock;

    public SendThread(Socket sock){

        this.sock=sock;

    }

    public void run(){

        //키보드로부터 입력받기 위한 스트림객체 생성

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

        try{

            //서버에 데이터를 보내기위한 출력스트림객체 생성하기

            PrintWriter pw=new PrintWriter(sock.getOutputStream());    

            System.out.println("대화명입력");

            //제일먼저 키보드로 대화명입력받기

            String ss=br.readLine();

            //대화명 서버에 보내기

            pw.println(ss);

            pw.flush();

            while(true){

                //키보드로 문자열 입력받기

                String msg=br.readLine();

                if(msg.equals("exit")) break;

                //서버에 문자열 보내기

                pw.println(msg);

                pw.flush();

            }

            pw.close();

            sock.close();

        }catch(IOException ie){

            System.out.println(ie.getMessage());

        }

    }

}

public class MultiChatClient{

    public static void main(String[] args) {

        try{

            Socket sock=new Socket("192.168.0.2",3001);

            System.out.println("서버접속성공!");

            //서버에서 보내온 데이터를 수신하는 스레드 실행

            new ReceiveThread(sock).start();

            //서버에 데이터를 보내는 스레드 실행

            new SendThread(sock).start();

        }catch(UnknownHostException ue){

            System.out.println(ue.getMessage());

        }catch(IOException ie){

            System.out.println(ie.getMessage());

        }

    }

}