BIO基本介绍以及使用

BIO基本介绍以及使用BIO 就是传统的 java io 编程 其相关的类和接口在 java io 上 BIO Blocking I O 同步阻塞 IO 服务器实现模式为一个连接一个线程 即客户端有连接请求时服务器端就会新起一个线程进行处理 如果这个线程不做任何事情会造成不必要的线程开销 可以通过线程池机制改善

大家好,我是讯享网,很高兴认识大家。

BIO就是传统的java io编程,其相关的类和接口在java.io 上。
BIO(Blocking I/O): 同步阻塞IO,服务器实现模式为一个连接一个线程,即客户端有连接请求时服务器端就会新起一个线程进行处理,如果这个线程不做任何事情会造成不必要的线程开销,可以通过线程池机制改善。
BIO适用于连接数较小且固定的架构,这种方式对服务器资源要求比较高,并发局限于应用,JDK1.4 以前的唯一选择。

1. BIO 简单流程

1.服务端启动一个ServerSocket
2.客户端启动Socket对服务器进行通信,默认情况下服务器端需要对每个客户建立一个线程与之通讯
3.客户端发出请求后,先咨询服务器是否有线程响应,如果没有则会等待,或者被拒绝
4.如果有响应,客户端线程会等待请求结束后,在继续执行

2.应用实例

1》使用BIO模型监听一个服务器端,监听6666端口,当有客户端连接时,就启动一个线程与之通讯
2》要求使用线程池机制改善,可以连接多个客户端
3》服务器端可以接收客户端发送的数据(telnet 方式即可)

package cn.qlq; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class BIOServer { 
    public static void main(String[] args) throws IOException { 
    // 1. 创建线程池 ExecutorService newCachedThreadPool = Executors.newCachedThreadPool(); // 2. 创建ServerSocket ServerSocket serverSocket = new ServerSocket(6666); System.out.println("服务器启动了===="); while (true) { 
    final Socket socket = serverSocket.accept(); System.out.println("接收到一个客户端连接"); newCachedThreadPool.execute(new Runnable() { 
    @Override public void run() { 
    handle(socket); } }); } } public static void handle(Socket socket) { 
    System.out.println("threadId: " + Thread.currentThread().getId() ); try { 
    byte[] bytes = new byte[1024]; // 通过sockets读取输入流 InputStream inputStream = socket.getInputStream(); // 循环读取数据 while (true) { 
    System.out.println("threadId: " + Thread.currentThread().getId() + " 等待read"); int read = inputStream.read(bytes); if (read != -1) { 
    String readStr = new String(bytes, 0, read); System.out.println("threadId: " + Thread.currentThread().getId() + "\t" + readStr); } else { 
    break; } } } catch (IOException e) { 
    e.printStackTrace(); } finally { 
    System.out.println("关闭和客户端的连接"); try { 
    socket.close(); } catch (IOException e) { 
    e.printStackTrace(); } } } } 

讯享网

启动服务端使用Telnet测试:
1. telnet连接

讯享网telnet 127.0.0.1 6666 

查看服务器日志

服务器启动了====
接收到一个客户端连接
threadId: 12
threadId: 12 等待read

2. CTRL + ] 键进入命令行,然后发送字符串命令


讯享网

Escape 字符为 'CTRL+]' Microsoft Telnet> send  发送字符串  Microsoft Telnet> send hello china! 发送字符串 hello china! Microsoft Telnet> 

3. 查看服务器控制台

讯享网服务器启动了==== 接收到一个客户端连接 threadId: 12 threadId: 12 等待read threadId: 12  threadId: 12 等待read threadId: 12 hello china! threadId: 12 等待read 

4. 新启动一个telnet窗口查看

欢迎使用 Microsoft Telnet Client Escape 字符为 'CTRL+]' Microsoft Telnet> send  发送字符串  Microsoft Telnet> 

5. 查看服务器控制台日志

讯享网服务器启动了==== 接收到一个客户端连接 threadId: 12 threadId: 12 等待read threadId: 12  threadId: 12 等待read threadId: 12 hello china! threadId: 12 等待read 接收到一个客户端连接 threadId: 13 threadId: 13 等待read threadId: 13  threadId: 13 等待read 

6. 断开一个

Microsoft Telnet> quit 

控制台日志

讯享网关闭和客户端的连接 

4. BIO问题

1》 每个请求都需要创建独立的线程,与对应的客户端进行Read,业务处理,数据Write
2》当并发数较大时,需要创建大量线程来处理连接,系统资源占用较大
3》连接建立后,如果当前线程暂时没有数据可读,则线程就阻塞在Read操作上,造成线程资源浪费

解决类似的问题就需要用NIO技术。

小讯
上一篇 2025-03-05 07:36
下一篇 2025-02-27 18:18

相关推荐

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容,请联系我们,一经查实,本站将立刻删除。
如需转载请保留出处:https://51itzy.com/kjqy/21599.html