- 浏览: 950830 次
文章分类
- 全部博客 (428)
- Hadoop (2)
- HBase (1)
- ELK (1)
- ActiveMQ (13)
- Kafka (5)
- Redis (14)
- Dubbo (1)
- Memcached (5)
- Netty (56)
- Mina (34)
- NIO (51)
- JUC (53)
- Spring (13)
- Mybatis (17)
- MySQL (21)
- JDBC (12)
- C3P0 (5)
- Tomcat (13)
- SLF4J-log4j (9)
- P6Spy (4)
- Quartz (12)
- Zabbix (7)
- JAVA (9)
- Linux (15)
- HTML (9)
- Lucene (0)
- JS (2)
- WebService (1)
- Maven (4)
- Oracle&MSSQL (14)
- iText (11)
- Development Tools (8)
- UTILS (4)
- LIFE (8)
最新评论
-
Donald_Draper:
Donald_Draper 写道刘落落cici 写道能给我发一 ...
DatagramChannelImpl 解析三(多播) -
Donald_Draper:
刘落落cici 写道能给我发一份这个类的源码吗Datagram ...
DatagramChannelImpl 解析三(多播) -
lyfyouyun:
请问楼主,执行消息发送的时候,报错:Transport sch ...
ActiveMQ连接工厂、连接详解 -
ezlhq:
关于 PollArrayWrapper 状态含义猜测:参考 S ...
WindowsSelectorImpl解析一(FdMap,PollArrayWrapper) -
flyfeifei66:
打算使用xmemcache作为memcache的客户端,由于x ...
Memcached分布式客户端(Xmemcached)
Channel接口定义:http://donald-draper.iteye.com/blog/2369111
AbstractInterruptibleChannel接口定义:http://donald-draper.iteye.com/blog/2369238
SelectableChannel接口定义:http://donald-draper.iteye.com/blog/2369317
SelectionKey定义:http://donald-draper.iteye.com/blog/2369499
SelectorProvider定义:http://donald-draper.iteye.com/blog/2369615
AbstractSelectableChannel定义:http://donald-draper.iteye.com/blog/2369742
NetworkChannel接口定义:http://donald-draper.iteye.com/blog/2369773
Selector定义:http://donald-draper.iteye.com/blog/2370015
AbstractSelector定义:http://donald-draper.iteye.com/blog/2370138
SelectorImpl分析 :http://donald-draper.iteye.com/blog/2370519
WindowsSelectorImpl解析一(FdMap,PollArrayWrapper):
http://donald-draper.iteye.com/blog/2370811
WindowsSelectorImpl解析二(选择操作,通道注册,通道反注册,选择器关闭等):
http://donald-draper.iteye.com/blog/2370862
ByteChannel,分散聚集通道接口的定义(SocketChannel):
http://donald-draper.iteye.com/blog/2371065
NIO-Pipe示例:http://donald-draper.iteye.com/blog/2373535
前面一篇文章我们看了一个管道实例,今天来看一下管道的定义
总结:
Pipe中包含一个可写通道SinkChannel和一个可读通道SourceChannel。sink向管道写字节序序列,source从管道读取字节序列。
PipeImpl解析:http://donald-draper.iteye.com/blog/2373628
AbstractInterruptibleChannel接口定义:http://donald-draper.iteye.com/blog/2369238
SelectableChannel接口定义:http://donald-draper.iteye.com/blog/2369317
SelectionKey定义:http://donald-draper.iteye.com/blog/2369499
SelectorProvider定义:http://donald-draper.iteye.com/blog/2369615
AbstractSelectableChannel定义:http://donald-draper.iteye.com/blog/2369742
NetworkChannel接口定义:http://donald-draper.iteye.com/blog/2369773
Selector定义:http://donald-draper.iteye.com/blog/2370015
AbstractSelector定义:http://donald-draper.iteye.com/blog/2370138
SelectorImpl分析 :http://donald-draper.iteye.com/blog/2370519
WindowsSelectorImpl解析一(FdMap,PollArrayWrapper):
http://donald-draper.iteye.com/blog/2370811
WindowsSelectorImpl解析二(选择操作,通道注册,通道反注册,选择器关闭等):
http://donald-draper.iteye.com/blog/2370862
ByteChannel,分散聚集通道接口的定义(SocketChannel):
http://donald-draper.iteye.com/blog/2371065
NIO-Pipe示例:http://donald-draper.iteye.com/blog/2373535
前面一篇文章我们看了一个管道实例,今天来看一下管道的定义
package java.nio.channels; import java.io.IOException; import java.nio.channels.spi.*; /** * A pair of channels that implements a unidirectional pipe. *Pipe是一对单向通道的实现 * A pipe consists of a pair of channels: A writable {@link * Pipe.SinkChannel </code>sink<code>} channel and a readable {@link * Pipe.SourceChannel </code>source<code>} channel. Once some bytes are * written to the sink channel they can be read from source channel in exactly * the order in which they were written. *管道Pipe包括一对通道,一个可写的SinkChannel,一个可读的SourceChannel。只要有字节序列 写到sink通道,那么source通道可以按字节写的顺序读取字节序列。 * Whether or not a thread writing bytes to a pipe will block until another * thread reads those bytes, or some previously-written bytes, from the pipe is * system-dependent and therefore unspecified. Many pipe implementations will * buffer up to a certain number of bytes between the sink and source channels, * but such buffering should not be assumed. *一个线程是否可以写字节序列到管道,取决于是否有其他线程从依赖于系统的管道, 读取这些字节序列或先前已写到管道的字节序列,因此是不确定的。许多管道的实现将会 把一定数量的字节序列在sink与source通道之前缓存起来,但这种缓存不应该assumed。 * * @author Mark Reinhold * @author JSR-51 Expert Group * @since 1.4 */ public abstract class Pipe { /** * A channel representing the readable end of a {@link Pipe}. *SourceChannel表示管道的可读端 * @since 1.4 */ public static abstract class SourceChannel extends AbstractSelectableChannel implements ReadableByteChannel, ScatteringByteChannel { /** * Constructs a new instance of this class. */ protected SourceChannel(SelectorProvider provider) { super(provider); } /** * Returns an operation set identifying this channel's supported * operations. *返回通道支持的操作事件 * Pipe-source channels only support reading, so this method * returns {@link SelectionKey#OP_READ}. *由于管道的Source通道只支持读操作,所以此方只返回SelectionKey#OP_READ * @return The valid-operation set */ public final int validOps() { return SelectionKey.OP_READ; } } /** * A channel representing the writable end of a {@link Pipe}. </p> * SinkChannel表示管道的可写端 * @since 1.4 */ public static abstract class SinkChannel extends AbstractSelectableChannel implements WritableByteChannel, GatheringByteChannel { /** * Initializes a new instance of this class. */ protected SinkChannel(SelectorProvider provider) { super(provider); } /** * Returns an operation set identifying this channel's supported * operations. *返回通道支持的操作事件 * Pipe-sink channels only support writing, so this method returns * {@link SelectionKey#OP_WRITE}. *由于管道的Sink通道只支持写操作,所以此方只返回SelectionKey#OP_WRITE * @return The valid-operation set */ public final int validOps() { return SelectionKey.OP_WRITE; } } /** * Initializes a new instance of this class. */ protected Pipe() { } /** * Returns this pipe's source channel. </p> *获取管道的source通道 * @return This pipe's source channel */ public abstract SourceChannel source(); /** * Returns this pipe's sink channel. </p> *获取管道的sink通道 * @return This pipe's sink channel */ public abstract SinkChannel sink(); /** * Opens a pipe. *打开一个管道 * The new pipe is created by invoking the {@link * java.nio.channels.spi.SelectorProvider#openPipe openPipe} method of the * system-wide default {@link java.nio.channels.spi.SelectorProvider} * object. * * @return A new pipe * * @throws IOException * If an I/O error occurs */ public static Pipe open() throws IOException { return SelectorProvider.provider().openPipe(); } }
总结:
Pipe中包含一个可写通道SinkChannel和一个可读通道SourceChannel。sink向管道写字节序序列,source从管道读取字节序列。
PipeImpl解析:http://donald-draper.iteye.com/blog/2373628
发表评论
-
文件通道解析二(文件锁,关闭通道)
2017-05-16 23:17 994文件通道解析一(读写操作,通道数据传输等):http://do ... -
文件通道解析一(读写操作,通道数据传输等)
2017-05-16 10:04 1102Reference定义(PhantomRefere ... -
文件通道创建方式综述
2017-05-15 17:39 932Reference定义(PhantomReference,Cl ... -
文件读写方式简单综述后续(文件,流构造)
2017-05-14 23:04 1399Java Socket通信实例:http://donald-d ... -
文件读写方式简单综述
2017-05-14 11:13 1069Java Socket通信实例:http://donald-d ... -
FileChanne定义
2017-05-12 23:28 869文件读写方式简单综述:http://donald-draper ... -
SeekableByteChannel接口定义
2017-05-11 08:43 1122ByteChannel,分散聚集通道接口的定义(SocketC ... -
FileChannel示例
2017-05-11 08:37 906前面我们看过socket通道,datagram通道,以管道Pi ... -
PipeImpl解析
2017-05-11 08:41 838ServerSocketChannel定义:http://do ... -
NIO-Pipe示例
2017-05-10 08:47 846PipeImpl解析:http://donald-draper ... -
DatagramChannelImpl 解析四(地址绑定,关闭通道等)
2017-05-10 08:27 690DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析三(多播)
2017-05-10 08:20 1687DatagramChannelImpl 解析一(初始化):ht ... -
NIO-UDP实例
2017-05-09 12:32 1517DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析二(报文发送与接收)
2017-05-09 09:03 1341DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析一(初始化)
2017-05-08 21:52 1329Channel接口定义:http://donald-drape ... -
MembershipKeyImpl 简介
2017-05-08 09:11 871MembershipKey定义:http://donald-d ... -
DatagramChannel定义
2017-05-07 23:13 1182Channel接口定义:http://donald-drape ... -
MulticastChanne接口定义
2017-05-07 13:45 1067NetworkChannel接口定义:ht ... -
MembershipKey定义
2017-05-06 16:20 830package java.nio.channels; i ... -
SocketChannelImpl 解析四(关闭通道等)
2017-05-05 08:38 2412SocketChannelImpl 解析一(通道连接,发送数据 ...
相关推荐
成果导向的创新创业基础3333教学大纲和PIPE教学方案定义.pdf
其中PCIe物理层接口(Physical Interface for PCI Express,PIPE)定义了物理层中的,媒介层(Media Access Layer,MAC)和物理编码子层(Physical Coding Sub-layer,PCS)之间的统一接口,旨在为提供一种统一的...
Pipe的定义如下代码所示: import { PipeTransform, Pipe } from '@angular/core'; /*users: Array<any> = [ { name: '1', id: 1 }, { name: '2', id: 2 }, { name: '3', id: 3 }, { name: '4', i
例子 const pipe = require ( '@jongleberry/pipe' )const render = function ( { currentUser} ) { return pipe ` <!DOCTYPE html> <html> <head> <title>Example</title> <link ...
管道单反 ...除其他事项外,pipe-DSL自动确保一个数据管道中使用的所有PipelineObject仅一次被包含在管道定义中,无论它们被引用的频率如何。 使用Scala命令行以交互方式组装管道定义并将其上载到AWS。
用例安全密码传递从剪贴板发送: pbpaste | warp_to coworker_a 接收到剪贴板warp_from coworker_b | pbcopy 对文件执行操作您无需定义,等待,手动抓取并执行操作,而可以定义要执行的操作,等待并自动执行。...
1 管道通信 利用pipe 和lockf 系统调用 编写程序 实现同族进程间的通信 使用系统调用pipe 建立一条管道线;创建子进程P1 P2 … 子进程Pi分别向管道各写信息 而父进程则从管道中读出来自于各子进程的信息 实现进程...
通过仅提供到rvl-pipe异步样式功能的一组路径映射来抽象一些构建快速服务器的怪癖。 您可以添加一个初始化程序(主要用于连接到诸如DB或MQ的资源)和中间件,以在单个路径上支持它们的大多数使用情况。 还包括几个...
管道(pipe)是windows中定义的一个非常重要的通讯媒介逻辑概念,在window中管道以内核对象的形式存在。 windows每个内核对象都可以用一个HANDLE 来进行索引,本实例利用管道实现Console输出重定向的功能,简单易学,...
你可以编辑所有忧缺陷的项目、在数据库源里搜索文本、输出和输入表、生成测试数据、输入文本或ODBC数据、比较表数据、模拟dbms_alert 和dbms_pipe等等。 插件扩展名 PL/SQL Developer功能可以通过插件程序扩展。在...
require-sugar是JavaScript和CoffeeScript的简单预处理器,它提供了用于定义RequireJS依赖项的自定义语法。 转换示例 原始资料: ### define jquery : $ underscore : _ ### code() 输出来源: define(["jquery",...
这个助手允许你在 browserify 中轻松定义路径别名。 使用示例 npm i browserify-modules --save-dev var browserify = require('gulp-browserify'); var define_modules = require('browserify-modules'); var ...
当前支持的经纪人:上面的每个模块都定义了一个服务,该服务包含各种用于从各个API提取数据的方法,通常用于特定的ZTF名称。安装在全新的virtualenv中, pip install -r requirements.txt用法在脚本中,从导入...
gulp-gitignore 从流中排除在.gitignore上定义的文件安装$ npm install --save-dev gulp-gitignore用法var gulp = require ( 'gulp' ) ;var gitignore = require ( 'gulp-gitignore' ) ;gulp . task ( 'default' , ...
将文件中匹配的字符串替换为定义的值 安装 $ npm install --save-dev gulp-substituter 吞咽用法 gulpfile.js var substituter = require ( 'gulp-substituter' ) ; gulp . task ( 'replace' , function ( ) { ...
Gulp模块,用于从协议缓冲区模型生成TypeScript定义 安装 // TODO: npm install gulp-proto2ts -save-dev npm install https://github.com/ilyes-garifullin/gulp-proto2ts.git -save-dev 用法 var gulp = require...
1.1.1 定义索引表 1.1.2 将条目插入到索引表中 1.1.3 对索引表中进行操作 1.1.4 索引表中的函数 1.2 嵌套表 1.2.1 初始化嵌套表 1.2.2 扩展嵌套表 1.2.3 删除嵌套表中的条目 1.3 变长数组 1.3.1 定义变长数组 ...
Gulp插件,可使用路径变量轻松定义目标路径。 用安装 $ npm i gulp-dest --save 例子 var dest = require ( 'gulp-dest' ) ; var gulp = require ( 'gulp' ) ; gulp . task ( 'default' , function ( ) { gulp . ...
您还可以使用ng generate directive|pipe|service|class|guard|interface|enum|module 。 建造 运行ng build来构建项目。 构建工件将存储在dist/目录中。 使用--prod标志进行生产构建。 运行单元测试 运行ng test以...