Java 프로그래밍 - 채팅 프로그램

KITRI/JAVA

Java 프로그래밍 - 채팅 프로그램

또효니 2020. 5. 25. 15:37

채팅프로그램

ServerReceiver.java

package network06.Chat;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
import java.net.SocketException;

public class ServerReceiver extends Thread{
	private Socket socket;
	
	public ServerReceiver(Socket socket) {
		this.socket = socket;
	}
	@Override
	public void run() {
		BufferedReader br = null;
		
		try {
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()), 512);
			
			while(true) {
				String inputMsg = br.readLine();
				
				if(inputMsg.equalsIgnoreCase("Q")) {
					System.out.println("채팅방을 나가셨습니다.");
					break;
				}
				System.out.println(inputMsg);
			}
		} catch (NullPointerException | SocketException e) {
			System.out.println("채팅이 종료되었습니다."); //클라이언트에서 socket close null 반환
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if(br!=null) br.close();
				if(socket!=null) socket.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

ServerEx.java

package network06.Chat;

import java.net.ServerSocket;
import java.net.Socket;

public class ServerEx {

	public static void main(String[] args) {
		ServerSocket serverSocket = null;
		
		try {
			serverSocket = new ServerSocket(8989);
			System.out.println("서버 챗팅 준비중...");
			
			Socket socket = serverSocket.accept();
			
			ServerReceiver receiver = new ServerReceiver(socket);
			receiver.start();
			
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if(serverSocket!=null) serverSocket.close();
			} catch (Exception ex) {
				ex.printStackTrace();
			}
		}

	}

}

ClientSender.java

