摘要:關(guān)于中順序的基本操作關(guān)于中順序的基本操作寫在前面最近研究一下中的順序,在網(wǎng)絡(luò)上找了一會兒,發(fā)現(xiàn)少有詳細(xì)的介紹,顧此在此處說說順序,才學(xué)疏淺,如有不對,望賜教。上述代碼中標(biāo)記位置中,返回下一次操作時的位置。
寫在前面
最近研究一下JAVA中的順序IO,在網(wǎng)絡(luò)上找了一會兒,發(fā)現(xiàn)少有詳細(xì)的介紹,顧此在此處說說順序IO,才學(xué)疏淺,如有不對,望賜教。
什么是順序IO
事實上JAVA具有很多操作文件的方案(方法), 許多程序需要將一些事件記錄到本地存儲中,常見的如數(shù)據(jù)庫,MQ等,首先文件是許多帶數(shù)據(jù)的塊組成的,傳統(tǒng)IO操作文件具有一個尋址過程(事實上硬件上也會存在尋道,旋轉(zhuǎn)延遲等因素),小文件尚可,大文件就比較消耗性能和時間,比如數(shù)據(jù)庫分配的文件(本地),順序IO具備指定位置的功能,但是任然需要我們維護一個偏移量(游標(biāo)).
MappedByteBuffer
JAVA順序IO通過MappedByteBuffer實現(xiàn),與傳統(tǒng)IO不同的是,MappedByteBuffer需要使用者提供一個位置(偏移量),詳細(xì)看以下代碼:
mappedByteBuffer.position(index);mappedByteBuffer.put(content.getBytes(StandardCharsets.UTF_8));
代碼中可見,通過MappedByteBuffer提供的api position();來指定位置(偏移量),put()進(jìn)行寫操作,詳細(xì)如下。
寫操作
先看代碼:
public int write(File file ,String content ,int index,long size){RandomAccessFile randomAccessFile;MappedByteBuffer mappedByteBuffer;try {randomAccessFile = new RandomAccessFile(file,"rw"); //1FileChannel fileChannel = randomAccessFile.getChannel(); //2mappedByteBuffer = fileChannel.map(FileChannel.MapMode.READ_WRITE,0,size); //3mappedByteBuffer.position(index); //4mappedByteBuffer.put(content.getBytes(StandardCharsets.UTF_8)); //5return mappedByteBuffer.position(); //6}catch (Exception e){e.printStackTrace();}return 0;}
"r"僅供閱讀。調(diào)用結(jié)果對象的任何寫方法都會引發(fā)IOException。(Open for reading only. Invoking any of the write methods of the resulting object will cause an IOException to be thrown. )
"rw"開放閱讀和寫作。如果該文件不存在,那么將嘗試創(chuàng)建它。(Open for reading and writing. If the file does not already exist then an attempt will be made to create it. )
“rws”和“rw”一樣,對文件內(nèi)容或元數(shù)據(jù)的每次更新都要同步寫入底層存儲設(shè)備。(Open for reading and writing, as with "rw", and also require that every update to the file"s content or metadata be written synchronously to the underlying storage device. )
“rwd”和“rw”一樣,都是打開的,可以讀寫,并且還要求對文件內(nèi)容的每次更新都要同步寫入底層存儲設(shè)備。(Open for reading and writing, as with "rw", and also require that every update to the file"s content be written synchronously to the underlying storage device. )
FileInputStream fileInputStream = new FileInputStream(file);FileChannel fileChannel = fileInputStream.getChannel();
運行結(jié)果,標(biāo)記3處拋出異常:NonWritableChannelException
或者:
FileOutputStream fileInputStream = new FileOutputStream(file);FileChannel fileChannel = fileInputStream.getChannel();
運行結(jié)果,標(biāo)記3處拋出異常:NonReadableChannelException
從上可以看到,不管是FileInputStream還是FileOutputStream獲取到的IO通道,均有局限性,不適用MappedByteBuffer。
只讀:任何修改結(jié)果緩沖區(qū)的嘗試都將導(dǎo)致拋出ReadOnlyBufferException。(MapMode.READ_ONLY) (Read-only: Any attempt to modify the resulting buffer will cause a ReadOnlyBufferException to be thrown. (MapMode.READ_ONLY) )
讀/寫:對產(chǎn)生的緩沖區(qū)所做的更改最終將傳播到文件;它們可能對映射了相同文件的其他程序可見,也可能不可見。(MapMode.READ_WRITE) (Read/write: Changes made to the resulting buffer will eventually be propagated to the file; they may or may not be made visible to other programs that have mapped the same file. (MapMode.READ_WRITE) )
Private:對產(chǎn)生的緩沖區(qū)所做的更改不會傳播到該文件中,并且不會對映射了該文件的其他程序可見;相反,它們將導(dǎo)致創(chuàng)建緩沖區(qū)修改部分的私有副本。(MapMode.PRIVATE) (Private: Changes made to the resulting buffer will not be propagated to the file and will not be visible to other programs that have mapped the same file; instead, they will cause private copies of the modified portions of the buffer to be created. (MapMode.PRIVATE) )
參數(shù)二代表從指定位置開始映射,0表示從頭開始映射全部內(nèi)容,參數(shù)三表示要映射的區(qū)域大小,可超出文件大小(如字符長度為3,此處可填寫6或者其他),但不可為負(fù)數(shù)或超出Integer.MAX_VALUE.
實際上到此處,IO通道已經(jīng)完成了它的任務(wù),可關(guān)閉。(在標(biāo)記3之后任意位置可執(zhí)行fileChannel.close()而不影響運行結(jié)果)
此處簡要說明了個參數(shù)的意思,要加深了解建議自己建立Demo并更改此處參數(shù)觀察運行結(jié)果。
上述代碼中標(biāo)記4位置中,通過MappedByteBuffer對象的position(); API設(shè)置寫入位置,官方解釋如下:
Sets this buffer"s limit. If the position is larger than the new limit then it is set to the new limit. If the mark is defined and larger than the new limit then it is discarded.
上述代碼中標(biāo)記5位置中,將內(nèi)容傳輸?shù)骄彌_區(qū),可理解為寫入,因為緩沖區(qū)的變動會傳播到實際文件中,除了PRIVATE。
上述代碼中標(biāo)記6位置中,返回下一次操作時的位置。
此篇文章簡要說明了一下JAVA順序IO,有些地方?jīng)]有詳細(xì)說明,會持續(xù)維護更新此篇文章,感謝大家。
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/124129.html
摘要:從通道進(jìn)行數(shù)據(jù)寫入創(chuàng)建一個緩沖區(qū),填充數(shù)據(jù),并要求通道寫入數(shù)據(jù)。三之通道主要內(nèi)容通道介紹通常來說中的所有都是從通道開始的。從中選擇選擇器維護注冊過的通道的集合,并且這種注冊關(guān)系都被封裝在當(dāng)中停止選擇的方法方法和方法。 由于內(nèi)容比較多,我下面放的一部分是我更新在我的微信公眾號上的鏈接,微信排版比較好看,更加利于閱讀。每一篇文章下面我都把文章的主要內(nèi)容給列出來了,便于大家學(xué)習(xí)與回顧。 Ja...
摘要:探索專為而設(shè)計的將探討進(jìn)行了何種改進(jìn),以及這些改進(jìn)背后的原因。關(guān)于最友好的文章進(jìn)階前言之前就寫過一篇關(guān)于最友好的文章反響很不錯,由于那篇文章的定位就是簡單友好,因此盡可能的摒棄復(fù)雜的概念,只抓住關(guān)鍵的東西來講,以保證大家都能看懂。 周月切換日歷 一個可以進(jìn)行周月切換的日歷,左右滑動的切換月份,上下滑動可以進(jìn)行周,月不同的視圖切換,可以進(jìn)行事件的標(biāo)記,以及節(jié)假日的顯示,功能豐富 Andr...
摘要:阻塞請求結(jié)果返回之前,當(dāng)前線程被掛起。也就是說在異步中,不會對用戶線程產(chǎn)生任何阻塞。當(dāng)前線程在拿到此次請求結(jié)果的過程中,可以做其它事情。事實上,可以只用一個線程處理所有的通道。 準(zhǔn)備知識 同步、異步、阻塞、非阻塞 同步和異步說的是服務(wù)端消息的通知機制,阻塞和非阻塞說的是客戶端線程的狀態(tài)。已客戶端一次網(wǎng)絡(luò)請求為例做簡單說明: 同步同步是指一次請求沒有得到結(jié)果之前就不返回。 異步請求不會...
摘要:通道可以異步讀寫。使用的方法讀取數(shù)據(jù)創(chuàng)建一個讀數(shù)據(jù)緩沖區(qū)對象從通道中讀取數(shù)據(jù)使用的方法寫入數(shù)據(jù)創(chuàng)建一個寫數(shù)據(jù)緩沖區(qū)對象寫入數(shù)據(jù)關(guān)閉完成使用后,您必須關(guān)閉它。五提供了一種被稱為的新功能,也稱為本地矢量。功能是通道提供的并不是。 歷史回顧: Java NIO 概覽 Java NIO 之 Buffer(緩沖區(qū)) 其他高贊文章: 面試中關(guān)于Redis的問題看這篇就夠了 一文輕松搞懂redis集...
摘要:一面試題及剖析今日面試題今天壹哥帶各位復(fù)習(xí)一塊可能會令初學(xué)者比較頭疼的內(nèi)容,起碼當(dāng)時讓我很有些頭疼的內(nèi)容,那就是流。在這里壹哥會從兩部分展開介紹流,即與流。除此之外盡量使用字節(jié)流。關(guān)閉此輸入流并釋放與流相關(guān)聯(lián)的任何系統(tǒng)資源。 一. 面試題及剖析 1. 今日面試題 今天 壹哥 帶各位復(fù)習(xí)一塊可...
閱讀 994·2021-11-23 09:51
閱讀 3486·2021-11-22 12:04
閱讀 2727·2021-11-11 16:55
閱讀 2955·2019-08-30 15:55
閱讀 3238·2019-08-29 14:22
閱讀 3360·2019-08-28 18:06
閱讀 1253·2019-08-26 18:36
閱讀 2138·2019-08-26 12:08