美文网首页程序员
Java NIO socket通信

Java NIO socket通信

作者: 大大大浣熊 | 来源:发表于2017-07-09 23:10 被阅读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的使用我就写这么多了,更多更详细的内容自行百度。对文中有不对的地方欢迎提出指正。

    相关文章

      网友评论

        本文标题:Java NIO socket通信

        本文链接:https://www.haomeiwen.com/subject/jieehxtx.html