利用 BIO 模型（传统阻塞 IO 模型）实现多用户访问

源代码

Server类
public class server {public static void main(String[] args) {ExecutorService executorService= Executors.newFixedThreadPool(6);try {ServerSocket serverSocket=new ServerSocket(9999);while (true){Socket socket =serverSocket.accept();executorService.execute(new SocketHandle(socket));}} catch (IOException ioException) {executorService.shutdown();ioException.printStackTrace();}}
}
SocketHandle类
public class SocketHandle implements  Runnable {private Socket socket;public SocketHandle(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {InputStreamReader in=new InputStreamReader(socket.getInputStream());BufferedReader bufferedReader=new BufferedReader(in);PrintWriter out=new PrintWriter(socket.getOutputStream());String client="<"+socket.getInetAddress()+":"+socket.getPort()+">"；String req=bufferedReader.readLine();System.out.println(client+"   say:   "+req);String ret=client+",Hello,too!";out.println(ret);out.flush();out.close();bufferedReader.close();socket.close();}catch (Exception e){e.printStackTrace();}}
}
Test类
public class test {public static void main(String[] args) throws Exception {Socket socket=new Socket("localhost",9999);InputStreamReader inputStreamReader=new InputStreamReader(socket.getInputStream());BufferedReader bufferedReader=new BufferedReader(inputStreamReader);PrintWriter writer=new PrintWriter(socket.getOutputStream());writer.println("Hello Sever");writer.flush();System.out.println("Server say:"+bufferedReader.readLine());writer.close();bufferedReader.close();socket.close();}
}