SocketIO---bio2---带线程池处理任务

1. server 先启动

public class Server {
    public static final int port = 8765;
    
    public static void main(String[] args) {
        System.out.println("Server start...
");
        Server server = new Server();
        server.init();

    }

    public void init()  {
        try {
            HandlerExecutorPool executorPool = new HandlerExecutorPool(50, 1000);
            ServerSocket serverSocket = new ServerSocket(port); //监听端口
            while(true){
                Socket socket = serverSocket.accept(); //接收客户端的请求数据
                executorPool.execute(new HandlerThread(socket));
                //new Thread(new HandlerThread(socket)).start(); //线程去处理请求
            }
        } catch (IOException e) {
            System.out.println("服务器异常: " + e.getMessage());
        }
    }
}

2. server 处理任务的线程

public class HandlerThread implements Runnable {
    private Socket socket;
    public HandlerThread(Socket socket){
        this.socket = socket;
    }
    
    @Override
    public void run() {
        try {
            BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String clientStr = input.readLine();
            System.out.println("服务端接收到客户端请求的数据为:"+clientStr);
            
            PrintStream out = new PrintStream(socket.getOutputStream());
            System.out.println("服务端请输入响应:	");
            String responseStr = new BufferedReader(new InputStreamReader(System.in)).readLine();
            out.println(responseStr);
            
            out.close();
            input.close();
            
        } catch (IOException e) {
            System.out.println("服务器 run 异常: " + e.getMessage());  
        } finally {    
            if (socket != null) {    
                try {    
                    socket.close();    
                } catch (Exception e) {    
                    socket = null;    
                    System.out.println("服务端 finally 异常:" + e.getMessage());    
                }    
            }    
        }   
        
    }

}

3. 线程池类

public class HandlerExecutorPool {

    private ExecutorService executor;
    public HandlerExecutorPool(int maxPoolSize, int queueSize){
        this.executor = new ThreadPoolExecutor(
                Runtime.getRuntime().availableProcessors(),//corePoolSize
                maxPoolSize, 
                120L, //keepAliveTime
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<Runnable>(queueSize));
    }
    
    public void execute(Runnable task){
        this.executor.execute(task);
    }
}

4. 客户端

public class Client {

    private static final int port = 8765;
    //private static final String host = "localhost"; 可以
    //private static final String host = "127.0.0.1"; 可以
    private static final String host = "192.168.233.1"; //可以
    
    public static void main(String[] args) {
        System.out.println("Client start...");
        while(true){
            Socket socket = null;
            try {
                socket = new Socket(host, port);
                BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintStream out = new PrintStream(socket.getOutputStream());
                System.out.println("客户端请输入请求:	");
                String str = new BufferedReader(new InputStreamReader(System.in)).readLine();
                out.println(str);
                
                String result = input.readLine();
                System.out.println("客户端接收到服务器端响应的数据:" + result);
                if("ok".equalsIgnoreCase(result)){
                    System.out.println("客户端将要关闭连接");
                    Thread.sleep(500);
                    break;
                }
                out.close();
                input.close();
                
            } catch (Exception e) {
                System.out.println("客户端异常:" + e.getMessage());
            } finally {
                if(null != socket){
                    try {
                        socket.close();
                    } catch (IOException e) {
                        socket = null;
                        System.out.println("客户端finally异常:"+e);
                    }
                }
            }
        }
    }
}