Java IO模型深入解析:BIO、NIO与AIO

news2024/9/22 2:09:06

Java IO模型深入解析:BIO、NIO与AIO

一. 前言

在Java编程中,IO(Input/Output)操作是不可或缺的一部分,它涉及到文件读写、网络通信等方面。Java提供了多种类和API来支持这些操作。本文将从IO的基础知识讲起,逐步深入,介绍Java IO的各个方面。

二. IO模型概述

2.1. IO模型分类

Java BIO:同步阻塞IO模型,服务器端为每个客户端连接创建一个线程,适用于连接数较少的场景。

Java NIO:同步非阻塞IO模型,通过选择器(Selector)监控多个通道(Channel),适用于高并发场景。

Java AIO:异步非阻塞IO模型,基于事件和回调机制,适用于大量并发连接且连接时间较长的应用。

2.2. BIO、NIO、AIO使用场景分析

  • BIO:适用于连接数较少且稳定的应用,如传统的Web应用服务器。
  • NIO:适用于需要处理大量并发连接的应用,如聊天服务器、弹幕系统。
  • AIO:适用于连接数多且连接时间较长的应用,如相册服务器、消息队列系统。

2.3. NIO与BIO的比较

  1. 数据流方式:BIO以流的方式处理数据,NIO以块的方式处理数据。
  2. 阻塞性:BIO是阻塞的,NIO是非阻塞的。
  3. 编程模型:BIO基于字节流和字符流,NIO基于通道和缓冲区。
  4. 资源消耗:BIO为每个连接创建一个线程,资源消耗大;NIO通过选择器监控多个通道,资源消耗小。

三. BIO(同步阻塞IO)

3.1. BIO编程流程

  1. 服务器端启动一个ServerSocket。
  2. 客户端启动Socket与服务器通信。
  3. 服务器端为每个客户端连接创建一个线程。
  4. 客户端请求结束后,线程结束。

3.2. BIO应用实例

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class BIOServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(6666);
        System.out.println("服务器启动了");
        while (true) {
            System.out.println("等待连接....");
            final Socket socket = serverSocket.accept();
            System.out.println("连接到一个客户端");
            new Thread(() -> {
                try {
                    InputStream inputStream = socket.getInputStream();
                    byte[] bytes = new byte[1024];
                    int read;
                    while((read = inputStream.read(bytes)) != -1) {
                        System.out.println(new String(bytes, 0, read));
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                } finally {
                    socket.close();
                }
            }).start();
        }
    }
}

3.3. BIO问题分析

  1. 线程开销:每个连接需要一个线程,资源消耗大。
  2. 并发限制:受限于线程数量,难以处理大量并发连接。

四. NIO(同步非阻塞IO)

4.1. NIO核心组件

  • 选择器(Selector):监控多个通道的IO事件。
  • 通道(Channel):进行非阻塞的IO操作。
  • 缓冲区(Buffer):存储IO操作的数据。

4.2. NIO三大核心原理示意图

NIO原理图

4.3. 缓冲区(Buffer)

4.3.1. Buffer类及其子类

Buffer是NIO中用于数据缓冲的顶层抽象类,包括ByteBuffer、CharBuffer等。

4.3.2. ByteBuffer

ByteBuffer是ByteBuffer类的基本使用,包括allocate、put、get等方法。

4.4. 通道(Channel)

4.4.1. FileChannel类

FileChannel用于文件的读写操作,常用方法有read、write、transferFrom等。

4.4.2. Selector应用

Selector用于监听多个通道的IO事件,提高并发处理能力。

五. AIO(异步非阻塞IO)

5.1. AIO基本介绍

AIO是Java 7引入的异步IO模型,基于事件和回调机制,适用于大量并发连接。

5.2. AIO的特点

  1. 高并发性:支持大量并发连接。
  2. 高吞吐量:异步读写操作,提高数据读写效率。
  3. 高可靠性:避免线程阻塞,提高程序可靠性。
  4. 简单易用:提供简单易用的API。

