面試刷題11:java系統中io的分類有哪些？

時間  2020-03-26
標籤 面試 java 系統 分類 哪些 欄目 快樂工作 简体版
原文   原文鏈接

image.png




隨着分佈式技術的普及和海量數據的增加，io的能力愈來愈重要，java提供的io模塊提供了足夠的擴展性來適應。


我是李福春，我在準備面試，今天的問題是：


java中的io有哪幾種？


java中的io分3類：


1，BIO ,即同步阻塞IO,對應java.io包提供的工具；基於流模型，雖然直觀，代碼實現也簡單，可是擴展性差，消耗資源大，容易成爲系統的瓶頸；




2，NIO，同步非阻塞io,對應java.nio包提供的工具，基於io多路複用；
核心類： Channel ,Selector , Buffer , Charset  
selector是io多路複用的基礎，實現了一個線程高效管理多個客戶端鏈接，經過事件監聽處理感興趣的事件。


3，AIO,即異步非阻塞io, 基於事件和回調java

io的類層級






image.png




java各類IO的例子

java.io客戶端鏈接服務端例子

package org.example.mianshi.io;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 說明：傳統流式io 客戶端鏈接服務端例子
 * @author carter
 * 建立時間： 2020年03月25日 9:58 下午
 **/

public class JavaIOApp {

    public static void main(String[] args) {

        final Server server = new Server();
        new Thread(server).start();

        try (
                Socket socket = new Socket(InetAddress.getLocalHost(), server.getPort());
        ) {
            final BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            bufferedReader.lines().forEach(System.out::println);

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static class Server implements Runnable {

        private ServerSocket serverSocket;

        public int getPort() {
            return serverSocket.getLocalPort();
        }

        @Override
        public void run() {

            try (ServerSocket serverSocket = new ServerSocket(0);) {

                this.serverSocket = serverSocket;
                while (true) {
                    final Socket socket = serverSocket.accept();
                    new RequestHandler(socket).start();
                }

            } catch (IOException e) {
                e.printStackTrace();
            }

        }

        private class RequestHandler extends Thread {
            private Socket socket;

            public RequestHandler(Socket socket) {
                this.socket = socket;
            }

            @Override
            public void run() {
                try (
                        final PrintWriter printWriter = new PrintWriter(socket.getOutputStream());
                ) {

                    printWriter.write("hello world");
                    printWriter.flush();

                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}




使用鏈接池優化


image.png




package org.example.mianshi.io;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 說明：傳統流式io 客戶端鏈接服務端例子
 * @author carter
 * 建立時間： 2020年03月25日 9:58 下午
 **/

public class ThreadPoolJavaIOApp {

    public static void main(String[] args) {

        final Server server = new Server();
        new Thread(server).start();

        try (
                Socket socket = new Socket(InetAddress.getLocalHost(), server.getPort());
        ) {
            final BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            bufferedReader.lines().forEach(System.out::println);

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static class Server implements Runnable {

        private ExecutorService threadPool = Executors.newFixedThreadPool(4);

        private ServerSocket serverSocket;

        public int getPort() {
            return serverSocket.getLocalPort();
        }

        @Override
        public void run() {

            try (ServerSocket serverSocket = new ServerSocket(0);) {

                this.serverSocket = serverSocket;
                while (true) {
                    final Socket socket = serverSocket.accept();

                    threadPool.submit(new RequestHandler(socket));
                }

            } catch (IOException e) {
                e.printStackTrace();
            }finally {
                threadPool.shutdown();
            }

        }

        private class RequestHandler implements Runnable {
            private Socket socket;

            public RequestHandler(Socket socket) {
                this.socket = socket;
            }

            @Override
            public void run() {
                try (
                        final PrintWriter printWriter = new PrintWriter(socket.getOutputStream());
                ) {

                    printWriter.write("hello world");
                    printWriter.flush();

                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}


java.nio例子

package org.example.mianshi.io;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;

/**
 * 說明：nio的客戶端鏈接服務端例子
 * @author carter
 * 建立時間： 2020年03月25日 10:32 下午
 **/

public class JavaNioApp {

    public static void main(String[] args) {

        new Server().start();

        try (
                Socket socket = new Socket(InetAddress.getLocalHost(), 8888);
        ) {
            final BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            bufferedReader.lines().forEach(System.out::println);

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static class Server extends Thread {

        @Override
        public void run() {

            try {
                ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

                serverSocketChannel.bind(new InetSocketAddress(InetAddress.getLocalHost(), 8888));

                serverSocketChannel.configureBlocking(false);

                final Selector selector = Selector.open();

                serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

                while (true) {

                    selector.select();
                    selector.selectedKeys().forEach(selectionKey -> {
                        sayHelloWorld((ServerSocketChannel) selectionKey.channel());
                    });

                }

            } catch (IOException e) {
                e.printStackTrace();
            }

        }

        private void sayHelloWorld(ServerSocketChannel channel) {

            try (SocketChannel socketChannel = channel.accept()) {

                socketChannel.write(Charset.defaultCharset().encode("hello world nio"));

            } catch (IOException e) {
                e.printStackTrace();
            }

        }
    }

}




image.png


java.nio2例子

package org.example.mianshi.io;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.channels.AsynchronousServerSocketChannel;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
import java.nio.charset.Charset;

/**
 * 說明：TODO
 * @author carter
 * 建立時間： 2020年03月25日 10:54 下午
 **/

public class JavaNio2App {

    public static void main(String[] args) {

        new Server().start();

        try (
                Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
        ) {
            final BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            bufferedReader.lines().forEach(System.out::println);

        } catch (IOException e) {
            e.printStackTrace();
        }


    }

    public static class Server extends Thread {


        @Override
        public void run() {

            try {
                AsynchronousServerSocketChannel serverSocketChannel = AsynchronousServerSocketChannel.open()
                        .bind(new InetSocketAddress(InetAddress.getLocalHost(), 9999));

                serverSocketChannel.accept(serverSocketChannel, new CompletionHandler<AsynchronousSocketChannel, AsynchronousServerSocketChannel>() {
                    @Override
                    public void completed(AsynchronousSocketChannel socketChannel,
                                          AsynchronousServerSocketChannel serverSocketChannel1) {
//                        serverSocketChannel1.accept(socketChannel, this);

                        socketChannel.write(Charset.defaultCharset().encode("hello world nio2 "));

                        try {
                            socketChannel.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }

                    @Override
                    public void failed(Throwable exc, AsynchronousServerSocketChannel attachment) {
                        exc.printStackTrace();
                    }
                });

            } catch (IOException e) {
                e.printStackTrace();
            }


        }
    }

}




本例子暫時沒法運行。只爲展現過程；






面試

小結


本篇主要介紹了java提供的3中io，即 BIO,NIO,AIO ; 並提供了一些示例代碼輔助理解。




異步

image.png

原創不易，轉載請註明出處，讓咱們互通有無，共同進步，歡迎溝通交流。
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程