国产成人精品亚洲777人妖,欧美日韩精品一区视频,最新亚洲国产,国产乱码精品一区二区亚洲

您的位置:首頁技術文章
文章詳情頁

Java文件斷點續(xù)傳實現原理解析

瀏覽:4日期:2022-09-01 14:06:05

一、作用:

隨機流(RandomAccessFile)不屬于IO流,支持對文件的讀取和寫入隨機訪問。

二、隨機訪問文件原理:

首先把隨機訪問的文件對象看作存儲在文件系統(tǒng)中的一個大型 byte 數組,然后通過指向該 byte 數組的光標或索引(即:文件指針 FilePointer)在該數組任意位置讀取或寫入任意數據。

三、相關方法說明:

1、對象聲明:RandomAccessFile raf = newRandomAccessFile(File file, String mode);

其中參數 mode 的值可選 'r':可讀,'w' :可寫,'rw':可讀性;

2、獲取當前文件指針位置:int RandowAccessFile.getFilePointer();

3、改變文件指針位置(相對位置、絕對位置):

1> 絕對位置:RandowAccessFile.seek(int index);

2> 相對位置:RandowAccessFile.skipByte(int step); 相對當前位置

4、給寫入文件預留空間:RandowAccessFile.setLength(long len);

斷點續(xù)傳實現原理:

1)下載斷開的時候,記錄文件斷點的位置position;

2)繼續(xù)下載的時候,通過RandomAccessFile找到之前的position位置開始下載

實際操作:

我們在D盤的根目錄下創(chuàng)建一個名為”test.txt”的文件,文件內容很簡單,如圖所示:

Java文件斷點續(xù)傳實現原理解析

沒錯,我們輸入的內容就是簡單的6個英語字母。然后我們右鍵→屬性:

Java文件斷點續(xù)傳實現原理解析

我們要實現的效果很簡單:將在D盤的”test.txt”文件寫入到E盤當中,但中途我們會模擬一次”中斷”行為,然后在重新繼續(xù)上傳,最終完成整個過程。

也就是說,我們這里將會把“D盤”視作一臺電腦,并且直接將”E盤”視作一臺服務器。那么這樣我們甚至都不再與http協議扯上半毛錢關系了,(當然實際開發(fā)我們肯定是還是得與它扯上關系的 ^<^),從而只關心最基本的文件讀寫的”斷”和”續(xù)”的原理是怎么樣的。

import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.IOException;import java.io.RandomAccessFile;public class Test { private static int position = -1; public static void main(String[] args) { // 源文件與目標文件 File sourceFile = new File('D:/', 'test.txt'); File targetFile = new File('E:/', 'test.txt'); // 輸入輸出流 FileInputStream fis = null; FileOutputStream fos = null; // 數據緩沖區(qū) byte[] buf = new byte[1]; try { fis = new FileInputStream(sourceFile); fos = new FileOutputStream(targetFile); // 數據讀寫 while (fis.read(buf) != -1) {fos.write(buf);// 當已經上傳了3字節(jié)的文件內容時,模擬網絡中斷了,拋出異常if (targetFile.length() == 3) { position = 3; throw new FileAccessException();} } } catch (FileAccessException e) { keepGoing(sourceFile, targetFile, position); } catch (FileNotFoundException e) { System.out.println('指定文件不存在'); } catch (IOException e) { } finally { try {// 關閉輸入輸出流if (fis != null) fis.close();if (fos != null) fos.close(); } catch (IOException e) {e.printStackTrace(); } } } private static void keepGoing(File source, File target, int position) { try { Thread.sleep(10000); } catch (Exception e) { e.printStackTrace(); } try { RandomAccessFile readFile = new RandomAccessFile(source, 'rw'); RandomAccessFile writeFile = new RandomAccessFile(target, 'rw'); readFile.seek(position); writeFile.seek(position); // 數據緩沖區(qū) byte[] buf = new byte[1]; // 數據讀寫 while (readFile.read(buf) != -1) {writeFile.write(buf); } } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }}class FileAccessException extends Exception {}

總結一下,我們在這次改動當中都做了什么工作:

首先,我們定義了一個變量position,記錄在發(fā)生中斷的時候,已完成讀寫的位置。(這是為了方便,實際來說肯定應該講這個值存到文件或者數據庫等進行持久化) 然后在文件讀寫的while循環(huán)中,我們去模擬一個中斷行為的發(fā)生。這里是當targetFile的文件長度為3個字節(jié)則模擬拋出一個我們自定義的異常。(我們可以想象為實際下載中,已經上傳(下載)了”x”個字節(jié)的內容,這個時候網絡中斷了,那么我們就在網絡中斷拋出的異常中將”x”記錄下來)。 剩下的就如果我們之前說的一樣,在“續(xù)傳”行為開始后,通過RandomAccessFile類來包裝我們的文件,然后通過seek將指針指定到之前發(fā)生中斷的位置進行讀寫就搞定了。(實際的文件下載上傳,我們當然需要將保存的中斷值上傳給服務器,這個方式通常為httpConnection.setRequestProperty(“RANGE”,”bytes=x”);)

在我們這段代碼,開啟”續(xù)傳“行為,即keepGoing方法中:我們起頭讓線程休眠10秒鐘,這正是為了讓我們運行程序看到效果。 現在我們運行程序,那么文件就會開啟“由D盤上傳到E盤的過程”,我們首先點開E盤,會發(fā)現的確多了一個test.txt文件,打開它發(fā)現內容如下:

Java文件斷點續(xù)傳實現原理解析

沒錯,這個時候我們發(fā)現內容只有“abc”。這是在我們預料以內的,因為我們的程序模擬在文件上傳了3個字節(jié)的時候發(fā)生了中斷。

Ok,我們靜靜的等待10秒鐘過去,然后再點開該文件,看看是否能夠成功:

Java文件斷點續(xù)傳實現原理解析

通過截圖我們發(fā)現內容的確已經變成了“abc”,由此也就完成了續(xù)傳。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Java
相關文章:
主站蜘蛛池模板: 正安县| 什邡市| 社旗县| 天全县| 平武县| 清水县| 富锦市| 阜南县| 莲花县| 鄂托克前旗| 怀远县| 深圳市| 三穗县| 乐昌市| 平乐县| 大城县| 资阳市| 成安县| 福鼎市| 普定县| 麦盖提县| 永城市| 新乡县| 文山县| 濮阳市| 望城县| 蓝山县| 常德市| 周宁县| 秀山| 靖边县| 黔南| 天津市| 鄂伦春自治旗| 玛纳斯县| 永川市| 名山县| 哈尔滨市| 张掖市| 弥渡县| 车致|