基于BIO的Java Socket通信详解

Bio，即阻塞IO，在基于Socket的消息通信过程中，Socket服务端向外部提供服务，而Socket客户端可以建立到Socket服务端的连接，进而发送请求数据，然后等待Socket服务端处理，并返回处理结果（响应）。
基于BIO的通信，Socket服务端会发生阻塞，即在监听过程中每次accept到一个客户端的Socket连接，就要处理这个请求，而此时其他连接过来的客户端只能阻塞等待。可见，这种模式下Socket服务端的处理能力是非常有限的，客户端也只能等待，直到服务端空闲时进行请求的处理。

BIO通信实现

下面基于BIO模式，来实现一个简单的Socket服务端与Socket客户端进行通信的逻辑，对这种通信方式有一个感性的认识。具体逻辑描述如下：
1、Socket客户端连接到Socket服务端，并发送数据“I am the client N.”；
2、Socket服务端，监听服务端口，并接收客户端请求数据，如果请求数据以“I am the client”开头，则响应客户端“I am the server, and you are the Nth client.”；

Socket服务端实现，代码如下所示：

package org.shirdrn.java.communications.bio;  import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket;   public class SimpleBiotcpServer extends Thread {         private int port = 8888;      private static int sequence = 0;      public SimpleBioTcpServer(int port) {     this.port = port;   }      @Override   public void run() {     Socket socket = null;     try {       ServerSocket serverSocket = new ServerSocket(this.port);       while(true) {         socket = serverSocket.accept(); // 监听         this.handleMessage(socket); // 处理一个连接过来的客户端请求       }     } catch (IOException e) {       e.printStackTrace();     }   }         private void handleMessage(Socket socket) throws IOException {     InputStream in = socket.getInputStream(); // 流：客户端->服务端（读）     OutputStream out = socket.getOutputStream(); // 流：服务端->客户端（写）     int receiveBytes;     byte[] receiveBuffer = new byte[128];     String clientMessage = "";     if((receiveBytes=in.read(receiveBuffer))!=-1) {       clientMessage = new String(receiveBuffer, 0, receiveBytes);       if(clientMessage.startsWith("I am the client")) {         String serverResponseWords =            "I am the server, and you are the " + (++sequence) + "th client.";         out.write(serverResponseWords.getBytes());       }     }     out.flush();     System.out.println("Server: receives clientMessage->" + clientMessage);   }    public static void main(String[] args) {     SimpleBioTcpServer server = new SimpleBioTcpServer(1983);     server.start();   } }