Android實現多任務多線程支持斷點續傳的下載軟件

多任務多線程下載並不麻煩，只要思路清晰，邏輯清晰正確，是很好實現的。我最後遇到的糾結問題是數據庫的操作上，我是拿數據庫來存儲下載信息的，所以在數據庫的關閉上遇到了麻煩。上面那個版本是建立在前面N個demo的基礎之上的，在這裡我寫下來的唯一目的就是能夠以一個清晰的思路寫清楚，同時讓大家看明白。

運行效果圖：

一、首先是數據庫，

數據庫五個字段：

任務的ID：_id

線程ID：thread_id

線程下載的起始位置：start_pos

這個線程下載的結束位置：end_pos

這個任務已經下載的大小：compelete_size

這個任務的下載地址：urlString

1. create table download_info(_id integer PRIMARY KEY AUTOINCREMENT, thread_id integer,start_pos integer, end_pos integer, compelete_size integer,urlString char)

二、操作數據庫的類。在實現斷點續傳下載的時候，我是把線程每次下載結束後的當前任務信息都保存到數據庫裡面一次，相當於每次一個線程下載一次，就給當前任務拍個照片，把當前信息存到數據庫裡面。這樣一旦暫停，或者退出程序，下次再下載的時候，直接從數據庫裡面讀數據，然後在這個數據的基礎上繼續下載就行。

1. package com.song.dao;
3. import java.util.ArrayList;
4. import java.util.List;
6. import Android.content.Context;
7. import android.database.Cursor;
8. import android.database.sqlite.SQLiteDatabase;
10. import com.song.db.DBHelper;
11. import com.song.entity.ThreadDownloadInfo;
13. /**
14. * 操作數據庫
15. * @author song
16. *
17. */
18. public class DownloadDao
19. {
20. private DBHelper dbHelper;
22. public DownloadDao(Context context)
23. {
24. dbHelper = new DBHelper(context);
25. }
27. /**
28. *
29. * 判斷數據庫中是不是有對應這個urlString的信息
30. *
31. * @return
32. */
33. public boolean unhasInfo(String urlString)
34. {
35. SQLiteDatabase db = dbHelper.getReadableDatabase();
36. String sql = "select count(*) from download_info where urlString=?";
37. Cursor cursor = db.rawQuery(sql, new String[]{urlString});
38. cursor.moveToFirst();
39. int count = cursor.getInt(0);
40. cursor.close();
41. return count == 0;
42. }
44. /**
45. * 把線程信息保存在數據庫裡面
46. * @param infos
47. */
48. public void saveInfos(List<ThreadDownloadInfo> infos)
49. {
50. SQLiteDatabase db = dbHelper.getWritableDatabase();
51. for (ThreadDownloadInfo info : infos)
52. {
53. String sql = "insert into download_info(thread_id,start_pos, end_pos,compelete_size,urlString) values (?,?,?,?,?)";
54. Object[] bindArgs =
55. { info.getThreadId(), info.getStartPos(), info.getEndPos(),
56. info.getCompleteSize() ,info.getUrlString()};
57. db.execSQL(sql, bindArgs);
58. }
60. }
62. /**
63. * 暫停之後，把當前數據保存在數據庫中，該方法是從數據庫中查詢數據
64. *
65. * @return
66. */
67. public List<ThreadDownloadInfo> getInfos(String urlString)
68. {
69. List<ThreadDownloadInfo> list = new ArrayList<ThreadDownloadInfo>();
70. SQLiteDatabase db = dbHelper.getReadableDatabase();
71. String sql = "select thread_id, start_pos, end_pos,compelete_size, urlString from download_info where urlString=?";
72. Cursor cursor = db.rawQuery(sql, new String[]{urlString});
73. while (cursor.moveToNext())
74. {
75. ThreadDownloadInfo info = new ThreadDownloadInfo(cursor.getInt(0),
76. cursor.getInt(1), cursor.getInt(2), cursor.getInt(3),cursor.getString(4));
77. list.add(info);
78. }
79. cursor.close();
80. return list;
81. }
83. /**
84. * 把當前的數據照片 存進數據庫中
85. *
86. * @param threadId
87. * @param completeSize
88. */
89. public void updateInfo(int threadId, int completeSize,String urlString)
90. {
91. SQLiteDatabase db = dbHelper.getWritableDatabase();
92. String sql = "update download_info set compelete_size=? where thread_id=? and urlString=?";
93. Object[] bindArgs =
94. { completeSize, threadId,urlString };
95. db.execSQL(sql, bindArgs);
96. }
98. /**
99. * 關閉數據庫
100. */
101. public void closeDB()
102. {
103. dbHelper.close();
104. }
106. /**
107. * 下載完成之後，從數據庫裡面把這個任務的信息刪除
108. * 不同的任務對應不同的urlString
109. * @param urlString
110. */
111. public void deleteInfos(String urlString)
112. {
113. SQLiteDatabase db=dbHelper.getWritableDatabase();
114. db.delete("download_info", "urlString=?", new String[]{urlString});
115. }
116. }

數據庫助手類DBhelper：

1. package com.song.db;
3. import android.content.Context;
4. import android.database.sqlite.SQLiteDatabase;
5. import android.database.sqlite.SQLiteOpenHelper;
6. import android.util.Log;
8. /**
9. * 數據庫助手類
10. * @author song
11. *
12. */
13. public class DBHelper extends SQLiteOpenHelper
14. {
16. public DBHelper(Context context)
17. {
18. super(context, "download.db", null, 1);
19. }
21. @Override
22. public void onCreate(SQLiteDatabase db)
23. {
24. Log.v("TAG", "DBHelper-->conCreate()");
25. String sql = "create table download_info(_id integer PRIMARY KEY AUTOINCREMENT, thread_id integer,start_pos integer, end_pos integer, compelete_size integer,urlString char)";
26. db.execSQL(sql);
27. }
29. @Override
30. public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion)
31. {
33. }
35. }