您当前的位置: 首页 > 

小志的博客

暂无认证

  • 0浏览

    0关注

    1217博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

Netty——ByteBuffer(ByteBuffer的基本使用)

小志的博客 发布时间:2022-07-18 22:41:56 ,浏览量:0

目录
    • 一、ByteBuffer 正确使用的步骤
    • 二、ByteBuffer的基本使用示例
      • 1.1、pom.xml文件引入依赖
      • 1.2、创建test.txt文件
      • 1.3、示例代码
      • 1.4、输出结果

一、ByteBuffer 正确使用的步骤
  1. 向 buffer 写入数据,例如:调用 channel.read(buffer)
  2. 调用 flip() 切换至读模式,例如:调用buffer.flip()
  3. 从 buffer 读取数据,例如:调用 buffer.get()
  4. 调用 clear() 或 compact() 切换至写模式,例如:调用buffer.clear()或 buffer.compact()
  5. 重复 1~4 步骤。
二、ByteBuffer的基本使用示例 1.1、pom.xml文件引入依赖
		
            io.netty
            netty-all
            4.1.39.Final
        
        
            org.projectlombok
            lombok
            1.16.18
        
        
            com.google.code.gson
            gson
            2.8.5
        
        
            com.google.guava
            guava
            19.0
        
        
            ch.qos.logback
            logback-classic
            1.2.3
        
        
            com.google.protobuf
            protobuf-java
            3.11.3
        
1.2、创建test.txt文件

在这里插入图片描述

1.3、示例代码
package com.example.nettytest.nio.day1;

import lombok.extern.slf4j.Slf4j;
import java.io.FileInputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

/**
 * @description:
 * @author: xz
 * @create: 2022-07-18 22:17
 */
@Slf4j
public class TestByteBuffer {
    public static void main(String[] args) {
        //FileChannel
        try (FileChannel channel = new FileInputStream("test.txt").getChannel()) {
            //allocate:分配一个新的字节缓冲区,容量为10
            ByteBuffer buffer = ByteBuffer.allocate(10);
            while(true){
                // 从 channel 读取数据,向 buffer 写入
                int len = channel.read(buffer);
                log.info("读取到的字节数 {}", len);
                if(len ==-1){
                    break;
                }
                // 打印 buffer 的内容
                buffer.flip();// 切换至读模式
                while (buffer.hasRemaining()){// 是否还有剩余未读数据
                    byte b = buffer.get();
                    log.info("实际字节 {}", (char) b);
                }
                buffer.clear(); // 切换为写模式
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
1.4、输出结果

在这里插入图片描述

关注
打赏
1661269038
查看更多评论
立即登录/注册

微信扫码登录

0.0397s