Java NIO - Pipe(管道)

Java NIO - Pipe(管道) 首页 / Nio入门教程 / Java NIO - Pipe(管道)

Java中,NIO Pipe(管道) 是用于在两个线程之间写入和读取数据的组件。Pipe(管道) 主要由两个通道组成,负责数据传输,在两个组成通道中,一个称为接收器通道,主要用于写入数据,另一个称为源通道,其主要目的是从接收器通道读取数据。

管道类函数

  • open()     - 此方法用于获取Pipe的实例,或者可以说通过调用此方法来创建管道。

  • sink()      - 此方法返回Pipe的接收器通道,该通道通过调用其write方法来写入数据。

  • source()  - 此方法返回Pipe的源通道,该通道通过调用其read方法来读取数据。

Pipe管道示例

以下示例显示了Java NIO管道的实现。

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;

public class PipeDemo {
   public static void main(String[] args) throws IOException {
      //创建 Pipe 的一个实例
      Pipe pipe=Pipe.open();
      //获取管道的 sink 通道
      Pipe.SinkChannel skChannel=pipe.sink();
      String testData="Test Data to Check java NIO Channels Pipe.";
      ByteBuffer buffer=ByteBuffer.allocate(512);
      buffer.clear();
      buffer.put(testData.getBytes());
      buffer.flip();
      //将数据写入接收器通道。
      while(buffer.hasRemaining()) {
         skChannel.write(buffer);
      }
      //获取管道的源通道
      Pipe.SourceChannel sourceChannel=pipe.source();
      buffer=ByteBuffer.allocate(512);
      //将数据写入控制台
      while(sourceChannel.read(buffer) > 0){
         //限制设置为当前位置,位置设置为零
         buffer.flip();
         while(buffer.hasRemaining()){
            char ch=(char) buffer.get();
            System.out.print(ch);
         }
         //position 设置为零,limit 设置为容量以清除缓冲区。
         buffer.clear();
      }
   }
}

运行上面代码输出

链接:https://www.learnfk.comhttps://www.learnfk.com/java-nio/java-nio-pipe.html

来源:LearnFk无涯教程网

Test Data to Check java NIO Channels Pipe.

祝学习愉快!(内容编辑有误?请选中要编辑内容 -> 右键 -> 修改 -> 提交!)

技术教程推荐

赵成的运维体系管理课 -〔赵成〕

Service Mesh实践指南 -〔周晶〕

代码精进之路 -〔范学雷〕

Flutter核心技术与实战 -〔陈航〕

NLP实战高手课 -〔王然〕

动态规划面试宝典 -〔卢誉声〕

编程高手必学的内存知识 -〔海纳〕

云计算的必修小课 -〔吕蕴偲〕

技术领导力实战笔记 2022 -〔TGO 鲲鹏会〕

好记忆不如烂笔头。留下您的足迹吧 :)