本文实例为大家分享了java群聊功能，供大家参考，具体内容如下
Java 对TCP协议的支持：
--> java.net包中定义了两个类ServerSocket 和Socket ，分别用来实现双向连接的server 端和client 端。
--> Client 类定义客户端
|
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
|
package com.dragon.java.tcpchat;import java.io.IOException;import java.net.Socket;import java.net.UnknownHostException;/** * 客户端 * * @author Auser * */public class Client { public static void main(String args[]) throws UnknownHostException, IOException { Socket client = new Socket("192.168.1.188", 10000); // 穿件发送信息的线程 new ClientSend(client).start(); // 创建接收信息的线程 new ClientReceive(client).start(); // 因为要实现聊天功能，而不是只发送一次信息，所以输出流和客户端都不能关闭。 // client.shutdownOutput(); // client.close(); }} |
--> ClientSend 类 定义客户端向服务端发送信息的线程
|
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
|
package com.dragon.java.tcpchat;import java.io.IOException;import java.io.PrintStream;import java.net.Socket;import java.util.Scanner;/** * 客户端向服务端发送信息的线程 * * @author Auser * */public class ClientSend extends Thread { private Scanner scanner; private Socket socket; public ClientSend(Socket socket) { this.socket = socket; } @Override public void run() { scanner = new Scanner(System.in); try { PrintStream ps = new PrintStream(socket.getOutputStream()); String line = ""; // 阻塞式发送信息 while ((line = scanner.nextLine()) != null) { ps.println(line); } } catch (IOException e) { e.printStackTrace(); } }} |
--> ClientReceive 类 定义客户端接收服务端信息的线程
|
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
|
package com.dragon.java.tcpchat;import java.io.BufferedReader;import java.io.InputStreamReader;import java.net.Socket;/** * 客户端接收信息的线程 * * @author Auser * */public class ClientReceive extends Thread { private Socket socket; public ClientReceive(Socket socket) { this.socket = socket; } @Override public void run() { try { BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream())); // 按行接收信息 String line = ""; while ((line = br.readLine()) != null) { System.out.println(line); } } catch (Exception e) { e.printStackTrace(); } }} |
--> Server 类定义服务端
|
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
|
package com.dragon.java.tcpchat;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.List;/** * 服务器 * * @author Auser * */public class Server { public static void main(String[] args) throws IOException, InterruptedException { List<Socket> list = new ArrayList<>(); // 创建服务器端的套接字 ServerSocket server = new ServerSocket(10000); while (true) { // 接收客户端的阻塞方法 Socket socket = server.accept(); // 设计到多个线程可能会对集合进行增删的操作，要进行同步的处理 synchronized (list) { list.add(socket); } // 启动一个新的线程去处理这个客户端的交流 new HandleSocket(socket, list).start(); } // 因为不知道客户端什么时候发送信息，所以服务端要一直开启不能关闭。 }} |
--> HandleSocket 类对连接到服务端的客户端进行操作(上下线通知、屏蔽拉黑、将信息发送到每个客户端等...)
|
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
|
package com.dragon.java.tcpchat;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.InetAddress;import java.net.Socket;import java.util.List;/** * 处理每个(单个)连接到服务器的客户端的线程 * * @author Auser * */public class HandleSocket extends Thread { private Socket socket; private List<Socket> list; /** * 构造方法 * * @param socket * 当前连接的客户端 * @param list * 存储已连接客户端的集合 */ public HandleSocket(Socket socket, List<Socket> list) { this.socket = socket; this.list = list; } /** * 线程run方法 */ @Override public void run() { InetAddress address = socket.getInetAddress(); // 获取连接到服务器的这的客户端的地址 String ip = address.getHostAddress(); System.out.println(ip + "上线了！"); if (ip.equals("192.168.1.117")) { synchronized (list) { sendToAll(ip + "由于违规操作，已被拉入黑名单！"); list.remove(socket); } return; } try { BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream(), "gbk")); String line = ""; while ((line = br.readLine()) != null) { String msg = ip + ":" + line; System.out.println(msg); // 输出到服务器端的控制台 // 把这个客户端说的话，发给其他所有的客户端 sendToAll(msg); } } catch (IOException e) { // e.printStackTrace(); System.out.println(ip + "下线了！"); synchronized (list) { list.remove(socket); } } } /** * 把信息发送给所有的客户端，去除当前socket * * @param msg * 发送的信息 */ private void sendToAll(String msg) { synchronized (list) { for (Socket s : list) { if (s != socket) { try { PrintStream ps = new PrintStream(s.getOutputStream()); ps.println(); } catch (IOException e) { e.printStackTrace(); } } } } }} |
--> 注意：因为要实现客户端连接到服务端，即客户端要先找到服务端，所以服务端要先开启，再开启服务端...
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
