程序员

Java NIO socket通信

2017-07-09  本文已影响0人  大大大浣熊

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的使用我就写这么多了,更多更详细的内容自行百度。对文中有不对的地方欢迎提出指正。

上一篇下一篇

猜你喜欢

热点阅读