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

来源:https://www.cnblogs.com/snidget/archive/2020/03/25/12571465.html

隨著分散式技術的普及和海量數據的增長,io的能力越來越重要,java提供的io模塊提供了足夠的擴展性來適應。 我是李福春,我在準備面試,今天的問題是: java中的io有哪幾種? java中的io分3類: 1,BIO ,即同步阻塞IO,對應java.io包提供的工具;基於流模型,雖然直觀,代碼實現也 ...


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, 基於事件和回調

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](https://img2020.cnblogs.com/other/268922/202003/268922-20200325233150738-94393984.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

原創不易,轉載請註明出處。


您的分享是我們最大的動力!

更多相關文章
  • 圖解Java設計模式之外觀模式 影院管理項目 傳統方式解決影院管理 傳統方式解決影院管理問題分析 外觀模式基本介紹 外觀模式原理類圖 外觀模式解決影院管理 外觀模式的註意事項和細節 影院管理項目 組建一個家庭影院 :DVD 播放器、投影儀、自動屏幕、環繞立體聲、爆米花機,要求完成使用家庭影院的功能, ...
  • 問題引入:電腦里安裝了從官網下載的python3.8.0,。先使用了菜鳥教程的方法2安裝。https://www.runoob.com/numpy/numpy-install.html 發現產生錯誤。先是提示我的pip工具沒有更新到最新版本,於是根據提示更新後,發現仍有錯誤,於是放棄使用這方法里的命 ...
  • 需求 基於Spring, SpringMVC, Mybatis 實現一個類似京東商城的3C電子商城系統, 能夠實現商品管理與展示, 加入購物車, 支付購買等功能 運行環境 jdk1.8,tomcat8.5,mysql5.6,EclispseEE 項目技術 spring springmvc, myba ...
  • 框架:具有很強的通用性,且封裝了一些通用實現方法的項目模板 (非同步框架): 高性能的網路請求 高性能的數據解析 高性能的持久化存儲 高性能的全站數據爬取 高性能的深度爬取 高性能的分散式 Scrapy環境安裝 IOS和Linux windows 安裝完成後,輸入 測試一下,出現如下圖顯示,即安裝成功 ...
  • 一、ItemPipeLine 1.爬蟲提取出的數據存入item之後,item中保存的數據需要進一步處理,比如:清洗,去重,存儲等 2.pipeline需要process_item函數 (1)process_item​:spider提出來的item作為參數出入,同時傳入的還有spider;此方法是必須 ...
  • 目錄 1. "安裝VSCode應用程式" 2. "安裝相關插件" 1. "漢化插件" 2. "C++編輯器插件" 3. "編寫配置文件" 1. "tasks.json" 2. "launch.json" 3. "c_cpp_properties.json" 第一步、安裝VSCode應用程式 打開 " ...
  • 1. 在執行python程式時遇到 ‘ModuleNotFoundError: No module named 'xxxxx'’ : 例如: 圖片中以導入第三方的 'requests' 模塊為例,此報錯提示找不到requests模塊。在python中,有的 模塊是內置的(直接導入就能使用)有的模塊是 ...
  • 近期在開發過程中,因為項目開發環境連接的mysql資料庫是阿裡雲的資料庫,而阿裡雲的資料庫版本是5.6的。而測試環境的mysql是自己安裝的5.7。因此在開發過程中有小伙伴不註意寫了有關group by的sql語句。在開發環境中運行是正常的,而到了測試環境中就發現了異常。 原因分析:MySQL5.7 ...
一周排行
  • 在上篇文章中我們已經知道了多線程是什麼了,那麼它到底可以幹嘛呢?這裡特別聲明一個前面的委托沒看的同學可以到上上上篇博文查看,因為多線程要經常使用到委托。源碼 一、非同步、同步 1.同步(在計算的理解總是要你措不及防,同步當線程做完一件事情之後,才會執行後續動作),同步方法慢,只有一個線程執行,非同步方法 ...
  • 本文主要是講解stopwatch對程式運行時間的準確測量 僅僅介紹裡面的StartNew()方法,Restart()方法和ElapsedMilliseconds { get;}屬性 public void StartNew():作用是對新的 System.Diagnostics.Stopwatch ...
  • 一、引言 RabbitMQ是Rabbit Message Queue的簡寫,但不能僅僅理解其為消息隊列,消息代理更合適。RabbitMQ是一個由 Erlang 語言開發的AMQP(高級消息隊列協議)的開源實現,其內部結構如下: RabbitMQ作為一個消息代理,主要和消息打交道,負責接收並轉發消息。 ...
  • TerminalMACS(Terminal Manager And Check System) 遠程終端管理和檢測系統 本文同步更新地址:https://dotnet9.com/11429.html 一、本系統可監控多種終端資源: 移動端 Android iOS PC端 Windows Linux ...
  • 首先,好消息是Goole將於2020年2月份發佈Chrome 80版本。本次發佈將推進Google的“漸進改良Cookie”策略,打造一個更為安全和保障用戶隱私的網路環境。 壞消息是,本次更新可能導致瀏覽器無法向服務端發送Cookie。如果你有多個不同功能變數名稱的應用,部分用戶很有可能出現會話時常被打斷的 ...
  • 在偶然一次調試某程式時,遇到提示: 無法載入程式集*****.XmlSerializers.dll,文件找不到(Could not load file or assembly ****.XmlSerializers.dll , FileNotFoundException...)。於是嘗試在項目屬性中 ...
  • 在上一篇abp(net core)+easyui+efcore實現倉儲管理系統——入庫管理之五(四十一) 文章中實現了入庫管理的列表頁面,並實現了控制器的代碼。在今天我們學習如何在前端實現新增入庫單信息界面。 ...
  • 面向對象 面向對象是一個抽象的概念,其本質就是對事物以抽象的方式建立對應的模型。 簡單來講,比如我有一隻鋼筆,那麼我就可以通過分析,可以得到 這隻鋼筆的材第是塑料,品牌是個雜牌 ,裡面裝的墨是黑色的,可以用。這時候就能建立一個鋼筆的模型,它在這裡應該有這些屬性: 圖是一個不正確的UML類圖,但是可以 ...
  • 在ASP.NET MVC中有四種過濾器類型 Action 1、在ASP.NET MVC項目中,新建文件夾Filter,然後新建類MyCustormFilter,繼承自ActionFilterAttribute類,我們來看下ActionFilterAttribute類有如下四個方法,從命名我應該就可以 ...
  • 你需要瞭解的 HTTP Status Code Intro 現在前後端分離的開發模式越來越流行,後端負責開發對應的 API,前端只需要 關註前端頁面的數據展示和前端邏輯即可。 對於前後端分離這種開發模式,我個人還是比較喜歡的,因為這樣可以讓更專業的人做更專業的事情,後端專註於做 API 的開發設計, ...
x