Java NIO socket通信

Java NIO 是Java1.4版本推出的新的IO接口,全称Java Non-BlockingIO,也有人称之为Java New IO。从其名称可以看出它是有别与Java 标准IO的,Non-blocking(非阻塞)道明了其主要特征。

Java标准io中,我们在使用的时候的流程是这样的,先创建一个InputStream,将数据写入InputStream,将InputStream中的数据读入一个字节数组中,然后创建一个OutputSteam,从字节数组中读取数据到OutputStream中,然后调用write方法写到目标,它是基于字节的,所有的io都被视为单个字节的移动。然而Nio却却别于这一过程,在NIO中,增加了channel,buffer,selector的概念,NIO的使用流程变成了这样,先创建一个channel,将channel中的数据读入buffer中,写数据时将buffer中的数据写入channel中即可。它是基于块的,这个块可以理解成就是那个buffer,buffer从channel中获取数据并运输,我们获取数据直接从buffer中获取。

下面来看看代码怎么实现。将一个字符串写入一个文件中。

//先在src路径下创建一个文件,获取outputStream

FileOutputStream fileOutStream =newFileOutputStream("src/JavaNio.txt");

//通过outputStream获取channel

FileChannel fileChannel = fileOutputStream.getChannel();

//创建一个buffer,并将要写到文件中的数据放入buffer中

ByteBuffer bb = ByteBuffer.allocate(1024);

String s ="Hello World!";

bb.put(s.getBytes());

//反转buffer,使其可读,很重要,个人觉得这个操作很恶心

bb.flip();

//然后写入通道

fileChannel.write(bb);

此时数据已经写入到文件中去了


从文件中读取字符串。

//获取channel

FileInputStream fileInputStream =newFileInputStream("src/JavaNio.txt");

FileChannel fileChannel = fileInputStream.getChannel();

//创建buffer并将channel中的数据写入buffer中

ByteBuffer bb = ByteBuffer.allocate(1024);

fileChannel.read(bb);

//反转buffer,并从buffer中获取一个字节数组

bb.flip();

//注意这里,这个字节数组的长度不要大于buffer中的数据长度,buffer读模式中limit代表这个buffer中有多少数据可以读。如果大了会抛出一个BufferUnderflowException。

byte[] b =new byte[bb.limit()];

String s = new String[b]

NIO socket使用。和标准io一样,nio的socket也分为ServerSocketChannel和SocketChannel。在标准io的socket通信中,server端每获取一个client端连接的时候会新开一条线程,在这个线程中来处理消息。NIO中你不必这样,NIO有一个Selector的概念,每个channel(不论是server端还是client端)注册到selector中后,selector会轮询这些channel,如果有数据,则进行数据处理,不需要我们手动去新开线程。

看看代码怎么做吧。

server.java  main()

//开启selector

Selector selector = Selector.open();

//创建serversocketchannel

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

serverSocketChannel.socket().bind(newInetSocketAddress(8765));

//设置非阻塞,并将serversocketchannel注册到selector中,这里的SelectionKey.OP_ACCEPT表示这个channel已经准备好接受连接了

serverSocketChannel.configureBlocking(false);

serverSocketChannel.register(selector,SelectionKey.OP_ACCEPT);

//然后遍历selector中的所有的channel

while(selector.select()>0){

for(SelectionKey key : selector.selectedKeys()){

//获取当前的key,这个key对应着一个channel,serverchannel和clientchannel都在其中,获取到之后就可以将其移除了。

selector.selectedKeys().remove(key);

//如果key是Acceptable,还记得serverchannel注册到seletor中时设置的key不。

if(key.isAcceptable()){

//通过serverChannel获取连接上的具体的clientChannel,就跟标准io中serversocket.accept()一样返回的是客户端的socket

SocketChannel sc = serverSocketChannel.accept();

//获取到客户端的channel后设置非阻塞并注册到selector中。

sc.configureBlocking(false);

sc.register(selector,SelectionKey.OP_READ);

}

//isReadable表示一个clientChannel已经准备好数据了,在这里进行数据处理

if(key.isReadable()){

SocketChannel sc = (SocketChannel) key.channel();

ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

// String content = "";

while(sc.read(byteBuffer)>0){

byteBuffer.flip();

System.out.println(newString(byteBuffer.array(),"utf-8"));}

key.interestOps(SelectionKey.OP_READ);}}}

client.java main()

SocketChannel sc = SocketChannel.open();

sc.connect(newInetSocketAddress("127.0.0.1",8765));

while(true) {

byte[] bytes =new byte[1024];

System.in.read(bytes);

ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

byteBuffer.put(bytes);

byteBuffer.flip();

//将buffer中的数据写入到channel中

sc.write(byteBuffer);

byteBuffer.clear();

好了JavaNIO的使用我就写这么多了,更多更详细的内容自行百度。对文中有不对的地方欢迎提出指正。

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

推荐阅读更多精彩内容