public class MySocketServer {
    private static ExecutorService executorService = Executors.newCachedThreadPool();

    public static void main(String[] args) throws IOException, InterruptedException {
        //服务端的主线程是用来循环监听客户端请求
        ServerSocket server = new ServerSocket(8686);
        //创建一个服务端且端口为8686
        Socket client = null;
        System.out.println("服务端启动");

        //循环监听
        while (true) {
            //服务端监听到一个客户端请求
            System.out.println("阻塞等待accept....");
            client = server.accept();
            System.out.println(client.getRemoteSocketAddress() + "地址的客户端连接成功!");
            //将该客户端请求通过线程池放入HandlMsg线程中进行处理
            executorService.submit(new HandleMsg(client));
        }
    }

    public static void handle(Socket client) {
        //创建字符缓存输入流
        BufferedReader bufferedReader = null;
        //创建字符写入流
        PrintWriter printWriter = null;
        try {
            //获取客户端的输入流
            bufferedReader = new BufferedReader(new InputStreamReader(client.getInputStream()));
            //获取客户端的输出流，true是随时刷新
            printWriter = new PrintWriter(client.getOutputStream(), true);
            String inputLine = null;
            long a = System.currentTimeMillis();
            Thread.sleep(1000);

            while ((inputLine = bufferedReader.readLine()) != null) {
                printWriter.println("hello " + inputLine);
            }
            long b = System.currentTimeMillis();
            System.out.println(Thread.currentThread().getName() + "线程结束，花费了：" + (b - a) + "ms");
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            try {
                bufferedReader.close();
                printWriter.close();
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    //一旦有新的客户端请求，创建这个线程进行处理
    private static class HandleMsg implements Runnable {
        //创建一个客户端
        Socket client;
        public HandleMsg(Socket client) {
            this.client = client;
        }
        @Override
        public void run() {
            handle(client);
        }
    }
}

public class MySocketClient {
    public static void main(String[] args) throws IOException {
        for (int i = 0; i < 5; i++) {
            new Thread(new Runnable() {
                @SneakyThrows
                @Override
                public void run() {
                    callServer();
                }
            }).start();
        }
    }

    public static void callServer() throws IOException {
        Socket client = null;
        PrintWriter printWriter = null;
        BufferedReader bufferedReader = null;
        try {
            client = new Socket();
            // 连接超时
            client.connect(new InetSocketAddress("localhost", 8686), 100);
            // 读写超时
//            client.setSoTimeout(10);

            printWriter = new PrintWriter(client.getOutputStream(), true);
            printWriter.println(Thread.currentThread().getName());
            printWriter.flush();

            System.out.println(Thread.currentThread().getName() + " " + "等待服务端消息...");
            bufferedReader = new BufferedReader(new InputStreamReader(client.getInputStream()));            //读取服务器返回的信息并进行输出
            System.out.println(Thread.currentThread().getName() + " " + "来自服务器的信息是：" + bufferedReader.readLine());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            printWriter.close();
            bufferedReader.close();
            client.close();
        }
    }
}