【Netty】NIO 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 操作

文章目录

I . 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 概念
II . 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 示例 ( 客户端 )
III . 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 示例 ( 服务器端 )

I . 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 概念

1 . 分散 Scattering 对应缓冲区写入 : 通道 ( Channel ) 向缓冲区数组中写出数据 , 按照索引从第 0 个缓冲区 ( Buffer ) 开始, 依次写入数据 ;

缓冲区 ( Buffer ) 分散 ( Scattering ) 对应方法 : 这是一类方法 , 有很多 , 这里只举一个例子说明 ;

public long read(ByteBuffer[] dsts) throws IOException;

2 . 聚合 Gathering 对应缓冲区读取 : 通道 ( Channel ) 从缓冲区数组中读取数据 , 按照索引从第 0 个缓冲区 ( Buffer ) 开始, 依次读取数据 ;

缓冲区 ( Buffer ) 聚合 ( Gathering ) 对应方法 : 这是一类方法 , 有很多 , 这里只举一个例子说明 ;

public long write(ByteBuffer[] srcs) throws IOException;

分散 Scattering 与聚合 Gathering 都是通道 ( Channel ) 对缓冲区数组 ( Buffer[] ) 进行读写的操作 ;

II . 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 示例 ( 客户端 )

客户端需求 : 本节演示代码的重心在服务器端 , 服务器端演示分散聚合的具体操作 , 客户端只是演示网络套接字流程 , 这里客户端使用 BIO , 使用 TCP 协议进行简单的数据发送 ;

package kim.hsl.bio;import java.io.IOException;
import java.net.Inet4Address;
import java.net.InetSocketAddress;
import java.net.Socket;public class TCPClient {public static void main(String[] args) {try {Socket socket = new Socket();InetSocketAddress inetSocketAddress =new InetSocketAddress(Inet4Address.getLocalHost(),   //本机IP地址8888                      //端口号);System.out.println("客户端开始连接 ...");//此处会阻塞等待连接成功socket.connect(inetSocketAddress);System.out.println("客户端连接成功");//连接成功后, 开始执行后续操作socket.getOutputStream().write("Hello World".getBytes());System.out.println("客户端写出 Hello World 成功");} catch (IOException e) {e.printStackTrace();}}
}

这是之前的示例中使用过的 , 这里在用一次 , 实现的功能就是连接目标 IP 地址的 8888 端口 , 发送 “Hello World” 字符串给服务器 , 之后退出 ;

III . 缓冲区 ( Buffer ) 分散 Scattering 与聚合 Gathering 示例 ( 服务器端 )

1 . 示例需求 : 服务器端使用多个缓冲区 ( Buffer ) 组成的数组 , 进行读写数据 , 客户端上传的数据通过套接字通道 ( SocketChannel ) 写出到缓冲区数组中 , 服务器端再使用文件通道 ( FileChannel ) 将数据写出到本地文件中 ;

2 . 示例分析 :

① 缓冲区数组 : ByteBuffer[] buffers = new ByteBuffer[2]; , 创建一个缓冲区数组 , 将这两个缓冲区数组作为读写操作的载体 , 读取数据时就涉及到了缓冲区的聚合操作 , 写出数据时 , 就涉及到了分散操作 ;

② 分散 Scattering : socketChannel.read(buffers); , 这里直接将数据读取存放到了缓冲区数组中 , 是将数据分散放入缓冲区数组 , 涉及到缓冲区分散操作 ;

③ 聚合 Gathering : fcOut.write(buffers); , 这里将两个缓冲区的数据写出到了文件中 , 将分散的数据输入到一个文件中 , 涉及到缓冲区聚合操作 ;

④ 注意缓冲区翻转操作 : 先读取数据 , 之后必须调用 flip() 方法翻转缓冲区 , 然后再写出数据 , 否则会出错 ;

3 . 示例代码 :

package kim.hsl.nio;import java.io.FileOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;/*** 分散 ( Scattering ) 与 聚合 ( Gathering ) 示例** 分散 ( Scattering ) : 通道 ( Channel ) 向 缓冲区数组 中写出数据,*                       按照索引从第 0 个缓冲区 ( Buffer ) 开始, 依次写入数据* 聚合 ( Gathering ) : 通道 ( Channel ) 从 缓冲区数组 中读取数据,*                      按照索引从第 0 个缓冲区 ( Buffer ) 开始, 依次读取数据** 使用 服务器套接字通道 ( ServerSocketChannel ) 和 套接字通道 ( SocketChannel ) 进行聚合演示* 使用 文件通道 ( FileChannel ) 进行分散演示** @author han**/
public class BufferDemo4 {public static void main(String[] args) {try {//1 . 创建 ServerSocketChannel, 绑定本地端口ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();InetSocketAddress inetSocketAddress = new InetSocketAddress(8888);serverSocketChannel.socket().bind(inetSocketAddress);//2 . 创建 2 个 ByteBuffer, 并放入数组中ByteBuffer[] buffers = new ByteBuffer[2];buffers[0] = ByteBuffer.allocate(4);buffers[1] = ByteBuffer.allocate(8);//3 . ServerSocketChannel 阻塞等待客户端连接, 该方法执行后一直阻塞SocketChannel socketChannel = serverSocketChannel.accept();//4 . 阻塞读取数据, 将数据读取到 buffers 缓冲区数组中的缓冲区中socketChannel.read(buffers);//5 . 将两个 缓冲区 flip 翻转一下, position 设置为 0buffers[0].flip();buffers[1].flip();//6 . 将读取到的数据写出到文件中FileOutputStream fos = null;try {//1 . FileChannel 可以从 FileOutputStream 中获取fos = new FileOutputStream("file4.txt");//2 . 创建 FileChannel , 从 FileInputStream / FileOutputStream 中可以获取到//FileChannel 是抽象类 , 实际类型是 FileChannelImplFileChannel fcOut = fos.getChannel();//3 .  将读取到的数据写出到文件中fcOut.write(buffers);} catch (IOException e) {e.printStackTrace();} finally {try {if(fos != null)fos.close();} catch (IOException e) {e.printStackTrace();}}} catch (IOException e) {e.printStackTrace();}}
}

4 . 执行服务器端与客户端程序 : 一定要按照顺序执行 , 先启动服务器端 , 再启动客户端 ;

① 启动服务器端 : 先运行服务器端 ;

② 启动客户端 : 再运行客户端 ;

客户端开始连接 ...
客户端连接成功
客户端写出 Hello World 成功

③ 查看服务器端文件写出结果 :