5.3. AIO的应用

AIO适用于需要大量并发连接且连接时间较长的应用,如相册服务器、消息队列系统。

六. 总结

BIONIOAIO
IO模型同步阻塞同步非阻塞(多路复用)异步非阻塞
编程难度简单复杂复杂
可靠性
吞吐量

通过本文的介绍,相信大家对Java的BIO、NIO和AIO有了更深入的理解。选择合适的IO模型,可以显著提高程序的性能和并发处理能力。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1943479.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

虚拟现实和增强现实技术系列—Expressive Talking Avatars

文章目录 1. 概述2. 背景介绍3. 数据集3.1 设计标准3.2 数据采集 4. 方法4.1 概述4.2 架构4.3 目标函数 5. 实验评测5.1 用户研究5.2 我们方法的结果5.3 比较与消融研究 1. 概述 支持远程协作者之间的交互和沟通。然而,明确的表达是出了名的难以创建,主…

两台电脑之间如何进行数据传输?两台电脑数据传输攻略

在数字化时代,电脑之间的数据传输变得日益重要。无论是个人用户还是企业用户,经常需要在不同的电脑之间共享或迁移数据。那么,两台电脑之间如何进行数据传输呢?本文将详细介绍两台电脑之间进行数据传输的几种常见方法,…

奖金+奖杯+荣誉证书 | FPGA硬件扑克牌比赛邀你参加

关键词:个人赛,随机发牌,比运气,还比设计,好玩又有趣 想用FPGA玩一场有趣的游戏吗?想检验自己的FPGA算法水平吗? “向日葵杯”全国教育仿真技术大赛——FPGA硬件扑克牌对抗赛等你来体验&#…

I can‘t link the chatbot model with react

题意:我无法将聊天机器人模型 chatbot 与React连接起来 问题背景: This is the model from flask import Flask, request, jsonify from flask_cors import CORS import json import nltk import numpy as np import random import pickle from time i…

英特尔终于宣布了解决CPU崩溃和不稳定性问题的方法,声称过高的电压是根本原因;补丁预计将于8月中旬推出【更新】

英特尔终于宣布了解决CPU崩溃和不稳定性问题的方法,声称过高的电压是根本原因;补丁预计将于8月中旬推出【更新】 英特尔官方宣布,已找到困扰其CPU的崩溃问题的根本原因,并将于8月中旬前发布微码更新以解决这一问题,从而…

聊聊 C# 中的顶级语句

前言 在 C# 9.0 版本之前,即使只编写一行输出 “Hello world” 的 C# 代码,也需要创建一个 C# 类,并且需要为这个 C# 类添加 Main 方法,才能在 Main 方法中编写代码。从 C# 9.0 开始,C# 增加了 “顶级语句” 语法&…

获取对象碎片情况

查看oracle数据库表上碎片 先创建个函数 FUNCTION get_space_usage1(owner IN VARCHAR2,object_name IN VARCHAR2,segment_type IN VARCHAR2,partition_name IN VARCHAR2 DEFAULT NULL) RETURN sys.DBMS_DEBUG_VC2COLL PIPELINEDASufbl NUMBER;ufby NUMBER;fs1bl NUMBER…

赋值运算符重载和运算符重载

1.运算符重载 在C中,运算符重载是一种强大的特性,它允许我们为已有的运算符赋予新的意义,以便它们能够应用于自定义类型上。 这一特性极大地增强了C的表达能力,使得自定义类型的使用更加直观和自然。例如,如果我们定义…

【区块链+绿色低碳】包头林草市域碳中和体系建设项目 | FISCO BCOS应用案例

在双碳体系建设背景下,政府、企业都在积极探索碳中和价值实现路径。但是在林业碳汇场景中,存在着林权认证、 身份授权、多方机构协作、数据交换等流程,在这些复杂的业务协作中存在一些风险,如:身份信息泄漏、数据造假、…

BSV区块链技术现实应用原理解析

