java的NIO管道用法代码分享
更新时间：2017年12月06日 09:25:14 作者：IT老蒋
这篇文章主要介绍了java的NIO管道用法代码分享，具有一定借鉴价值，需要的朋友可以参考下。
Java的NIO中的管道，就类似于实际中的管道，有两端，一段作为输入，一段作为输出。也就是说，在创建了一个管道后，既可以对管道进行写，也可以对管道进行读，不过这两种操作要分别在两端进行。有点类似于队列的方式。
这里是Pipe原理的图示：
创建管道
通过Pipe.open()方法打开管道。例如：
Pipe pipe = Pipe.open();
向管道写数据
要向管道写数据，需要访问sink通道。像这样：
Pipe.SinkChannel sinkChannel = pipe.sink();
通过调用SinkChannel的write()方法，将数据写入SinkChannel,像这样：
String newData = "New String to write to file..." + System.currentTimeMillis();
ByteBuffer buf = ByteBuffer.allocate(48);
buf.clear();
buf.put(newData.getBytes());
buf.flip();
while(buf.hasRemaining()) {
sinkChannel.write(buf);
}
我们在测试例子中给出一个非常简单的管道操作，先向管道写入内容，再从管道读出内容。
package com.test.nio;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;
public class TestPipeA {
/**
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {
//创建一个管道
Pipe pipe=Pipe.open();
//创建一个写管道
Pipe.SinkChannel sinkChannel=pipe.sink();
String newData="itbuluoge.com says:"+System.currentTimeMillis();
ByteBuffer buf=ByteBuffer.allocate(48);
buf.clear();
buf.put(newData.getBytes());
buf.flip();
/*向管道写入内容*/
while(buf.hasRemaining())
{
sinkChannel.write(buf);
}
/*创建一个读管道*/
Pipe.SourceChannel sourceChannel=pipe.source();
ByteBuffer getBuf=ByteBuffer.allocate(48);
int bytesRead=sourceChannel.read(getBuf);
getBuf.flip();
/*从管道读出内容*/
while(getBuf.hasRemaining())
{
System.out.print((char)getBuf.get());
}
}
}
输出结果
我们可以看到，已经可以完成我们需要的目标了。注意，我在这个地方编程的时候，出现了一点错误，就是我在读取管道的时候，没有设置getBuf.flip()，导致无法读出数据，这个函数非常重要，在完成buffer读取内容之后，一定要设置一下读标志，恢复指针到原始位置，才能读取到全部内容。
以上就是本文关于java的NIO管道用法代码分享的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！
相关文章
RediSearch是一款构建在Redis上的搜索引擎,它为Redis数据库提供了全文搜索、排序、过滤和聚合等高级查询功能,本文将介绍如何在Java应用中集成并使用RediSearch,以实现高效的数据检索功能,感兴趣的朋友跟着小编一起来看看吧2024-05-05
MDC 在 Spring Boot 中的作用是为日志事件提供上下文信息，并将其与特定的请求、线程或操作关联起来，通过使用 MDC，可以更好地理解和分析日志，并在多线程环境中确保日志的准确性和一致性，这篇文章主要介绍了SpringBoot MDC全局链路解决方案,需要的朋友可以参考下2023-08-08
这篇文章主要介绍了Java实现ZooKeeper的zNode监控问题，本文给大家介绍的非常详细，具有一定的参考借鉴价值 ,需要的朋友可以参考下2019-08-08
这篇文章主要介绍了Java struts2请求源码分析案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-08-08
IntelliJ IDEA 2022.1.1 沒有CVS的过程分析
这篇文章主要介绍了IntelliJ IDEA 2022.1.1 沒有CVS的过程解析,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-07-07
这篇文章主要介绍了Spring Boot中单例类实现对象的注入方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
idea2020.1最新版永久破解/pycharm也可用(步骤详解)
这篇文章主要介绍了idea2020.1最新版永久破解/pycharm也可用,本文给大家分享简单实现步骤，通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-04-04
springboot整合swagger3报Unable to infer base&nbs
这篇文章主要介绍了springboot整合swagger3报Unable to infer base url错误问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-05-05
SpringBoot和Springfox(Swagger)版本不兼容的解决方案
documentationPluginsBootstrapper这个 bean 无法正常启动,原因是遇到了空指针异常（NullPointerException）,这通常是由于 Spring Boot 和 Springfox 的版本不兼容导致的路径匹配策略冲突,本文给大家介绍了SpringBoot和Springfox(Swagger)版本不兼容的解决方案2024-12-12
这篇文章主要介绍了简单了解Spring中的事务控制，事务是一组操作的执行单元，下面我们来简单学习一下吧2019-05-05
最新评论