728x90
간단한 채팅방 만드는 예제입니다.
Client 측 코드는 바로가기에서 확인하시기 바랍니다.
학원 수업 자료인 관계로 코드 파일은 제공하지 않습니다.
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
importjava.net.ServerSocket;
importjava.net.Socket;
import java.util.ArrayList;
public class ChatServer implements Runnable{
ServerSocket ss;
Service service;
ArrayList<Service> list = new ArrayList();
public ChatServer() {
try {
ss = new ServerSocket(7777);
System.out.println("채팅 서버 서비스 중...");
new Thread(this).start();
} catch (Exception e) {
System.out.println("ChatServer err : " + e);
}
}
@Override
public void run() { //ChatServer의 run
while(true) {
try {
Socket socket = ss.accept();
service = new Service(socket);
service.start();
service.chat_name = service.in.readLine(); //접속자의 이름 읽기
//System.out.println(service.chat_name);
service.messageSend("/c" + service.chat_name);
for(Service ser : list) {
ser.messageSend("/c" + service.chat_name);
service.messageSend("/c" + service.chat_name);
}
list.add(service);
} catch (Exception e) {
System.out.println("ChatServer run err :" + e);
}
}
}
//client 별 처리를 위한 내부 클래스
class Service extends Thread {
String chat_name;
BufferedReader in;
OutputStream out;
Socket socket;
public Service(Socket socket) {
try {
this.socket = socket;
in = new BufferedReader(
new InputStreamReader(socket.getInputStream(), "euc-kr"));
out = socket.getOutputStream();
} catch (Exception e) {
System.out.println("Service err : " + e);
}
}
@Override
public void run() {
while(true) {
try {
String msg = in.readLine();
if(msg == null || msg.equals("")) continue;
if(msg.charAt(0) == '/') {
if(msg.charAt(1) == 'r') { //대화명 변경
messageAll("/r" + chat_name + "-" + msg.substring(2));
chat_name = msg.substring(2);
}else if(msg.charAt(1) == 'q') { //퇴장
try {
messageAll("/q" + chat_name);
list.remove(this);
in.close();
out.close();
socket.close();
} catch (Exception e) {
// TODO: handle exception
}
break;
}else if(msg.charAt(1) == 's') { //귓속말 /s이름-메세지
String name = msg.substring(2, msg.indexOf('-')).trim();
for(Service ser : list) {
if(name.equals(ser.chat_name)) {
ser.messageSend((chat_name + ">(secret)" +
msg.substring(msg.indexOf('-') + 1)));
}
}
}
}else { //일반 메세지
messageAll(chat_name + ">" + msg);
}
} catch (Exception e) {
break;
}
}
}
public void messageAll(String msg) {
try {
for (int i = 0; i < list.size(); i++) {
Service ser = list.get(i);
ser.messageSend(msg);
}
} catch (Exception e) {
System.out.println("messageAll err : " + e);
}
}
public void messageSend(String msg) {
try {
out.write((msg + "\n").getBytes("euc-kr"));
} catch (Exception e) {
System.out.println("messageSend err : " + e);
}
}
}
public static void main(String[] args) {
new ChatServer();
}
}
본 포스팅은 IT 교육기관인 KIC 캠퍼스의 지원을 받은 리포트입니다.
혹시 잘못되거나 문제 소지시 댓글 남겨주시면 조치하겠습니다.
728x90
'DEV' 카테고리의 다른 글
| Django 프로젝트 생성 및 세팅 (0) | 2018.05.17 |
|---|---|
| Django 설치 및 이클립스 연동 (0) | 2018.05.16 |
| JAVA 채팅방 만들기 예제 (Client 측) (0) | 2018.01.29 |
| JAVA Socket을 활용하여 간단한 통신하기 예제 (0) | 2018.01.26 |
| JAVA Socket을 활용한 html 읽어오기 예제 (0) | 2018.01.26 |
| JAVA InetAddress 클래스를 활용한 IP 읽기 예제 (0) | 2018.01.26 |