Java BufferedOutputStream類的常用方法講解
更新時間：2021年10月12日 11:41:33 作者：scbiaosdo
這篇文章主要介紹了Java BufferedOutputStream類的常用方法，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
BufferedOutputStream類的常用方法
BufferedOutputStream字節(jié)緩沖輸出流
構造方式
第一種開發(fā)中
public BufferedOutputStream(OutputStream out)
采用的默認的緩沖區(qū)大小(足夠大了) ,來構造一個字節(jié)緩沖輸出流對象
public BufferedOutputStream(OutputStream out,int size)
指定size緩沖區(qū)大小構造緩沖輸出流對象
IllegalArgumentException - 如果 size <= 0
常用方法
public void write(int b)throws IOException
一次寫一個字節(jié)
- b - 要寫入的字節(jié)。
public void write(byte[] b,int off,int len) throws IOException
一次寫一個字節(jié)數(shù)組的一部分
- b - 數(shù)據(jù)。
- off - 數(shù)據(jù)的起始偏移量。
- len - 要寫入的字節(jié)數(shù)。
public void flush() throws IOException
刷新此緩沖的輸出流。這迫使所有緩沖的輸出字節(jié)被寫出到底層輸出流中。
public void close() throws IOException
關閉此輸出流并釋放與此流有關的所有系統(tǒng)資源。
FilterOutputStream 的 close 方法先調(diào)用其 flush 方法，然后調(diào)用其基礎輸出流的 close 方法。
程序示例
public static void main(String[] args) throws Exception {
//符合Java一種設計模式:裝飾者設計模式(過濾器:Filter)
BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("bos.txt")) ;
//寫數(shù)據(jù)
bos.write("hello".getBytes());
//釋放資源
bos.close();
}
BufferedOutputStream深入分析
FileOutputStream和BufferedOutputStream都提供了一系列的將數(shù)據(jù)寫入文件的方式，并且我們都知道BufferedOutputStream要比直接使用FileOutputStream寫入速度要快，本文通過案例實際演示一下兩者的區(qū)別。
代碼準備
public class BufferFile {
public static void main(String[] args) {
//每次向文件中寫入一個8字節(jié)的數(shù)組
byte[] bytes = "1234567\n".getBytes();
//每隔100毫秒通過buffer的方式向文件中寫入數(shù)據(jù)
new Thread(() -> {
System.out.println("buffer_while start...");
File file = new File("/var/file_test_data/out_buffer_while.txt");
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(file);
BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
while (true) {
Thread.sleep(100);
bufferedOutputStream.write(bytes);
}
} catch (Exception e) {
e.printStackTrace();
}
}).start();
//通過buffer的方式向文件中寫入1千萬次
new Thread(() -> {
System.out.println("buffer_for start...");
File file = new File("/var/file_test_data/out_buffer_for.txt");
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(file);
BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
for (int i = 0; i < 10000000; i++) {
bufferedOutputStream.write(bytes);
}
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(new Date() + ": buffer_for end...");
}).start();
//通過file的方式向文件中寫入1千萬次
new Thread(() -> {
System.out.println("file_for start...");
File file = new File("/var/file_test_data/out_file_for.txt");
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(file);
for (int i = 0; i < 10000000; i++) {
fileOutputStream.write(bytes);
}
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(new Date() + ": file_for end...");
}).start();
}
}
開始運行
強行停止后的運行結果
1、file和buffe寫入速度比較
兩者分別寫入1千萬次，時間上buffer比file快8秒，如果當寫入次數(shù)指數(shù)級增加時，buffer的優(yōu)勢將更加明顯。
2、數(shù)據(jù)寫入完整性問題
buffer雖然要比file快，但是從最終數(shù)據(jù)上可以看出，buffer會丟數(shù)據(jù)
- 當?shù)谝粋€線程寫入時數(shù)據(jù)還未滿8kb時，強制停止java進程，最終out_buffer_while.txt沒有數(shù)據(jù)。
- 第二個線程，雖然最終代碼執(zhí)行完畢，但是比較file方式，out_buffer_for.txt文件看起來也丟了一部分數(shù)據(jù)。
原因分析
當使用buffer讀寫文件時，數(shù)據(jù)并沒有直接被寫入磁盤，而是被緩存到一個字節(jié)數(shù)據(jù)中，這個字節(jié)數(shù)組的大小是8kb，默認情況下只有當8kb被填充滿了以后，數(shù)據(jù)才會被一次性寫入磁盤，這樣一來就大大減少了系統(tǒng)調(diào)用的次數(shù)（file是每一次write都會產(chǎn)生系統(tǒng)調(diào)用），當然也正是因為buffer中的每一次write只是寫入到內(nèi)存中（JVM自身內(nèi)存中），所以當數(shù)據(jù)未寫入磁盤前，如果JVM進程掛了，那么就會造成數(shù)據(jù)丟失。
手動刷盤
為了解決數(shù)據(jù)丟失的問題，buf中提供了flush()方法，用戶可以自行決定合適將數(shù)據(jù)刷寫到磁盤中
- 如果你的flush()調(diào)用的非常頻繁，那就會退化為普通的file模式了。
- 如果你的flush()調(diào)用的又不太頻繁，那么丟數(shù)據(jù)的可能性就比較高。
- 無論如何業(yè)務邏輯中數(shù)據(jù)寫完時，一定要調(diào)用一次flush()，確保緩沖區(qū)的數(shù)據(jù)刷到磁盤上。
將無限循環(huán)寫入的代碼注釋掉，在buf寫1千萬完成后，加上bufferedOutputStream.flush();
public class BufferFile {
public static void main(String[] args) {
//每次向文件中寫入一個8字節(jié)的數(shù)組
byte[] bytes = "1234567\n".getBytes();
//每隔100毫秒通過buffer的方式向文件中寫入數(shù)據(jù)
/*new Thread(() -> {
System.out.println("buffer_while start...");
File file = new File("/var/file_test_data/out_buffer_while.txt");
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(file);
BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
while (true) {
Thread.sleep(100);
bufferedOutputStream.write(bytes);
}
} catch (Exception e) {
e.printStackTrace();
}
}).start();*/
//通過buffer的方式向文件中寫入1千萬次
new Thread(() -> {
System.out.println("buffer_for start...");
File file = new File("/var/file_test_data/out_buffer_for.txt");
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(file);
BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
for (int i = 0; i < 10000000; i++) {
bufferedOutputStream.write(bytes);
}
bufferedOutputStream.flush();
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(new Date() + ": buffer_for end...");
}).start();
//通過file的方式向文件中寫入1千萬次
new Thread(() -> {
System.out.println("file_for start...");
File file = new File("/var/file_test_data/out_file_for.txt");
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(file);
for (int i = 0; i < 10000000; i++) {
fileOutputStream.write(bytes);
}
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(new Date() + ": file_for end...");
}).start();
}
}
這次再看數(shù)據(jù)寫入完整了
buffer源碼分析
類的機構圖
首先當創(chuàng)建一個BufferedOutputStream對象時，構造方法就初始化了緩沖的字節(jié)數(shù)組大小為8kb
protected byte buf[];
public BufferedOutputStream(OutputStream out) {
this(out, 8192);
}
public BufferedOutputStream(OutputStream out, int size) {
super(out);
if (size <= 0) {
throw new IllegalArgumentException("Buffer size <= 0");
}
buf = new byte[size];
}
當調(diào)用buffer.write(b)時，調(diào)用的是父類FilterOutputStream的方法
public void write(byte b[]) throws IOException {
//寫入的字節(jié)數(shù)組b，從0開始，一共要寫入的長度
write(b, 0, b.length);
}
public void write(byte b[], int off, int len) throws IOException {
if ((off | len | (b.length - (len + off)) | (off + len)) < 0)
throw new IndexOutOfBoundsException();
//遍歷數(shù)組，一個字節(jié)一個字節(jié)的把數(shù)據(jù)寫入數(shù)組中
for (int i = 0 ; i < len ; i++) {
write(b[off + i]);
}
}
public synchronized void write(int b) throws IOException {
//判斷字節(jié)長度是否超過buf.length，buf在初始化已經(jīng)指定大小為8192，即8kb
//如果超過則調(diào)用flushBuffer
if (count >= buf.length) {
flushBuffer();
}
把每一個字節(jié)寫入緩沖的buf數(shù)組中，并且統(tǒng)計值count++
buf[count++] = (byte)b;
}
private void flushBuffer() throws IOException {
if (count > 0) {
//真正的調(diào)用OutputStream，寫入數(shù)據(jù)到磁盤中
//寫入buf緩沖字節(jié)數(shù)組數(shù)據(jù)，從0下標開始，一直寫到count，即有多少寫多少。
out.write(buf, 0, count);
count = 0;
}
}
關于buf緩沖數(shù)據(jù)大小設置
buffer提供了可以自定義緩沖大小的構造方法
public BufferedOutputStream(OutputStream out, int size) {
super(out);
if (size <= 0) {
throw new IllegalArgumentException("Buffer size <= 0");
}
buf = new byte[size];
}
如果緩沖大小設置的比較大。
- 好處：進一步減少調(diào)用系統(tǒng)內(nèi)核寫數(shù)據(jù)的方法，提高寫入速度，kafka的批寫入默認就是16kb寫一次。
- 壞處：1、丟失的數(shù)據(jù)可能會更多，2、要注意堆內(nèi)存的消耗。
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
在Spring Boot中集成RabbitMQ詳細步驟(最新推薦)
本文將介紹如何在Spring Boot項目中集成RabbitMQ,實現(xiàn)生產(chǎn)者和消費者的基本配置,本文分步驟給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧2023-12-12
用Java產(chǎn)生100個1-150間不重復數(shù)字
這篇文章主要介紹了用Java產(chǎn)生100個1-150間不重復數(shù)字,需要的朋友可以參考下2017-02-02
SpringCloud集成Eureka并實現(xiàn)負載均衡的過程詳解
這篇文章主要給大家詳細介紹了SpringCloud集成Eureka并實現(xiàn)負載均衡的過程,文章通過代碼示例和圖文講解的非常詳細,對大家的學習或工作有一定的參考價值,需要的朋友可以參考下2023-11-11
SpringCloud+Tornado基于jwt實現(xiàn)請求安全校驗功能
這篇文章主要介紹了SpringCloud+Tornado基于jwt實現(xiàn)請求安全校驗,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12
這篇文章主要介紹了java中import作用，import與package機制相關，這里先從package入手，再講述import以及static import的作用。2021-04-04
這篇文章主要介紹了JAVA并發(fā)編程 線程同步的的相關資料，文中示例代碼非常詳細，幫助大家更好的理解和學習，感興趣的朋友可以了解下2020-06-06
這篇文章主要介紹了淺談對于DAO設計模式的理解，小編覺得挺不錯的，這里分享給大家，供需要的朋友參考。2017-10-10
這篇文章主要介紹了如何重寫hashcode和equals方法，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
springmvc前臺向后臺傳值幾種方式總結(從簡單到復雜)
今天小編就為大家分享一篇springmvc前臺向后臺傳值幾種方式總結(從簡單到復雜)，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-08-08
JAVAWEB實現(xiàn)簡單的商城項目(一)實例代碼解析
本文給大家分享一段實例代碼給大家介紹JAVAWEB實現(xiàn)簡單的商城項目(一)，非常具有參考價值，感興趣的朋友一起學習吧2016-02-02