BSV区块链以其卓越的可扩展性、坚如磐石的安全性、极低的交易成本等特性,成为满足企业当下需求并为企业未来成功奠基铺路的理想技术。 BSV协会近期发布了一个题为《驾驭数字化转型:在自动化世界中建立信任——区块链在数据保护和交易优化中的角色》的报…

Java代码基础算法练习-竞猜卡片值-2024.07.22

任务描述: 小米和小王玩竞猜游戏:准备7张卡片包含数字2、3、4、5、6、7、8,从中抽出2张(有 顺序之分,抽2、3跟抽3、2是两种情况),猜2张卡片的和,如果是奇数,则猜对。小米…

mmpretrain报错解决记录-socket.gaierror: [Errno -2] Name or service not known

在使用Beit模型时出现 mmengine - INFO - load model from: https://download.openmmlab.com/mmselfsup/1.x/target_generator_ckpt/dalle_encoder.pth 07/19 11:27:30 - mmengine - INFO - Loads checkpoint by http backend from path: https://download.openmmlab.com/mmsel…

unity2022 il2cpp 源码编译

新建一个XCODE静态库工程 从unity安装目录中找到il2cpp源码 Editor\Data\il2cpp\ 改名 il2cpp/libil2cpp -> il2cpp/il2cpp 加入工程中 ->工程根目录 extends/zlib libil2cpp/ buildSettings 相关设置 IOS Deployment Target ios 12.0 Header Search Paths $(in…

总结——TI_音频信号分析仪

一、简介 设备:MSPM0G3507 库:CMSIS-DSP TI 数据分析:FFT 软件:CCS CLion MATLAB 目的:对音频信号进行采样(滤波偏置处理),通过FFT获取信号的频率成分&am…

7.23模拟赛总结 [数据结构优化dp] + [神奇建图]

目录 复盘题解T2T4 复盘 浅复盘下吧… 7:40 开题 看 T1 ,起初以为和以前某道题有点像,子序列划分,注意到状态数很少,搜出来所有状态然后 dp,然后发现这个 T1 和那个毛关系没有 浏览了一下,感觉 T2 题面…

前端(1)HTML

1、标签 创建1.html文件&#xff0c;浏览器输入E:/frontheima/1.html&#xff0c;可以访问页面 页面展示 在VSCODE安装IDEA的快捷键&#xff0c;比如ctld复制一行、ctrlx剪切 <p id"p1" title"标题1">Hello,world!</p> <p id"p2"…

Java | Leetcode Java题解之第268题丢失的数字

题目&#xff1a; 题解&#xff1a; class Solution {public int missingNumber(int[] nums) {int n nums.length;int total n * (n 1) / 2;int arrSum 0;for (int i 0; i < n; i) {arrSum nums[i];}return total - arrSum;} }

[排序]hoare快速排序

今天我们继续来讲排序部分&#xff0c;顾名思义&#xff0c;快速排序是一种特别高效的排序方法&#xff0c;在C语言中qsort函数&#xff0c;底层便是用快排所实现的&#xff0c;快排适用于各个项目中&#xff0c;特别的实用&#xff0c;下面我们就由浅入深的全面刨析快速排序。…

PHP接入consul,注册服务和发现服务【学习笔记】

PHP接入consul,注册服务和发现服务 consul安装 链接: consul安装 启动consul C:\Users\14684>consul agent -dev安装TP5 composer create-project topthink/think5.0.* tp5_pro --prefer-dist配置consul 创建tp5_pro/application/service/Consul.php <?php /*****…

环境变量配置文件中两种路径添加方式

环境变量配置文件中两种路径添加方式 文章目录 环境变量配置文件中两种路径添加方式代码示例区别和作用 代码示例 export HBASE_HOME/opt/software/hbase-2.3.5 export PATH$PATH:$HBASE_HOME/binexport SPARK_HOME/opt/software/spark-3.1.2 export PATH$SPARK_HOME/bin:$PAT…