IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> Java知识库 -> 二、 剖析Netty的工作机制之Buffer、Channel、Selector分析 -> 正文阅读

[Java知识库]二、 剖析Netty的工作机制之Buffer、Channel、Selector分析

一、缓冲区

1.1 基本介绍

缓冲区(buffer):缓冲区本质上是一个可以读写数据的内存块,可以理解成是一个容器对象(含数组),该对象提供了一组方法,可以更轻松的使用内存块,缓冲区对象内置了一些机制,能够跟踪和记录缓冲区的状态变化情况。Channel提供从文件、网络读取数据的渠道,但是读写或写入的数据都必须经过Buffer
在这里插入图片描述

1.2 Buffer类及其子类分析

Buffer类定义了所有的缓冲区都具有的四个属性来提供关于其包含的数据元素的信息:
在这里插入图片描述

对于java中的基本数据类型(Boolean除外),都有一个Buffer类型与之相对应,最常用的自然是ByteBuffer类(二进制数据),该类的主要方法如下:

在这里插入图片描述

在这里插入图片描述
代码演示

package com.bio;

import java.nio.IntBuffer;

/*
* 实验目的:掌握Buffer的基本使用
* 实验步骤: 利用buffer 进行存取数据
* */
public class BasicBuffer {
    public static void main(String[] args) {
        //创建一个buffer对象,设置容量为10,默认为16
        IntBuffer intBuffer = IntBuffer.allocate(10);
        //循环往buffer中放入数据
        for (int i = 0; i < 10; i++) {
            intBuffer.put(i);
        }
        //反转buffer  当需要切换 读/写操作时  必须要调用 filp()
        intBuffer.flip();
        //设置开始读取的索引位置
        intBuffer.position(5);
        //设置读取的最大索引位置
        intBuffer.limit(8);
        while(intBuffer.hasRemaining()){
            System.out.println(intBuffer.get());
        }

    }
}

在这里插入图片描述

1.3

二、 Channel(通道)

2.1 基本介绍

NIO的通道类似于流,但是有些区别如下:

  • 通道可以同时进行读写,而流只能读或者只能写
  • 通道可以实现异步读写数据
  • 通道可以从缓冲读取数据,也可以写数据到缓冲区中
  • Channel在NIO中是一个接口public interface Channel extends Closeable{}
  • 常用的Channel 类有:FileChannel、DatagramChannel、ServerSocketChannel和SocketChannel.
  • FileChannel 用于文件的数据读写,DatagrapChannel 用于UDP的数据读写,ServerSocketChannel 和SocketChannel用于TCP的数据读写。

2.2 FileChannel 类

FileChannel主要用来对本地文件进行IO操作,常见的方法有

  • public int read(ByteBuffer dst) 从通道读取数据并放到缓冲区中
  • public int write(byteBuffer src) 把缓冲区的数据写到通道中
  • public long transferFrom (ReadableByteChannel src long position,long count) 从目标通道中复制数据到当前通道
  • public long transferTo(long position,long count,WritableByteChannel target),把数据从当前通道复制给目标通道

2.3 实例操作

实例要求

  • 使用前面学习后的ByteBuffer(缓冲)和FileChannel(通道)
  • 将 ”小沙弥,真帅“写入到file01.txt中
  • 从file01.txt 中读取数据显示到控制台
package com.nio;

import java.io.*;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

/*
* 实验目的:掌握对NIO中的channel使用
* 实验步骤:使用前面学习后的ByteBuffer(缓冲)和FileChannel(通道),将;小沙弥,真帅!“写入到file01.txt中
* */
public class NIOFileChannel01 {
    //创建ByteBuffer对象
    static   ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
    public static void main(String[] args) throws FileNotFoundException {
        // writeFile();
         readFile();
    }


    //将字符串写入到文件中
    public static void writeFile() throws FileNotFoundException {
        String str="小沙弥 真帅!";
        //创建一个文件输入流
        FileOutputStream fileOutputStream = new FileOutputStream("d:\\file01.txt");
        //通过文件输入流得到一个channel对象
        FileChannel channel = fileOutputStream.getChannel();
        //将数据写入到缓冲区中,并反转缓冲区
        byteBuffer.put(str.getBytes());
        byteBuffer.flip();
        try {
            channel.write(byteBuffer);
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                //关闭文件输入流
                fileOutputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

    }

    //从文件中读取字符串显示到控制台
    public static void readFile() throws FileNotFoundException {
        FileInputStream fileInputStream = new FileInputStream("d:\\file01.txt");
        FileChannel channel = fileInputStream.getChannel();
        try {
            channel.read(byteBuffer);
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                fileInputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        byteBuffer.flip();
        byte bytes[]=new byte[1024];
        bytes = byteBuffer.array();
        System.out.println(new String(bytes));
    }
}

流程图
在这里插入图片描述

在这里插入图片描述

实例 2

实验目的:巩固NIO中channel的使用
实验步骤:将图片使用 channel的transferFrom() 进行拷贝

package com.nio;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.nio.channels.FileChannel;

/*
* 实验目的:巩固NIO中channel的使用
* 实验步骤:将图片使用 channel的transferFrom() 进行拷贝
* */
public class NIOFileChannel02 {
    public static void main(String[] args) throws  Exception{
        FileInputStream  fileInputStream = new FileInputStream("d:\\a1.jpg");
        FileOutputStream fileOutputStream = new FileOutputStream("d:\\a2.jpg");

        //获取各个流相对应的filechannel
        FileChannel sourceChannel = fileInputStream.getChannel();
        FileChannel targetChannel = fileOutputStream.getChannel();
        //将数据从目标通道复制到当前通道
        targetChannel.transferFrom(sourceChannel,0,sourceChannel.size());
        //关闭各个流
        fileInputStream.close();
        fileOutputStream.close();
    }
}

推荐阅读上篇: 💥
一、Netty的特性介绍及解决的问题

  Java知识库 最新文章
计算距离春节还有多长时间
系统开发系列 之WebService(spring框架+ma
springBoot+Cache(自定义有效时间配置)
SpringBoot整合mybatis实现增删改查、分页查
spring教程
SpringBoot+Vue实现美食交流网站的设计与实
虚拟机内存结构以及虚拟机中销毁和新建对象
SpringMVC---原理
小李同学: Java如何按多个字段分组
打印票据--java
上一篇文章      下一篇文章      查看所有文章
加:2021-11-01 11:32:51  更:2021-11-01 11:33:11 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年10日历 -2024/10/30 17:21:07-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码