快捷導(dǎo)航

解決DataInputStream?read不等于-1,socket文件傳輸只能傳輸一個文件無法傳輸多個問題

更新時間：2024年08月12日 08:58:30 作者：客?卿

這篇文章主要介紹了解決DataInputStream?read不等于-1,socket文件傳輸只能傳輸一個文件無法傳輸多個問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

被一個朋友問到一個關(guān)于sokcet文件傳輸?shù)膯栴}

他發(fā)現(xiàn)他寫的代碼只能發(fā)送一次文件，沒辦法發(fā)送第二次，或者說發(fā)送第二次的時候服務(wù)端就接收不到了。

部分代碼

  // 開始接收文件
                    byte[] bytes = new byte[1024];
                    //byte[] bytes = new byte[dis.available()];
                    int length = 0;
                    while((length = dis.read(bytes, 0, bytes.length)) != -1) {
                    	 System.out.println(bytes.length);
                        fos.write(bytes, 0, length);
                        fos.flush();
                        
                        
                        
                    }
                    System.out.println("======== 文件接收成功 [File Name：" + fileName + "] [Size：" + getFormatFileSize(fileLength) + "] ========");

我給他調(diào)試的時候發(fā)現(xiàn)確確實實發(fā)送第一次文件后就就一直阻塞在while循環(huán)里了，出不來。

本來傳輸完第一次的文件后應(yīng)該有打印“======== 文件接收成功 [File。。。。。。”

這些信息，但是實際上沒有，而且也不報錯。

調(diào)試的時候打斷點也是走著走著斷點就不見了，要說他是阻塞也不像是阻塞，因為如果是阻塞的話起碼斷點是會存在的只是無法往下運行了而已，但是他這個調(diào)試就是直接斷點就消失了，我也懵了。

后來查資料才發(fā)現(xiàn)原來只要客戶端的DataOutputStream不close掉，那么服務(wù)端的DataInputStream read就永遠不等于-1。

即使文件的數(shù)據(jù)已經(jīng)傳完了，DataInputStream依舊會等著客戶端DataOutputStream再傳數(shù)據(jù)過來。

最后只能通過判斷文件的的大小來確認(rèn)文件是否已經(jīng)傳輸完成。

解決代碼代碼

  //dis就是DataInputStream
 String fileName = dis.readUTF();//文件名字
                    long fileLength = dis.readLong();//文件長度
                    File directory = new File(savepath);
                    if(!directory.exists()) {
                        directory.mkdir();
                    }
                    File file = new File(directory.getAbsolutePath() + File.separatorChar + fileName);
                    fos = new FileOutputStream(file);
                    // 開始接收文件
                    byte[] bytes = new byte[1024];
                    //byte[] bytes = new byte[dis.available()];
                    int length = 0;
                    while((length = dis.read(bytes, 0, bytes.length)) != -1) {
                    	 System.out.println(bytes.length);
                    	 //fos就是FileOutputStream
                        fos.write(bytes, 0, length);
                        fos.flush();

                       //*************關(guān)鍵的一步**************//
                        if(fileLength == file.length()) break;
                        //***************************//
                    }
                    System.out.println("======== 文件接收成功 [File Name：" + fileName + "] [Size：" + getFormatFileSize(fileLength) + "] ========");