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());
}
}
}
'JAVA' 카테고리의 다른 글
| Swing ( Ⅰ ) (0) | 2014.09.13 |
|---|---|
| 내부클래스(inner class) / 로컬 내부 클래스 / static 내부 클래스 / 익명의 내부클래스 / url (0) | 2014.09.13 |
| AWT ( Frame / Button / Layout / JPanel ) - 간단한 예제 (0) | 2014.09.13 |
| Network - 파일전송 ( Ⅳ ) (0) | 2014.09.12 |
| Network - 채팅 샘플 ( Ⅲ ) (0) | 2014.09.12 |
