第七节 netty前传-NIO 几种channel介绍01

FileChannel

前面已经简单介绍过 FileChannel,文件通道时阻塞的

  1. 使用:
    在使用FileChannel前,须先将其打开。 通过InputStream,OutputStream或RandomAccessFile获取FileChannel。 以下是通过RandomAccessFile打开FileChannel的方法:
RandomAccessFile randomAccessFile =
                    new RandomAccessFile("F:\\data\\test.txt","rw")){
            //获取连接通道
            FileChannel fileChannel = randomAccessFile.getChannel();
  • 注意: 文件通道无法直接打开
  1. 从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();

  1. 在文件指定位置读写

调用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连接其他服务。
  1. 创建方式

其一 是在客户端直接打开
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
其二 是服务端接受到客户端的连接后,获取客户端的socket。(下一节会详细介绍)
SocketChannel socketChannel = serverSocketChannel.accept();

  1. 客户端主动关闭连接

socketChannel.close();

  1. 从通道中读取数据(前面介绍过,通道的读写都需要buffer的参与)

ByteBuffer buf = ByteBuffer.allocate(48);
int bytesRead = socketChannel.read(buf);

  1. 将数据写入通道中,参考前面FileChannel.write()代码
  • 与fileChannel不同的是socketchannel支持非阻塞模式
  1. 设置非阻塞模式,在连接时设置

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只监听准备好阅读、写入等的通道交给其他线程处理

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,776评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,527评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,361评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,430评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,511评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,544评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,561评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,315评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,763评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,070评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,235评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,911评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,554评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,173评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,424评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,106评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,103评论 2 352

推荐阅读更多精彩内容

  • Java NIO(New IO)是从Java 1.4版本开始引入的一个新的IO API,可以替代标准的Java I...
    JackChen1024阅读 7,554评论 1 143
  • (转载说明:本文非原创,转载自http://ifeve.com/java-nio-all/) Java NIO: ...
    柳岸阅读 817评论 0 3
  • (转载说明:本文非原创,转载自http://ifeve.com/java-nio-all/) Java NIO: ...
    数独题阅读 802评论 0 3
  • 简介 Java NIO 是由 Java 1.4 引进的异步 IO.Java NIO 由以下几个核心部分组成: Ch...
    永顺阅读 1,791评论 0 15
  • NIO 并发编程网 - ifeve.comJava NIO系列教程 笔记 http://ifeve.com...
    梓青阅读 591评论 0 0