堕落不振功业废,勤耕不辍日月新

基于线程池的TCP服务器(JAVA实现)

综合 hailen 18℃

基于线程池的TCP服务器(JAVA实现)

在开始的tcp/ip socket中 服务端实现方式是一个客户端一个线程,但是,每个新的线程都会消耗系统资源。随着线程数的增加。线程将消耗越来越多的系统资源。
对于这个问题,使用线程池限制线程总数并重复使用线程可以避免这个问题,
具体做法是,在服务器启动时创建一个有固定线程数量组成的线程池,当一个新的客户端连接请求连入服务器时,将由线程池中的一个线程处理,该线程处理完这个客户端之后又返回线程池,继续等待下一次请求,如果当客户端请求到达服务器时。线程池中所有的线程都已经被占用那么把请求放入等待队列中,直到有空闲的线程可用,当然使用线程池并不是最优的解决方案,因为在实际情况中需要考虑线程池的个数,使线程池的大小既不会创建太多,也不会太少,这是很难做到的。这需要一个策略来实现,具体实现后面会有

基于线程池的TCP服务器是实现步骤
1、与一个客户端,一个线程服务器一样,线程池服务器首先创建一个ServerSocket实例。
2、然后创建N个线程,每个线程反复循环,从(共享的)ServerSocket实例接收客户端连接。当多个线程同时调用一个ServerSocket实例的accept()方法时,它们都将阻塞等待,直到一个新的连接成功建立,然后系统选择一个线程,为建立起的连接提供服务,其他线程则继续阻塞等待。

具体实现代码如下:

客户端代码:
public static void tcpClient(String hostname, int port) throws IOException {
String serverResponse = null;
//与端口进行连接
Socket tcpClient = new Socket(hostname, port);
tcpClient.setSoTimeout(6000);
//获取键盘输入
BufferedReader input = new BufferedReader(new InputStreamReader(System.in));
//输出流
PrintStream out = new PrintStream(tcpClient.getOutputStream());
//输入流 ,获取服务器消息
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(tcpClient.getInputStream()));

//使用循环主要是为了更好的展示线程池,如果只是建立一次连接就结束,没有必要使用循环
boolean flag = true;
while (flag) {
System.out.print(“输入需要发送的信息:”);
String msg = input.readLine();
//发送数据到服务端
out.println(msg);
try {
serverResponse = bufferedReader.readLine();
System.out.println(“服务端返回:”+serverResponse);
} catch (SocketTimeoutException e) {
System.out.println(“连接超时,无响应”);
}
if (“bye”.equals(msg)) {
flag = false;
}
}
if (tcpClient != null) {
tcpClient.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
服务端线程类:
public class TcpServerThread implements Runnable {
private Socket client = null;

public TcpServerThread(Socket client) {
this.client = client;
}

public static void executeClient(Socket client) {
String msg = “你好,客户端”;
try {
//获取Socket的输出流,用来向客户端发送数据
PrintStream out = new PrintStream(client.getOutputStream());
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(client.getInputStream()));
boolean flag = true;
while (flag) {
String str = bufferedReader.readLine();
if (str == null || “”.equals(str)) {
flag = false;
} else {
out.println(“服务端消息:” + msg);
System.out.println(“接受到客户端消息客户端消息:” + str);
}
}
out.close();
bufferedReader.close();
client.close();

} catch (Exception e) {
e.printStackTrace();
}
}

public void run() {
executeClient(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
28
29
30
31
32
33
34
35
36
37
服务端代码
private static final int THREAD_POOL_SIZE = 3;
public static void tcpServerByPool(int serverPort)throws Exception{
final ServerSocket server = new ServerSocket(serverPort);
for(int i = 0; i< THREAD_POOL_SIZE; i++){
Thread thread = new Thread(){
public void run(){
while(true){
try {
//等待客户端的连接
Socket client = server.accept();
TcpServerThread.executeClient(client);
} catch (IOException e) {
e.printStackTrace();
}
}
}
};

thread.start();
}
}
———————
作者:Sean_zzZ
来源:CSDN
原文:https://blog.csdn.net/github_38151745/article/details/79061222
版权声明:本文为博主原创文章,转载请附上博文链接!

转载请注明:我是IT » 基于线程池的TCP服务器(JAVA实现)

喜欢 (0)or分享 (0)