FileChannel
前面已经简单介绍过 FileChannel,文件通道时阻塞的
- 使用:
在使用FileChannel前,须先将其打开。 通过InputStream,OutputStream或RandomAccessFile获取FileChannel。 以下是通过RandomAccessFile打开FileChannel的方法:
RandomAccessFile randomAccessFile =
new RandomAccessFile("F:\\data\\test.txt","rw")){
//获取连接通道
FileChannel fileChannel = randomAccessFile.getChannel();
- 注意: 文件通道无法直接打开
- 从FileChannel读取数据,将数据写入FileChannel(前面我们了解到通道的操作,是需要buffer参与的)
ByteBuffer buf = ByteBuffer.allocate(48);
//此方法将数据从FileChannel读入缓冲区。 read()方法返回的int告诉缓冲区中有多少字节。 如果返回-1,则到达文件结尾。
int bytesRead = inChannel.read(buf);
FileChannel.write()方法将数据写入FileChannel,该方法将Buffer作为参数。
String newData = "test data..." + System.currentTimeMillis();
ByteBuffer buf = ByteBuffer.allocate(48);
//数据写入缓冲
buf.put(newData.getBytes());
//切换为读模式
buf.flip();
//直到没有数据可读
while(buf.hasRemaining()) {
channel.write(buf);
}
- 注意操对文件的读写操作完成都需要关闭通道减少资源损耗
channel.close();
- 在文件指定位置读写
调用position()方法能够获取FileChannel对象的当前位置。
也可以通过调用position(long pos)方法来设置FileChannel的位置。
long pos channel.position();
channel.position(pos +32);
需要注意的是,如果设置的位置在文件的结尾,读取的时候会返回-1,-1表示文件结束标记。如果在文件结束后设置位置并写入数据到通道,则文件会以适合位置和写入数据。 这可能导致“文件漏洞”,磁盘上的物理文件在写入数据中存在间隙。
其他几种文件通道的方法
1、获取文件大小
long fileSize = channel.size();
2、 从通道中将文件截断
channel.truncate(1024);
3、 将未写入磁盘的文件刷新到硬盘上
一般操作系统为了提高效率,io都会有一定的缓冲区,来减少io操作。所以我们不能确保我们写道通道的数据就写入到了磁盘上。下面方法会强制刷到磁盘上
channel.force(true);
SocketChannel
- SocketChannel是用来通过tcp连接其他服务。
- 创建方式
其一 是在客户端直接打开
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
其二 是服务端接受到客户端的连接后,获取客户端的socket。(下一节会详细介绍)
SocketChannel socketChannel = serverSocketChannel.accept();
- 客户端主动关闭连接
socketChannel.close();
- 从通道中读取数据(前面介绍过,通道的读写都需要buffer的参与)
ByteBuffer buf = ByteBuffer.allocate(48);
int bytesRead = socketChannel.read(buf);
- 将数据写入通道中,参考前面FileChannel.write()代码
- 与fileChannel不同的是socketchannel支持非阻塞模式
- 设置非阻塞模式,在连接时设置
socketChannel.configureBlocking(false);
注意:在阻塞模式下connect() write() read()这些方法会立刻返回,即使可能在连接建立之前、未写入数据之前、未读取数据前,所以我们使用时需要注意这点
socketChannel.configureBlocking(false);
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
//socketChannel.finishConnect()方法来判断是否已经成功建立连接
while(! socketChannel.finishConnect() ){
//wait, or do something else...
}
使用非阻塞模式和selector一起使用是最合适的,通过向Selector注册一个或多个SocketChannel,Selector只监听准备好阅读、写入等的通道交给其他线程处理