Java使用线程池实现socket编程的方法详解

import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
    public static void main(String[] args) throws Exception {
        System.out.println("server start");
        ServerSocket server = new ServerSocket(1003);
        while (true) {
            Socket client = server.accept();
            InputStream input = client.getInputStream();
            byte[] b = new byte[8196];
            int len = input.read(b);
            System.out.println(new String(b, 0, len));
            if(new String(b).equals("close"))
                break;
            client.close();
        }
        server.close();
    }
}

import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class Client {
    public static void main(String[] args) throws Exception {
        System.out.println("client start");
        Scanner scanner =new Scanner(System.in);
        Socket client =new Socket("localhost",1003);
        OutputStream out = client.getOutputStream();
        while (true) {
            String str = scanner.nextLine();
            out.write(str.getBytes());
        }
    }
}

ExecutorService pool = Executors.newFixedThreadPool(3);

private static class InnerThread implements Runnable{
public void run();
}

InnerThread innerThread = new InnerThread();
pool.execute(innerThread);

while(true){
                Socket clientSocket = server.accept();
                InnerThread innerThread = new InnerThread(clientSocket);
                pool.execute(innerThread);
            }

BufferedReader br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter pw = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
while(true){
                    String buf = br.readLine();
                    System.out.println(Thread.currentThread().getName()+" client: " + buf);
                    if(buf.equals("close")){
                        break;
                    }
                    pw.println("response:"+buf);
                    pw.flush();
                }
                System.out.println("close client");
                br.close();
                pw.close();
                clientSocket.close();

BufferedReader br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter pw = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
            while(true){
                System.out.print("client: ");
                String buf = sc.nextLine();
                pw.println(buf);
                pw.flush();
                if(buf.equals("close")){
                    break;
                }
                buf= br.readLine();
                System.out.println("server: " + buf);
                if(buf.equals("close")){
                    break;
                }
            }
            br.close();
            pw.close();
            sc.close();
            clientSocket.close();