当前位置: 开发笔记 > 运维 > 正文

基于BIO的JavaSocket通信详解

作者：mobiledu2502885111 | 来源：互联网 | 2022-10-17 15:27

这篇文章主要为大家详细介绍了基于BIO的JavaSocket通信相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

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; 
 
/** 
 * 基于BIO的Socket服务器端 
 * 
 * @author shirdrn 
 */ 
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(); 
    } 
  } 
   
  /** 
   * 处理一个客户端socket连接 
   * @param socket 客户端socket 
   * @throws IOException 
   */ 
  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(); 
  } 
}

上述实现，没有进行复杂的异常处理。

Socket客户端实现，代码如下所示：

package org.shirdrn.java.communications.bio; 
 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.OutputStream; 
import java.net.Socket; 
import java.net.UnknownHostException; 
import java.util.Date; 
 
/** 
 * 基于BIO的Socket客户端 
 * 
 * @author shirdrn 
 */ 
public class SimpleBioTcpClient { 
   
  private String ipAddress; 
  private int port; 
  private static int pos = 0; 
   
  public SimpleBioTcpClient() {} 
   
  public SimpleBioTcpClient(String ipAddress, int port) { 
    this.ipAddress = ipAddress; 
    this.port = port; 
  } 
 
  /** 
   * 连接Socket服务端，并模拟发送请求数据 
   * @param data 请求数据 
   */ 
  public void send(byte[] data) { 
    Socket socket = null; 
    OutputStream out = null; 
    InputStream in = null; 
    try { 
      socket = new Socket(this.ipAddress, this.port); // 连接 
      // 发送请求 
      out = socket.getOutputStream(); 
      out.write(data);  
      out.flush(); 
      // 接收响应 
      in = socket.getInputStream(); 
      int totalBytes = 0; 
      int receiveBytes = 0; 
      byte[] receiveBuffer = new byte[128]; 
      if((receiveBytes=in.read(receiveBuffer))!=-1) { 
        totalBytes += receiveBytes; 
      } 
      String serverMessage = new String(receiveBuffer, 0, receiveBytes); 
      System.out.println("Client: receives serverMessage->" + serverMessage); 
    } catch (UnknownHostException e) { 
      e.printStackTrace(); 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      try { 
        // 发送请求并接收到响应，通信完成，关闭连接 
        out.close(); 
        in.close(); 
        socket.close(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
 
  public static void main(String[] args) { 
    int n = 1; 
    StringBuffer data = new StringBuffer(); 
    Date start = new Date(); 
    for(int i=0; i

首先启动Socket服务端进程SimpleBioTcpServer，然后再运行Socket客户端SimpleBioTcpClient。可以看到，服务端接收到请求数据，然后响应客户端，客户端接收到了服务端的响应数据。

上述实现中，对于Socket客户端和服务端都是一次写入，并一次读出，而在实际中如果每次通信过程中数据量特别大的话，服务器端是不可能接受的，可以在确定客户端请求数据字节数的情况，循环来读取并进行处理。

另外，对于上述实现中流没有进行装饰（Wrapped）处理，在实际中会有性能的损失，如不能缓冲等。

对于Socket服务端接收数据，如果可以使多次循环读取到的字节数据通过一个可变长的字节缓冲区来存储，就能方便多了，可是使用ByteArrayOutputStream，例如：

ByteArrayOutputStream data = new ByteArrayOutputStream(); 
data.write(receiveBuffer, totalBytes , totalBytes + receiveBytes);

BIO通信测试

下面测试一下大量请求的场景下，Socket服务端处理的效率。

第一种方式：通过for循环来启动5000个Socket客户端，发送请求，代码如下所示：

public static void main(String[] args) { 
  int n = 5000; 
  StringBuffer data = new StringBuffer(); 
  Date start = new Date(); 
  for(int i=0; i

经过测试，大约需要9864ms，大概接近10s。

第二种方式：通过启动5000个独立的客户端线程，同时请求，服务端进行计数：

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; 
import java.net.UnknownHostException; 
import java.util.Date; 
 
/** 
 * 基于BIO的Socket通信测试 
 * 
 * @author shirdrn 
 */ 
public class SimpleBioTcpTest { 
   
  static int threadCount = 5000; 
   
  /** 
   * 基于BIO的Socket服务端进程 
   * 
   * @author shirdrn 
   */ 
  static class SocketServer extends Thread { 
     
    /** 服务端口号 */ 
    private int port = 8888; 
    /** 为客户端分配编号 */ 
    private static int sequence = 0; 
     
    public SocketServer(int port) { 
      this.port = port; 
    } 
     
    @Override 
    public void run() { 
      Socket socket = null; 
      int counter = 0; 
      try { 
        ServerSocket serverSocket = new ServerSocket(this.port); 
        boolean flag = false; 
        Date start = null; 
        while(true) { 
          socket = serverSocket.accept(); // 监听 
          // 有请求到来才开始计时 
          if(!flag) { 
            start = new Date(); 
            flag = true; 
          } 
          this.handleMessage(socket); // 处理一个连接过来的客户端请求 
          if(++counter==threadCount) { 
            Date end = new Date(); 
            long last = end.getTime() - start.getTime(); 
            System.out.println(threadCount + " requests cost " + last + " ms."); 
          } 
        } 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
     
    /** 
     * 处理一个客户端socket连接 
     * @param socket 客户端socket 
     * @throws IOException 
     */ 
    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); 
    } 
  } 
   
  /** 
   * 基于BIO的Socket客户端线程 
   * 
   * @author shirdrn 
   */ 
  static class SocketClient implements Runnable { 
     
    private String ipAddress; 
    private int port; 
    /** 待发送的请求数据 */ 
    private String data; 
     
    public SocketClient(String ipAddress, int port) { 
      this.ipAddress = ipAddress; 
      this.port = port; 
    } 
 
    @Override 
    public void run() { 
      this.send();       
    } 
     
    /** 
     * 连接Socket服务端，并模拟发送请求数据 
     */ 
    public void send() { 
      Socket socket = null; 
      OutputStream out = null; 
      InputStream in = null; 
      try { 
        socket = new Socket(this.ipAddress, this.port); // 连接 
        // 发送请求 
        out = socket.getOutputStream(); 
        out.write(data.getBytes());  
        out.flush(); 
        // 接收响应 
        in = socket.getInputStream(); 
        int totalBytes = 0; 
        int receiveBytes = 0; 
        byte[] receiveBuffer = new byte[128]; 
        if((receiveBytes=in.read(receiveBuffer))!=-1) { 
          totalBytes += receiveBytes; 
        } 
        String serverMessage = new String(receiveBuffer, 0, receiveBytes); 
        System.out.println("Client: receives serverMessage->" + serverMessage); 
      } catch (UnknownHostException e) { 
        e.printStackTrace(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } catch (Exception e) { 
        e.printStackTrace(); 
      } finally { 
        try { 
          // 发送请求并接收到响应，通信完成，关闭连接 
          out.close(); 
          in.close(); 
          socket.close(); 
        } catch (IOException e) { 
          e.printStackTrace(); 
        } 
      } 
    } 
 
    public void setData(String data) { 
      this.data = data; 
    } 
  } 
 
  public static void main(String[] args) throws Exception { 
    SocketServer server = new SocketServer(1983); 
    server.start(); 
     
    Thread.sleep(3000); 
     
    for(int i=0; i

经过测试，大约需要7110ms，大概接近7s，没有太大提高。

BIO通信改进

通过上面的测试我们可以发现，在Socket服务端对来自客户端的请求进行处理时，会发生阻塞，严重地影响了能够并发处理请求的效率。实际上，在Socket服务端接收来自客户端连接能力的范围内，可以将接收请求独立出来，从而在将处理请求独立粗话来，通过一个请求一个线程处理的方式来解决上述问题。这样，服务端是多处理线程对应客户端多请求，处理效率有一定程度的提高。

下面，通过单线程接收请求，然后委派线程池进行多线程并发处理请求：

/** 
   * 基于BIO的Socket服务端进程 
   * 
   * @author shirdrn 
   */ 
  static class SocketServer extends Thread { 
     
    /** 服务端口号 */ 
    private int port = 8888; 
    /** 为客户端分配编号 */ 
    private static int sequence = 0; 
    /** 处理客户端请求的线程池 */ 
    private ExecutorService pool; 
     
    public SocketServer(int port, int poolSize) { 
      this.port = port; 
      this.pool = Executors.newFixedThreadPool(poolSize); 
    } 
     
    @Override 
    public void run() { 
      Socket socket = null; 
      int counter = 0; 
      try { 
        ServerSocket serverSocket = new ServerSocket(this.port); 
        boolean flag = false; 
        Date start = null; 
        while(true) { 
          socket = serverSocket.accept(); // 监听 
          // 有请求到来才开始计时 
          if(!flag) { 
            start = new Date(); 
            flag = true; 
          } 
          // 将客户端请求放入线程池处理 
          pool.execute(new RequestHandler(socket)); 
          if(++counter==threadCount) { 
            Date end = new Date(); 
            long last = end.getTime() - start.getTime(); 
            System.out.println(threadCount + " requests cost " + last + " ms."); 
          } 
        } 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
     
    /** 
     * 客户端请求处理线程类 
     * 
     * @author shirdrn 
     */ 
    class RequestHandler implements Runnable { 
 
      private Socket socket; 
       
      public RequestHandler(Socket socket) { 
        this.socket = socket; 
      } 
       
      @Override 
      public void run() { 
        try { 
          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); 
        } catch (IOException e) { 
          e.printStackTrace(); 
        }         
      } 
    } 
  }

可见，这种改进方式增强服务端处理请求的并发度，但是每一个请求都要由一个线程去处理，大量请求造成服务端启动大量进程进行处理，也是比较占用服务端资源的。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

推荐阅读

服务器
利用Linux服务器构建简单路由器

本文介绍如何通过配置Linux服务器作为路由器来实现两个不同网段（192.168.1.0/24 和 192.168.2.0/24）之间的互联互通。 ... [详细]

蜡笔小新 2024-11-27 20:39:27
服务器
四套住房实战经验：如何构建高效全屋WiFi系统

基于四套不同房屋的实际应用案例，本文深入探讨了全屋WiFi系统的构建方法与技巧，旨在帮助读者避免常见错误，实现最佳的家庭网络覆盖。 ... [详细]

蜡笔小新 2024-11-28 20:18:46
服务器
C# Winform 实现局域网文件传输

本文介绍了如何使用C# Winform开发局域网内的文件传输功能，详细描述了从用户界面到后端网络通信的具体实现。 ... [详细]

蜡笔小新 2024-11-25 20:10:16
服务器
Socket 编程基础入门

本文介绍了一个基本的同步Socket程序，演示了如何实现客户端与服务器之间的简单消息传递。此外，文章还概述了Socket的基本工作流程，并计划在未来探讨同步与异步Socket的区别。 ... [详细]

蜡笔小新 2024-11-25 12:35:34
服务器
Linux网络配置文件详解及常见命令

本文详细介绍了Linux系统中网络配置文件的作用及其配置方法，并提供了常用的网络管理命令，帮助用户更好地理解和管理网络配置。 ... [详细]

蜡笔小新 2024-11-18 17:20:14
服务器
深入理解FastDFS

FastDFS是一款高效、简洁的分布式文件系统，广泛应用于互联网应用中，用于处理大量用户上传的文件，如图片、视频等。本文探讨了FastDFS的设计理念及其如何通过独特的架构设计提高性能和可靠性。 ... [详细]

蜡笔小新 2024-12-03 14:42:56
服务器
如何为定制化平板电脑连接蓝牙键盘？

本文介绍了为定制化平板电脑连接蓝牙键盘的具体步骤，旨在帮助用户提升平板电脑的使用体验。 ... [详细]

蜡笔小新 2024-12-01 19:24:43
linux
Android开发经验分享：优化用户体验的关键因素

随着Android市场的不断扩展，用户对于移动应用的期望也在不断提高。本文探讨了在Android开发中如何优化用户体验，以及为何用户体验的重要性超过了技术本身。 ... [详细]

蜡笔小新 2024-11-28 16:32:13
server
代码优化：避免重复和提高可读性

本文讨论了在处理分页数据时常见的低级错误，并提供了优化后的代码示例，以减少重复代码并提高可读性和维护性。 ... [详细]

蜡笔小新 2024-11-28 15:27:32
server
如何阻止iOS14下载的应用同步至其他苹果设备

对于同时使用多台苹果设备（如iPhone和iPad）的用户而言，可能会遇到在一个设备上下载的应用自动同步到其他设备的情况。如果您希望避免这种自动同步，以节省存储空间或减少不必要的应用同步，下面的方法或许能帮助您。 ... [详细]

蜡笔小新 2024-11-28 15:22:15
server
JavaScript技巧：判断Web应用是在Safari浏览器还是以独立模式运行

本文介绍了如何使用JavaScript来检测Web页面是通过Safari浏览器的标准模式打开，还是作为独立应用（无地址栏）从iPad的主屏幕启动。 ... [详细]

蜡笔小新 2024-11-25 15:25:58
server
Web应用与原生应用的区别及应用场景

本文探讨了Web应用（Web App）与原生应用（Native App）之间的主要差异，包括它们在开发、功能实现及版本管理等方面的不同特点，并分析了各自的优势与适用场景。 ... [详细]

蜡笔小新 2024-11-22 16:12:44
server
朋友，别随意打开陌生文件夹

一个周末的家庭聚会，因为一个不经意的举动，引发了一系列尴尬的事件。 ... [详细]

蜡笔小新 2024-11-20 20:27:45
server
Web前端开发的职业前景与就业指南

随着互联网行业的蓬勃发展，Web前端技术因其在用户界面和交互设计中的关键作用而备受企业重视。本文探讨了前端开发的职业前景，以及应届毕业生如何提高自己的竞争力。 ... [详细]

蜡笔小新 2024-11-19 13:47:18
ssh
Python中的pexpect模块与Linux中的expect命令

本文介绍了Linux系统中的expect命令及其在自动化任务中的应用，同时探讨了Python中的pexpect模块如何实现类似功能。 ... [详细]

蜡笔小新 2024-11-18 13:38:40

mobiledu2502885111

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章