728x90
반응형
자바 socket을 이용한 다중채팅
123a로 들어온 클라이언트는 123b클라이언트만 채팅이 가능하고
클라이언트들은 해쉬맵을 통해 서버에서 관리한다.
Server.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Set;
public class Server {
static HashMap<String, Object> hash;
public static void main(String[] args) {
try {
//소켓 번호는 임시로 1525
ServerSocket server = new ServerSocket(1525);
hash = new HashMap<String, Object>();
//hash맵 키값불러와서 각 방마다 몇명인지 구하기
while(true)
{
System.out.println("=======================");
//hash맵 개수 구하기
System.out.println("접속을 기다리는중...");
Socket sck = server.accept();
//클라이언트가 새로들어올때마다 chatThr스레드 한개 실행 각각은 독립적으로 실행
ChatThread chatThr = new ChatThread(sck, hash);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
//추후에 제어서버와 연결할 부분
/*
* //제어서버와 연결되는 스레드 class ControlThread extends Thread { Socket sck;
* BufferedReader br; PrintWriter pwr;
*
* public ControlThread(Socket sck, PrintWriter pwr) { this.sck = sck; this.pwr
* = pwr; try { br = new BufferedReader(new
* InputStreamReader(sck.getInputStream())); System.out.println(sck);
* pwr.println("relay server/1525"); System.out.println("println() 실행");
*
* } catch (IOException e) { e.printStackTrace(); } } public void run() { String
* line = null; try { while((line = br.readLine()) != null) {
* System.out.println("--------제어서버: "+line);
*
* //클라이언트로부터 quit을 받으면 종료 if(line.equals("quit")) sck.close(); } }catch
* (Exception e) { System.out.println("제어서버와 연결 끊김..."); } } }
*/
class ChatThread extends Thread{
Socket sck;
String [] split;
String code;
BufferedReader br;
//들어온 클라이언트의 Printwriter객체와 code를 저장하고 관리해주는 해쉬맵
HashMap<String, Object> hash;
boolean initFlag = false;
public ChatThread(Socket sck,HashMap<String, Object> hash) {
this.sck = sck;
this.hash = hash;
try {
PrintWriter pw = new PrintWriter(new OutputStreamWriter(sck.getOutputStream()));
br = new BufferedReader(new InputStreamReader(sck.getInputStream()));
//123a는 123b랑만 채팅이 가능
pw.println("Please press your code number(123a, 123p, 456a, 456p)");
System.out.println("코드보내기");
code = br.readLine();
System.out.println("===="+code+"님과 성공적으로 연결");
//직렬화 후 해쉬맵에 저장
synchronized (hash) {
}
initFlag = true;
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
String line = null;
try {
while((line = br.readLine()) != null)
{//클라이언트로부터 quit을 받으면 종료
if(line.split("/")[0].equals("quit"))
{
System.out.println(code+"님이 시스탬을 종료합니다...");
break;
}else
{//아닐 경우 계속 읽어온 데이터를 클라이언트들에게 전송
sendMsg(line);
}
}
} catch (IOException e) {
System.out.println(code+"님이 시스탬을 강제적으로 종료합니다...");
}finally
{
synchronized (hash) {
}
System.out.println("=======================");
System.out.println("=======================");
try {
} catch (IOException e) {
System.out.println("socket이 정상적으로 종료되지 않았습니다.");
}
}
}
//1:1 전송 (코드가 123a이면 123p에게만 1:1로 전송해주는 방식)
public void sendMsg(String msg)
{
synchronized (hash)
{
PrintWriter pw = null;
//code가 a로 끝나면 안드로이드이므로 pc에게 메시지
if(msg.split("/")[0].endsWith("a"))
{//split함수와 replace함수를 이용해 간편하게 수신받을 클라이언트 printwriter객체를 설정
pw.println(msg.split("/")[1]);
}else if(msg.split("/")[0].endsWith("p"))//메시지 보낸 주체가 pc인 경우
{
pw.println(msg.split("/")[1]);
}else//잘못된 코드
{
pw.println("연결된 코드가 잘못된 코드입니다.");
}
}
}
}
http://colorscripter.com/info#e" target="_blank" style="color:#e5e5e5text-decoration:none">Colored by Color Scripter
|
s |
Client.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class Client {
public static void main(String[] args) {
Socket sck = null;
BufferedReader br = null;
PrintWriter pw = null;
boolean endFlag = false;
String id = null;
String code = null;
try {
//서버의 소캣번호 입력
sck = new Socket("192.168.0.7", 1525);
pw = new PrintWriter(new OutputStreamWriter(sck.getOutputStream()));
br = new BufferedReader(new InputStreamReader(sck.getInputStream()));
BufferedReader keyboard = new BufferedReader(new InputStreamReader(System.in));
//code목록 읽어오기-서버에서 (123a,123b,456a,456p)의 보기를 준다. 클라이언트는 여기서 선택
//123, 456이 실질적 방번호
System.out.println("코드읽어오기");
String str = br.readLine();
System.out.println(str);
//방번호 입력받기
code = keyboard.readLine();
pw.println(code);//code 스트링에 담아보내기
System.out.println("==========="+code+"님의 대화창=========");
//서버로 부터 계속 읽어오는 스레드 실행
InputThread it = new InputThread(sck,br);
String line = null;
while((line = keyboard.readLine())!=null)
{
pw.println(code+"/"+line);
if(line.equals("quit"))
{
System.out.println("시스템을 종료합니다.");
endFlag = true;
break;
}
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
if(br != null)
if(pw != null)
if(sck != null)
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
}
class InputThread extends Thread
{
Socket sck = null;
BufferedReader br = null;
public InputThread(Socket sck, BufferedReader br) {
this.sck = sck;
this.br = br;
}
public void run()//스레드로 서버로부터 계속 읽어오기
{
try {
String line = null;
//null값이 아니면 계속 읽어다 출력해주기
while((line = br.readLine()) !=null)
{
System.out.println(line);
}
} catch (IOException e) {
System.out.println("시스템을 종료합니다.");
}finally {
try {
if(sck != null)
if(br !=null)
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
}
http://colorscripter.com/info#e" target="_blank" style="color:#e5e5e5text-decoration:none">Colored by Color Scripter
|
위 사진처럼 123a가 쓴 채팅 내용을 123p에서는 볼 수 있지만
클라이언트 456a에서는 볼 수 없다.
728x90
반응형
