java socket大數(shù)據(jù)傳輸丟失問(wèn)題及解決

更新時(shí)間：2024年08月10日 14:05:30 作者：yahahassr

這篇文章主要介紹了java socket大數(shù)據(jù)傳輸丟失問(wèn)題及解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

java socket大數(shù)據(jù)傳輸丟失

最近遇見(jiàn)一個(gè)問(wèn)題。利用java 的socket進(jìn)行數(shù)據(jù)傳輸時(shí)，當(dāng)數(shù)據(jù)量過(guò)大，比如4w個(gè)字節(jié)。

這時(shí)候我在客戶端輸出流將數(shù)據(jù)發(fā)送給服務(wù)器。

服務(wù)器如果利用數(shù)組接收時(shí)(即is.read(byte[])方法)，接收到的數(shù)據(jù)不全。網(wǎng)上解決方法。

一、分批發(fā)送，分批讀取，并不要直接讀取

將輸入輸出流利用BufferedInputStream包裝。

實(shí)測(cè)這種方法不能根本上解決問(wèn)題，治標(biāo)不治本。還是會(huì)有概率丟失。

二、實(shí)際上，數(shù)據(jù)是不會(huì)丟失的

即使輸入數(shù)據(jù)過(guò)大導(dǎo)致溢出。數(shù)據(jù)也不會(huì)丟失。

根據(jù)觀察，應(yīng)該只是數(shù)據(jù)還沒(méi)有傳輸過(guò)來(lái)，但是利用is.read(byte[])方法時(shí)，即使讀取到的數(shù)據(jù)不到byte[]數(shù)組長(zhǎng)度時(shí)，該方法也可以進(jìn)行下去，不會(huì)阻塞?。?！

譬如以下代碼：

public class Test {
    @org.junit.Test
    public void server() throws IOException {
        ServerSocket serverSocket = new ServerSocket(8080);
        while (true){
            Socket accept = serverSocket.accept();
            InputStream is = accept.getInputStream();
            byte[] bytes = new byte[5];
            int len = is.read(bytes);
            System.out.println(Arrays.toString(bytes));//發(fā)送端發(fā)送的數(shù)據(jù)只有兩個(gè)字節(jié)，我們接收端設(shè)置為5個(gè)字節(jié)的字節(jié)數(shù)組，結(jié)果打印[1,2,0,0,0]，而不會(huì)在上一步阻塞
        }
    }

    @org.junit.Test
    public void client() throws IOException {
        Socket socket = new Socket("127.0.0.1",8080);
        OutputStream os = socket.getOutputStream();
        os.write(new byte[]{1,2});
    }
}

從這個(gè)例子我們就知道為什么會(huì)丟失數(shù)據(jù)了。

原因有兩點(diǎn)：

網(wǎng)絡(luò)延時(shí)
inputStream.read(byte[])方法讀取的數(shù)據(jù)長(zhǎng)度不一定等于byte[]數(shù)組長(zhǎng)度

根據(jù)以上兩點(diǎn)，修改后的接收端代碼應(yīng)該如此。

public static byte[] readData(InputStream is,int length) throws IOException {
        byte[] bytes = new byte[length];
        int index = 0;
        int len = 0;
        while(index < length){
            len = is.read(bytes,index,length - index);
            //每次讀取完判斷數(shù)據(jù)是否全部讀取完畢
            if(len > 0){
                index += len;
            }else {
                break;
            }
        }
        return bytes;
    }