第五课管道

2021-02-27 11:57:23 阅读：170 来源： 互联网

标签：pipe sinkChannel 第五课 Pipe 管道 sink 缓冲区 buf

Java NIO 管道（Pipe）是两个线程之间的单向数据连接。Pipe有一个 source 通道和一个 sink 通道。数据会被写到 sink 通道，从 source 通道读取。

Pipe管道

package NIO;

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

public class TestPipe {
	public static void main(String[] args) {
		Sink();
	}

	public static void Sink() {
		Pipe pipe = null;
		Pipe.SinkChannel sinkChannel = null;
		try {
			// 获取管道
			pipe = Pipe.open();
			// 获取Pipe内部类 SinkChannel
			sinkChannel = pipe.sink();
			// 创建缓冲区
			ByteBuffer buf = ByteBuffer.allocate(1024);
			// 将数据写入缓冲区
			buf.put("sink--发送".getBytes());
			// 转换缓冲区为读模式
			buf.flip();
			// 将缓冲区写入通道
			sinkChannel.write(buf);
			buf.clear();
			Pipe.SourceChannel sourceChannel = pipe.source();
			sourceChannel.read(buf);
			buf.flip();
			System.out.println(new String(buf.array(), 0, buf.limit()));
			buf.clear();
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (sinkChannel != null) {
				try {
					sinkChannel.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}
}

标签：pipe,sinkChannel,第五课,Pipe,管道,sink,缓冲区,buf
来源： https://blog.csdn.net/weixin_44782182/article/details/114167597

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

第五课 管道

第五课管道