解決bufferedReader.readLine()讀到最后發(fā)生阻塞的問(wèn)題
bufferedReader.readLine()讀到最后發(fā)生阻塞
最近在做一個(gè)imageserver,需求簡(jiǎn)化后就是使用socket響應(yīng)HTTP請(qǐng)求從而截取所需要的數(shù)據(jù)流，寫(xiě)入到服務(wù)器端的文件中，從而完成客戶端將圖片上傳到服務(wù)器。
因?yàn)閺目蛻舳说玫降臄?shù)據(jù)流中，我們只希望截取其中的一部分。這樣就使我們無(wú)法像經(jīng)常那樣邊讀邊向文件中寫(xiě)入，而且在流已經(jīng)讀到末尾時(shí)，使用bufferedInputStream.read()>0或inputStream.read()>0作為while語(yǔ)句結(jié)束的判斷條件在使用socket獲得的數(shù)據(jù)流中是無(wú)法返回-1（因?yàn)榭蛻舳耸峭ㄟ^(guò)瀏覽器提交的form表單，它無(wú)法告訴服務(wù)器的socket數(shù)據(jù)已經(jīng)發(fā)送結(jié)束。因此read()方法還在等待客戶端發(fā)送消息產(chǎn)生了阻塞）。
但是我們?nèi)绻皇褂胋ufferedInputStream.read()，我們就無(wú)法得到客戶端的數(shù)據(jù)流。那么我們將如何取得數(shù)據(jù)流，并避免在讀取數(shù)據(jù)時(shí)發(fā)生阻塞。
我是這樣解決的：
int newread = 0;
int totalread = 0;
int contentLength = Integer.parseInt(headers.get("content-length"));
byte[] bytes = new byte[contentLength];
while (totalread < contentLength) {
newread = bufferedInputStream.read(bytes, totalread, contentLength - totalread);
totalread += newread;
}
headers：自定義的map對(duì)象用來(lái)存儲(chǔ)之前已經(jīng)解析的http請(qǐng)求消息中Content-Length的值
這樣循環(huán)讀數(shù)據(jù)可以解決兩個(gè)問(wèn)題：
1、避免使用read（）方法造成的整個(gè)程序陷入阻塞。
2、當(dāng)讀的數(shù)據(jù)流較大時(shí)，還可以防止read（）方法不能完全讀取。
這樣問(wèn)題即可解決，完美！
BufferedReader的readline()踩坑
剛剛踩了一個(gè)readLine()方法的小坑
本來(lái)功能沒(méi)有問(wèn)題，但是根據(jù)下面的代碼，我的lineStr一直為Null,看來(lái)網(wǎng)上的挺多這種相關(guān)的問(wèn)題，但是和我的問(wèn)題都不一樣；
這里是有問(wèn)題的代碼：
BufferedReader br = new BufferedReader(new InputStreamReader(in));
// 讀取結(jié)果
System.out.println("獲取:"+br.readLine());//注意這里是先打印了
String lineStr = br.readLine();//然后在獲取的
后面我根據(jù)看別人解釋readLine方法，發(fā)現(xiàn)是因?yàn)閞eadLine方法讀取了一行之后，不關(guān)閉就會(huì)讀取下一行，而我只需要讀取一行，所以我原來(lái)的打印吧數(shù)據(jù)拿出來(lái)了，在給lineStr賦值時(shí)它去打印下一行根本沒(méi)有東西，于是我把上面的打印刪掉解決了這個(gè)問(wèn)題
下面是修改了的：
BufferedReader br = new BufferedReader(new InputStreamReader(in));
// 讀取結(jié)果
String lineStr = br.readLine();//直接賦值
這本身可能不算問(wèn)題哈，但是難為了我小半天，做個(gè)記錄。以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
java StringBuilder類的詳解及簡(jiǎn)單實(shí)例
這篇文章主要介紹了java StringBuilder類的詳解及簡(jiǎn)單實(shí)例的相關(guān)資料,實(shí)現(xiàn)了StringBuilder類的追加、插入、替換、刪除等操作，需要的朋友可以參考下2017-08-08
Maven將Jar包打入本地倉(cāng)庫(kù)的實(shí)現(xiàn)
項(xiàng)目需要用到一個(gè)Jar包,不能從遠(yuǎn)程倉(cāng)庫(kù)拉取,只有一個(gè)Jar包,所以需要將Jar包打入到本地倉(cāng)庫(kù)才能引入項(xiàng)目,本文主要介紹了Maven將Jar包打入本地倉(cāng)庫(kù)的實(shí)現(xiàn),感興趣的可以了解一下2023-12-12
SpringBoot中的ExpiringMap代碼實(shí)例
這篇文章主要介紹了SpringBoot中的ExpiringMap代碼實(shí)例,ExpiringMap是一個(gè)可以設(shè)置過(guò)期策略、可變條目過(guò)期、延遲條目加載和過(guò)期偵聽(tīng)器的線程安全存儲(chǔ)容器,需要的朋友可以參考下2023-08-08
Java 異步編程實(shí)踐_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
異步編程提供了一個(gè)非阻塞的，事件驅(qū)動(dòng)的編程模型。下面通過(guò)本文給大家介紹Java 異步編程實(shí)踐，感興趣的的朋友一起看看吧2017-05-05
一文搞懂SpringBoot如何利用@Async實(shí)現(xiàn)異步調(diào)用
異步調(diào)用幾乎是處理高并發(fā)，解決性能問(wèn)題常用的手段，如何開(kāi)啟異步調(diào)用？SpringBoot中提供了非常簡(jiǎn)單的方式，就是一個(gè)注解@Async。今天我們重新認(rèn)識(shí)一下@Async,以及注意事項(xiàng)2022-09-09
最長(zhǎng)重復(fù)子數(shù)組 findLength示例詳解
今天給大家分享一道比較常問(wèn)的算法面試題,最長(zhǎng)重復(fù)子數(shù)組 findLength,文中給大家分享解題思路,結(jié)合示例代碼介紹的非常詳細(xì),需要的朋友參考下吧2023-08-08
springboot中使用redis并且執(zhí)行調(diào)試lua腳本
今天有個(gè)項(xiàng)目需要使用redis，并且有使用腳本的需求，本文主要介紹了springboot中使用redis并且執(zhí)行調(diào)試lua腳本，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04
Java定義了一套JDBC的接口，但并未提供具體實(shí)現(xiàn)類，而是在不同云廠商提供的數(shù)據(jù)庫(kù)實(shí)現(xiàn)包。這篇文章給大家介紹Java的SPI機(jī)制，感興趣的朋友一起看看吧2021-11-11
詳解Java關(guān)于JDK中時(shí)間日期的API
這篇文章主要介紹了詳解Java關(guān)于JDK中時(shí)間日期的API，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-09-09
Java 8新時(shí)間日期庫(kù)java.time的使用示例
這篇文章主要給你大家介紹了關(guān)于Java 8新時(shí)間日期庫(kù)java.time的使用示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07