基于线程池的TCP服务器(JAVA实现)
2018-01-15 09:45
423 查看
在开始的tcp/ip socket中 服务端实现方式是一个客户端一个线程,但是,每个新的线程都会消耗系统资源。随着线程数的增加。线程将消耗越来越多的系统资源。
对于这个问题,使用线程池限制线程总数并重复使用线程可以避免这个问题,
具体做法是,在服务器启动时创建一个有固定线程数量组成的线程池,当一个新的客户端连接请求连入服务器时,将由线程池中的一个线程处理,该线程处理完这个客户端之后又返回线程池,继续等待下一次请求,如果当客户端请求到达服务器时。线程池中所有的线程都已经被占用那么把请求放入等待队列中,直到有空闲的线程可用,当然使用线程池并不是最优的解决方案,因为在实际情况中需要考虑线程池的个数,使线程池的大小既不会创建太多,也不会太少,这是很难做到的。这需要一个策略来实现,具体实现后面会有
2、然后创建N个线程,每个线程反复循环,从(共享的)ServerSocket实例接收客户端连接。当多个线程同时调用一个ServerSocket实例的accept()方法时,它们都将阻塞等待,直到一个新的连接成功建立,然后系统选择一个线程,为建立起的连接提供服务,其他线程则继续阻塞等待。
具体实现代码如下:
对于这个问题,使用线程池限制线程总数并重复使用线程可以避免这个问题,
具体做法是,在服务器启动时创建一个有固定线程数量组成的线程池,当一个新的客户端连接请求连入服务器时,将由线程池中的一个线程处理,该线程处理完这个客户端之后又返回线程池,继续等待下一次请求,如果当客户端请求到达服务器时。线程池中所有的线程都已经被占用那么把请求放入等待队列中,直到有空闲的线程可用,当然使用线程池并不是最优的解决方案,因为在实际情况中需要考虑线程池的个数,使线程池的大小既不会创建太多,也不会太少,这是很难做到的。这需要一个策略来实现,具体实现后面会有
基于线程池的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,其关联的输入输出流也会被关闭 } }
服务端线程类:
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); } }
服务端代码
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(); } }
相关文章推荐
- Java基于TCP实现服务器和多客户端之间的通信
- 【Java TCP/IP Socket】基于线程池的TCP服务器(含代码)
- 【Java TCP/IP Socket】基于线程池的TCP服务器(含代码)
- WINDOWS (服务器) 和 DOS(客户端) 网络互连 基于TCP/IP的编程实现
- 基于tcp服务器的多线程版-java-简单
- winsock实现基于TCP的客户端/服务器通讯
- WINDOWS (服务器) 和 DOS(客户端) 网络互连 基于TCP/IP的编程实现
- WINDOWS (服务器) 和 DOS(客户端) 网络互连 基于TCP/IP的编程实现
- 基于TCP和UDP的Socket实现(JAVA)
- 简易版基于Java的处理静态资源服务器实现
- 运用JAVA的concurrent.ExecutorService线程池实现socket的TCP和UDP连接
- 简易版基于Java的处理静态资源服务器实现
- java中基于线程池和反射机制实现定时任务
- WINDOWS (服务器) 和 DOS(客户端) 网络互连 基于TCP/IP的编程实现
- 基于WSAEventSelect模型的TCP服务器实现
- java 通过 socket 实现 服务器和客户端的通信 TCP
- 运用JAVA的concurrent.ExecutorService线程池实现socket的TCP和UDP连接
- WINDOWS (服务器) 和 DOS(客户端) 网络互连 基于TCP/IP的编程实现
- 初探基于TCP的服务器/客户端结构的聊天系统(三)之表情聊天的实现
- java基于TCP的socket编程简单实现[代码实践过]