package network06.Chat;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class ClientSender extends Thread{
	private Socket socket;
	private String nickName;
	
	public ClientSender(Socket socket, String nickName) {
		this.socket = socket;
		this.nickName = nickName;
	}
	
	@Override
	public void run() {
		BufferedWriter bw = null;
		PrintWriter pw = null;
		Scanner sc = null;
		
		try {
			bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()), 512); 
			pw = new PrintWriter(bw);
			sc = new Scanner(System.in);
			
			while(true) {
				String outputMsg = sc.nextLine();
				
				if(outputMsg.equalsIgnoreCase("q")) {
					pw.println(outputMsg);
					pw.flush();
					break;
				}
				
				pw.println(nickName + ">>>" + outputMsg);
				pw.flush();
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if(bw!=null) bw.close();
				if(pw!=null) bw.close();
				if(sc!=null) bw.close();
				if(socket!=null) socket.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

ClientEx.java

package network06.Chat;

import java.net.Socket;

public class ClientEx {

	public static void main(String[] args) {
		if(args.length!=1) {
			System.out.print("닉네임 하나만 입력하세요:");
			return;
		}
		
		try {
			String nickName = args[0];
			Socket socket = new Socket("내 아이피 주소", 8989);
			
			ClientSender sender = new ClientSender(socket, nickName);
			sender.start();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

network > chat 폴더에 작성한 자바파일을 복사해서 붙여넣기한다.

메모장으로 열고 난 후 패키지명을 지우고, 다른이름으로 저장 > ansi로 하고 모든파일

C:\sohyunkim\java\network\chat

컴파일(java filename.java명령 실행) 후에 .class 파일이 생성된 것을 확인할 수 있다.

단체 채팅 프로그램

ClientEx.java

package network07.ChatMulti;

import java.net.Socket;

public class ClientEx {

	public static void main(String[] args) {
		
		try {
			
			Socket socket = new Socket("192.168.0.23", 7575);
			
			ClientSender sender = new ClientSender(socket, "haha");
			sender.start();
			
			ClientReceiver receiver = new ClientReceiver(socket);
			receiver.start();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

ClientReceiver.java

package network07.ChatMulti;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
import java.net.SocketException;


public class ClientReceiver extends Thread{
	private Socket socket;
	public ClientReceiver(Socket socket) {
		this.socket = socket;
	}
	
	@Override
	public void run() {
		BufferedReader br = null;
		
		try {
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()), 512);
			while(true) {
				String inputMsg = br.readLine();
				
				if(inputMsg.equalsIgnoreCase("Q")) {
					System.out.println("채팅방을 나가셨습니다.");
					break;
				}
				System.out.println(inputMsg);
			}
		} catch (NullPointerException | SocketException e) {
			System.out.println("채팅이 종료되었습니다.");
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if(br!=null) br.close();
				if(socket!=null) socket.close();
			} catch(Exception e) {
				e.printStackTrace();
			}
		}
	}
}

ClientSender.java

package network07.ChatMulti;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class ClientSender extends Thread{
	private Socket socket;
	private String nickName;
	
	public ClientSender(Socket socket, String nickName) {
		this.socket = socket;
		this.nickName = nickName;
		
		System.out.println("채팅 시작입니다.");
	}
	
	@Override
	public void run() {
		BufferedWriter bw = null;
		PrintWriter pw = null;
		Scanner sc = null;
		
		try {
			bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()), 512); 
			pw = new PrintWriter(bw);
			sc = new Scanner(System.in);
			
			while(true) {
				String outputMsg = sc.nextLine();
				
				if(outputMsg.equalsIgnoreCase("q")) {
					pw.println(outputMsg);
					pw.flush();
					break;
				}
				
				pw.println(outputMsg);
				pw.flush();
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if(bw!=null) bw.close();
				if(pw!=null) pw.close();
				if(sc!=null) sc.close();
				if(socket!=null) socket.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

ServerArr.java

package network07.ChatMulti;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;


public class ServerArr extends Thread{
	private Socket socket;
	public static List<PrintWriter> list = Collections.synchronizedList(new ArrayList<PrintWriter>());
	private PrintWriter pw;
	
	public ServerArr(Socket socket) { //[0]pw 홍길동/ [1]pw 김길동
		this.socket = socket;
		sendArr();
	}
	
	public void sendArr() {
		try {
			BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()), 152);
			pw = new PrintWriter(bw);
			
			list.add(pw);
		} catch(Exception e) {
			e.printStackTrace();
		}
	}
	
	public void sendPrintAll(String str) {
		for(PrintWriter pw:list) {
			pw.println(str);
			pw.flush();
		}
	}
	
	@Override
	public void run() {
		BufferedReader br = null;
		String nickName = null;
		
		try {
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()), 512);
			nickName = br.readLine();
			
			sendPrintAll("#" + nickName + "님이 들어오셨습니다.");
			
			while(true) {
				String inputMsg = br.readLine();
				if(inputMsg.equalsIgnoreCase("Q")) {
					sendPrintAll("#" + nickName + "님이 채팅방을 나갔습니다.");
					break;
				}
				
				sendPrintAll(nickName + ">>" + inputMsg);
			}
		} catch(SocketException | NullPointerException e) {
			sendPrintAll("#" + nickName + "님이 채팅방을 나갔습니다.");
		} catch (Exception e) {

		}
	}
	
}

ServerEx.java

package network07.ChatMulti;

import java.net.ServerSocket;
import java.net.Socket;

public class ServerEx {

	public static void main(String[] args) {
		ServerSocket serverSocket = null;
		
		try {
			serverSocket = new ServerSocket(7575);
			System.out.println("서버 챗팅 준비중...");			
			
			while(true) {
				Socket socket = serverSocket.accept(); 
				
				ServerArr arr = new ServerArr(socket);
				arr.start();
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if(serverSocket!=null) serverSocket.close();
			} catch (Exception ex) {
				ex.printStackTrace();
			}
		}

	}

}

cmd 창에서

javac ServerArr.java, javac ServerEx.java, java ServerEx(서버세팅)

여러개의 cmd창에서

javac ClientReceiver.java , javac ClientSender.java, javac ClientEx.java, java ClienEx