本文实例为大家分享了java通过socket实现多人聊天室的具体代码,供大家参考,具体内容如下
socket可以实现网络上两个程序通过双向通道进行数据的交换,此外它是java中网络tcp/ip协议的封装,例如可以进行网络通信等等,下面我们就来简单写一下多人聊天室。
首先来分析一下要实现的流程
- 首先建立一个服务器端,构建serversocket并绑定端口
- 创建socket客户端,连接到指定ip以及其端口
- 然后使用accept阻塞接收socket发出的连接请求
- 获取连接后的socket客户端的输入流和输出流
- 根据输入流和输出流进行两者数据的通信
值得一提是:该socket是同步阻塞的,因此在socket客户端需要进行创建一个线程,来分别进行向服务器输出,和接收服务器传输的数据。要解决同步阻塞这个问题可以去了解java nio。
socket客户端代码如下:
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
|
import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.socket;
public class client{
public static void main(string[] args) throws ioexception {
//创建连接指定ip和端口的socket
socket socket = new socket( "127.0.0.1" , 5200 );
//获取系统标准输入流
bufferedreader reader = new bufferedreader( new inputstreamreader(system.in));
printwriter out = new printwriter(socket.getoutputstream());
bufferedreader in = new bufferedreader( new inputstreamreader(socket.getinputstream()));
//创建一个线程用于读取服务器的信息
new thread( new runnable() {
@override
public void run() {
try {
while ( true ){
system.out.println(in.readline());
}
} catch (ioexception e) {
e.printstacktrace();
}
}
}).start();
//写信息给客户端
string line = reader.readline();
while (! "end" .equalsignorecase(line)){
//将从键盘获取的信息给到服务器
out.println(line);
out.flush();
//显示输入的信息
line = reader.readline();
}
out.close();
in.close();
socket.close();
}
}
|
由于要接收多个客户端的请求,因此服务端需要多个线程进行分别来接收客户端的请求。
socket服务端代码如下:
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
|
import java.io.ioexception;
import java.net.serversocket;
import java.net.socket;
import java.util.list;
import java.util.vector;
public class servers {
//将接收到的socket变成一个集合
protected static list<socket> sockets = new vector<>();
public static void main(string[] args) throws ioexception {
//创建服务端
serversocket server = new serversocket( 5200 );
boolean flag = true ;
//接受客户端请求
while (flag){
try {
//阻塞等待客户端的连接
socket accept = server.accept();
synchronized (sockets){
sockets.add(accept);
}
//多个服务器线程进行对客户端的响应
thread thread = new thread( new serverthead(accept));
thread.start();
//捕获异常。
} catch (exception e){
flag = false ;
e.printstacktrace();
}
}
//关闭服务器
server.close();
}
}
|
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
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
|
import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.socket;
/**
* 服务器线程,主要来处理多个客户端的请求
*/
public class serverthead extends servers implements runnable{
socket socket;
string socketname;
public serverthead(socket socket){
this .socket = socket;
}
@override
public void run() {
try {
bufferedreader reader = new bufferedreader( new inputstreamreader(socket.getinputstream()));
//设置该客户端的端点地址
socketname = socket.getremotesocketaddress().tostring();
system.out.println( "client@" +socketname+ "已加入聊天" );
print( "client@" +socketname+ "已加入聊天" );
boolean flag = true ;
while (flag)
{
//阻塞,等待该客户端的输出流
string line = reader.readline();
//若客户端退出,则退出连接。
if (line == null ){
flag = false ;
continue ;
}
string msg = "client@" +socketname+ ":" +line;
system.out.println(msg);
//向在线客户端输出信息
print(msg);
}
closeconnect();
} catch (ioexception e) {
try {
closeconnect();
} catch (ioexception e1) {
e1.printstacktrace();
}
}
}
/**
* 向所有在线客户端socket转发消息
* @param msg
* @throws ioexception
*/
private void print(string msg) throws ioexception {
printwriter out = null ;
synchronized (sockets){
for (socket sc : sockets){
out = new printwriter(sc.getoutputstream());
out.println(msg);
out.flush();
}
}
}
/**
* 关闭该socket的连接
* @throws ioexception
*/
public void closeconnect() throws ioexception {
system.out.println( "client@" +socketname+ "已退出聊天" );
print( "client@" +socketname+ "已退出聊天" );
//移除没连接上的客户端
synchronized (sockets){
sockets.remove(socket);
}
socket.close();
}
}
|
由于要接收多个客户端的信息,并转发到每一个已经连接上的客户端,因此创建了一个vector集合来保存每一个客户端socket,由于是多个线程同时对这个vector集合进行操作,因此加上synchronized关键字保证同步安全。
先运行服务器端,然后在运行多个客户端就可以进行多人聊天了。
下面是运行的结果。
客户端2
客户端1
客户端3
服务端
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://blog.csdn.net/qq741058114/article/details/82918351