面試刷題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 ...
一周排行
  • 比如要拆分“呵呵呵90909086676喝喝999”,下麵當type=0返回的是中文字元串“呵呵呵,喝喝”,type=1返回的是數字字元串“90909086676,999”, private string GetStrings(string str,int type=0) { IList<strin ...
  • Swagger一個優秀的Api介面文檔生成工具。Swagger可以可以動態生成Api介面文檔,有效的降低前後端人員關於Api介面的溝通成本,促進項目高效開發。 1、使用NuGet安裝最新的包:Swashbuckle.AspNetCore。 2、編輯項目文件(NetCoreTemplate.Web.c ...
  • 2020 年 7 月 30 日, 由.NET基金會和微軟 將舉辦一個線上和為期一天的活動,包括 微軟 .NET 團隊的演講者以及社區的演講者。本次線上大會 專註.NET框架構建微服務,演講者分享構建和部署雲原生應用程式的最佳實踐、模式、提示和技巧。有關更多信息和隨時瞭解情況:https://focu... ...
  • #abp框架Excel導出——基於vue #1.技術棧 ##1.1 前端採用vue,官方提供 UI套件用的是iview ##1.2 後臺是abp——aspnetboilerplate 即abp v1,https://github.com/aspnetboilerplate/aspnetboilerp ...
  • 前言 本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。 作者:碧茂大數據 PS:如有需要Python學習資料的小伙伴可以加下方的群去找免費管理員領取 input()輸入 Python提供了 input() 內置函數從標準輸入讀入一 ...
  • 從12年到20年,python以肉眼可見的趨勢超過了java,成為了當今It界人人皆知的編程語言。 python為什麼這麼火? 網路編程語言搜索指數 適合初學者 Python具有語法簡單、語句清晰的特點,這就讓初學者在學習階段可以把精力集中在編程對象和思維方法上。 大佬都在用 Google,YouT ...
  • 在社會上存在一種普遍的對培訓機構的學生一種歧視的現象,具體表現在,比如:當你去公司面試的時候,一旦你說了你是培訓機構出來的,那麼基本上你就涼了,那麼你瞞著不說,然後又通過了面試成功入職,但是以後一旦在公司被髮現有培訓經歷,可能會面臨被降薪,甚至被辭退,培訓機構出來的學生,在用人單位眼裡就是能力低下的 ...
  • from typing import List# 這道題看了大佬寫的代碼,經過自己的理解寫出來了。# 從最外圍的四周找有沒有為O的,如果有的話就進入深搜函數,然後深搜遍歷# 判斷上下左右的位置是否為Oclass Solution: def solve(self, board: List[List[s ...
  • import requests; import re; import os; # 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, li ...
  • import requests; import re; import os; import parsel; 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537. ...