利用 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();} }

總結

以上是生活随笔為你收集整理的Java—BIO模型的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。