本文原创,转载需标明原处。
通道,主要负责传输数据,相当于流,但流只能是输入或输出类型中的其一,而通道则可以兼并二者。
通道的基类是:Channel
- boolean isOpen()
- void close()
通道有同步方式和异步方式。
- 同步方式:亲力亲为,不交给他人来做。
- 异步方式:需要等待的事情,交给他人来做。做完之后,可以自己接着做,也可以由他人继续接着做。
通道有阻塞方式与非阻塞方式。
- 阻塞方式:在做这件事时,可能需要等待,也可能不需要等待。
- 非阻塞方式:在做这件事之前,确保不需要等待。换句话说,确保不需要等待的时候,我才来做。例如,银行人多的时候,我就直接离开,没人的时候,我就进入。
同步方式的输入输出通道
上图表示出,同步方式的输入输出通道的数据流通。这些通道的基类主要是ReadableByteChannel,WritableByteChannel。
- ReadableByteChannel和WritableByteChannel,操作一个ByteBuffer进行读写字节数据。
- ScatteringByteChannel和GatheringByteChannel分别是ReadableByteChannel,WritableByteChannel强化版,不仅可以操作一个ByteBuffer,还可以操作一组ByteBuffer。
- FileChannel提供了更为快捷的操作,直接操作ReadableByteChannel和WritableByteChannel进行读写。
- ByteChannel仅仅只是ReadableByteChannel和WritableByteChannel的组合,因此自然也是那些同时继承了ReadableByteChannel和WritableByteChannel的Channel的基类。
- SeekableByteChannel(FileChannel是该类的唯一实现类),其表示不仅可以输入输出,还可以定位操作点,获取容量(文件大小)和缩减容量(文件大小)。
异步方式的输入输出通道
上图表示出,异步方式的输入输出通道的数据流通。
异步方式的具体通道类有两个,分别是AsynchronousSocketChannel和AsynchronousFileChannel。
输入输出通道
整合所有输入输出的通道,可以有五种源头类型的通道:文件,网络,管道,输入流,输出流。
可使用非阻塞方式的通道(以下简称可非阻塞通道)
这类通道的基类是SelectableChannel,默认是阻塞,通过方法configBlocking(boolean)设置是否阻塞,方法isBlocking()查看是否阻塞。
上图表示出具体的可非阻塞通道类,以及表示出非阻塞方式所使用到的各组件之间的关系图。
具体怎么使用,可以参考其它相关的文章,最重要还是记得一点,非阻塞的概念就是确保这件事情不需要等待的时候才去做。怎么确保,selector的select()系列方法,这些方法会阻塞,阻塞到它检测到那些事情不需要等待了,就会让我去做。
需要注意的是,在使用非阻塞方式的方法时,必须先使用configBlocking(false),设置为非阻塞。
异步方式的通道
异步的概念,就是把需要等待的事情,委托给他人来做,做完的时候,可以选择自己接着做,也可以继续由受委托的人接着做。
那么异步有两种结果,一种是自己接着做,一种是他人接着做。
自己接着做的方式,操作方法的返回值是一个Future对象,使用这个对象可以检测完成进度。
- boolean isDone():测试是否完成。
- boolean isCanceled():测试异步运行是否被中止。
- boolean cannel(boolean):中止异步运行,并返回是否中止成功。
- V get()/get(long, TimeUnit):有些操作需要获取运行的返回值,如读取时,需要知道读取的字节数。但如果异步运行未完成或未中止,就会进入阻塞。
他人接着做的方式,操作参数里需要传入一个CompletionHandler对象,这个对象的方法将由异步线程来调用。
- void completed(V result, A attachment):完成时异步运行的方法。
- void failed(Throwable exc, A attachment):失败时异步运行的方法。
异步方式的通道基类是AsynchronousChannel,但这个类仅仅只是一个身份类,并没有提供任何操作方法。它的子类有:
- AsynchronousFileChannel
- AsynchronousByteChannel:这是一个接口,表示不仅具有异步方式,同时是输入输出字节类型的通道。但唯一的实现类为AsynchronousSocketChannel。
- AsynchronousServerSocketChannel
- AsynchronousSocketChannel
其它通道
- NetworkChannel:网络通道,用于网络的通道。
- InterruptibleChannel:表示线程被中止时,可以中断输入输出的通道。
通道的建立
一般使用静态方法open建立,其它方式的建立,如下图:
待续更新……