Android斷點下載小結
前言
斷點續傳是一個很傳統的話題；如今但凡包含下載功能的軟件，大部分都會有斷點續傳的功能；所以對於斷點續傳的實現，已經 有不少成熟的解決方案；對於Android開發來講更是這樣，github上有大量基於Java語言的斷點續傳框架；有不少庫結合Android Application 生命週期及Sqlite的實現，已經接近完美，使用起來幾行代碼，兩三個回調方法就能夠很方便的實現文件斷點下載的功能。javascript
所以，這裏僅就斷點下載最基礎的知識作一個簡單的總結。java
基本原理
斷點續傳，顧名思義就是下載文件時沒必要每次都從新開始，能夠從以前已經下載好的地方接着下載，這樣既能夠省流量還能省時間。那麼怎麼樣才能作到呢？這就要靠RandomAccessFile 這個類了。android
/** * Allows reading from and writing to a file in a random-access manner. This is * different from the uni-directional sequential access that a * {@link FileInputStream} or {@link FileOutputStream} provides. If the file is * opened in read/write mode, write operations are available as well. The * position of the next read or write operation can be moved forwards and * backwards after every operation. */
public class RandomAccessFile implements DataInput, DataOutput, Closeable {
.......
}複製代碼
這是RandomAccessFile 這個類的定義。git
那麼怎麼使用這個類呢？下面來看一個簡單的demo github
public class RandomIoDemo {
private static int len;
public static void main(String[] args) throws Exception {
// 在磁盤中預先建立一個文件，分配預約的空間
RandomAccessFile raf = new RandomAccessFile("result.txt", "rwd");
raf.setLength(1024); // 預分配 1kb 的文件空間
raf.close();
// 所要寫入的文件內容
String s1 = "第一個字符串的內容";
String s2 = "第二個字符串的內容";
String s3 = "第三個字符串的內容";
String s4 = "第四個字符串的內容";
String s5 = "第五個字符串的內容";
len = s1.getBytes().length;
// 利用多線程同時寫入一個文件
new FileWriteThread(0, s1.getBytes()).start();
new FileWriteThread(len, s2.getBytes()).start();
new FileWriteThread(len * 2, s3.getBytes()).start();
new FileWriteThread(len * 3, s4.getBytes()).start();
new FileWriteThread(len * 4, s5.getBytes()).start();
}
// 利用線程在文件的指定位置寫入指定數據
private static class FileWriteThread extends Thread {
private int skip;
private byte[] content;
/** * * @param skip 寫入文件須要跳過的字節數 * @param content 寫入到文件的內容 */
private FileWriteThread(int skip, byte[] content) {
this.skip = skip;
this.content = content;
}
public void run() {
try {
FileChannel channel = new RandomAccessFile("result.txt", "rwd").getChannel();
MappedByteBuffer buffer = channel.map(FileChannel.MapMode.READ_WRITE, skip, len);
buffer.put(content);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}複製代碼
這個一個簡單的Java 實現，功能很簡單，就是把s1~s5，這幾個字符串的內容寫入到result.txt 這個文本文件中去；爲了方便起見這幾個s1~s5這幾個字符串的大小都是相同的；你可能會說這樣一個功能很簡單呀，用StringBuffer就能夠實現，是能夠；可是若是s1~s5 這幾個字符串的長度很長，或者說要寫入到最終文件的內容不是字符串，而是音頻、圖片流之類的，那麼使用RandomAccessFile就能夠展示出他的優點了。一句話歸納來講，RandomAccessFile 能夠實現文件從特定的位置進行讀寫。服務器
基於OKHttp的斷點下載簡單實現
好了，RandomAccessFile只是提供了一種文件類型，方便咱們進行斷點續傳，那麼若是要實現斷點下載的功能，咱們須要思考如下兩個問題。多線程
首先，全部服務器上的文件都支持斷點下載嗎？怎麼判斷一個文件是否支持斷點下載？。
其次，若是一個文件支持斷點下載，那麼怎麼告知服務器端，我要從哪一個字節開始下載？app
好了，這兩個疑問能夠經過下面的代碼獲得答案：框架
public class DownloadHelper {
public static OkHttpClient mClient = new OkHttpClient();
private static Call mCall;
public static void startDownload(int startPoint, int endPoint, Handler mHandler) {
Request request = new Request.Builder()
.url(Constants.PACKAGE_URL)
.header("RANGE", "bytes=" + startPoint + "-" + endPoint)
.build();
mCall = mClient.newCall(request);
mCall.enqueue(new OkHttpCallback(startPoint, mHandler));
}
public static void startDownload(int startPoint, Handler mHandler) {
Request request = new Request.Builder()
.url(Constants.PACKAGE_URL)
.header("RANGE", "bytes=" + startPoint + "-")
.build();
mCall = mClient.newCall(request);
mCall.enqueue(new OkHttpCallback(startPoint, mHandler));
}
public static void cancelDownload() {
if (mCall != null) {
mCall.cancel();
}
}
}複製代碼
能夠看到，經過設置Request對象的header方法的RANGE就能夠告知服務器端開始下載的節點；咱們再看OkHttpCallback的實現dom
public class OkHttpCallback implements Callback {
private Handler mHandler;
private int startPoint;
public OkHttpCallback(int startPoint, Handler mHandler) {
this.startPoint = startPoint;
this.mHandler = mHandler;
}
@Override
public void onFailure(Call call, IOException e) {
mHandler.sendEmptyMessage(100);
}
@Override
public void onResponse(Call call, Response response) {
if (response.code() != HttpURLConnection.HTTP_PARTIAL) {
//返回code非206 ，不支持斷點續傳
mHandler.sendEmptyMessage(400);
return;
}
FileChannel fileChannel = null;
ResponseBody body = response.body();
int total = (int) body.contentLength();
int currentLength = 0;
InputStream inputStream = body.byteStream();
try {
RandomAccessFile randomAccessFile = new RandomAccessFile(Constants.FILE_PATH, "rws");
fileChannel = randomAccessFile.getChannel();
Log.e(TAG, "onResponse: startPoint=" + startPoint + " ,total=" + total);
MappedByteBuffer mappedByteBuffer = fileChannel.map(FileChannel.MapMode.READ_WRITE, startPoint, total);
int len;
byte[] buffer = new byte[1024];
while ((len = inputStream.read(buffer)) != -1) {
currentLength = currentLength + len;
mappedByteBuffer.put(buffer, 0, len);
Message msg = Message.obtain();
msg.arg1 = total;
msg.arg2 = currentLength;
msg.what = 300;
mHandler.sendMessage(msg);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
inputStream.close();
if (fileChannel != null) {
fileChannel.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}複製代碼
在onResponse 回調方法中咱們能夠看到，當咱們在以前的head中添加了RANGE字段，可是若是返回的http code不是206是，咱們就能夠肯定所請求的文件是不支持斷點下載的。
如今就能夠很是方便的實現一個簡單的斷點續傳功能了。
class MyHandler extends Handler {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
switch (msg.what) {
case 400:
Toast.makeText(mContext, "不支持斷點續傳", Toast.LENGTH_SHORT).show();
break;
case 100:
Toast.makeText(mContext, "fail", Toast.LENGTH_SHORT).show();
break;
case 300:
int total = msg.arg1;
int current = msg.arg2;
if (!isPause && !isStop) {
totalValue = current + breakPointValue;
int percent = (int) (totalValue * 100f / (total + breakPointValue));
if (percent < 100) {
mProgressBar.setProgress(percent);
progressValue.setText(String.valueOf(percent));
} else {
Intent intent = new Intent(Intent.ACTION_VIEW);
intent.setDataAndType(Uri.parse("file://" + Constants.FILE_PATH),
"application/vnd.android.package-archive");
mContext.startActivity(intent);
resetStatus();
}
}
break;
default:
break;
}
}
}
isPause=true;
pause.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
if (isPause) {
pause.setImageResource(R.drawable.ic_pause_circle_outline_black_24dp);
DownloadHelper.startDownload(breakPointValue, mMyHandler);
} else {
pause.setImageResource(R.drawable.ic_play_circle_outline_black_24dp);
DownloadHelper.cancelDownload();
breakPointValue = totalValue;
}
isPause = !isPause;
}
});複製代碼
breakPointValue 這個變量記錄了每次暫停下載時，斷點位置已完成的下載量，第一次開始下載時他的初始值爲0，所以便開始從頭下載這個文件，並經過Handler依次累加已經完成的下載量totalValue， 同時更新下載進度；當暫停時，中止下載任務；breakPointValue的值就是此刻的總下載量，再次點擊繼續下載，此時breakPointValue就會從上次斷掉的位置開始新一次的下載任務；依次類推直到下載完成。這樣，就簡單的完成了一個文件的斷點下載任務。
這個實現很簡單，這裏再總結一下須要注意的地方：
使用APK 類型的文件，做爲斷點下載的測試很是有針對性，若是斷點續傳的過程當中數據錯誤或丟失，將致使最終下載的完成的APK 文件破損，沒法安裝。
在Http的ResponseBody中，contentLength 的值不是一成不變的，他每次返回的值，並非當前所請求文件實際的大小，而是這次請求可以傳輸的大小，也就是從文件總大小-RANGE 所包含的大小。所以，須要每次把上一次暫停時breakPointValue的值做爲下一次累加值的基數。
好了，這就是關於斷點下載的簡單總結。另附Github 源碼地址，有須要的能夠查看。
- 1. Android——斷點續傳（下載）
- 2. android 斷點下載---XUtils
- 3. Android之斷點續傳下載
- 4. Android多線程斷點續傳下載
- 5. android多線程斷點下載
- 6. Android斷點續傳下載器JarvisDownloader
- 7. android 斷點續傳下載簡介
- 8. Android多線程 斷點下載文件
- 9. Android 中 Service+Notification 斷點續傳下載
- 10. android 多線程斷點續傳下載
- 更多相關文章...
- • MySQL下載步驟詳解 - MySQL教程
- • Wireshark下載安裝和使用教程 - TCP/IP教程
- • Docker容器實戰(七) - 容器眼光下的文件系統
- • IDEA下SpringBoot工程配置文件沒有提示
-
每一个你不满意的现在，都有一个你没有努力的曾经。