电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術(shù)文章
文章詳情頁

Android多線程斷點(diǎn)續(xù)傳下載實(shí)現(xiàn)代碼

瀏覽:3日期:2022-09-21 16:14:05

學(xué)習(xí)了多線程下載,而且可以斷點(diǎn)續(xù)傳的邏輯,線程數(shù)量可以自己選擇,但是線程數(shù)量過多手機(jī)就承受不起,導(dǎo)致閃退,好在有斷點(diǎn)續(xù)傳。

步驟寫在了代碼的注釋里。大概就是獲取服務(wù)器文件的大小,在本地新建一個相同大小的文件用來申請空間,然后將服務(wù)器的文件讀下來寫到申請的文件中去。若開多線程,將文件分塊,計(jì)算每個線程下載的開始位置和結(jié)束位置。若斷點(diǎn)傳輸,則保存斷開后下載的位置,下次將此位置賦給開始下載的位置即可。細(xì)節(jié)見代碼。

下面是效果圖:

Android多線程斷點(diǎn)續(xù)傳下載實(shí)現(xiàn)代碼

布局文件activity_main.xml:

<?xml version='1.0' encoding='utf-8'?><android.support.constraint.ConstraintLayout xmlns:android='http://schemas.android.com/apk/res/android' xmlns:tools='http://schemas.android.com/tools' android:layout_width='match_parent' android:layout_height='match_parent' tools:context='.MainActivity'> <LinearLayout android:layout_width='match_parent' android:layout_height='match_parent' android:orientation='vertical'> <EditText android: android:layout_width='match_parent' android:layout_height='wrap_content' android:hint='請輸入下載路徑' android:text='http://10.173.29.234/test.exe' /> <EditText android: android:layout_width='match_parent' android:layout_height='wrap_content' android:hint='請輸入線程數(shù)量' /> <Button android:layout_width='wrap_content' android:layout_height='wrap_content' android:onClick='click' android:text='下載' /> <LinearLayout android: android:layout_width='match_parent' android:layout_height='match_parent' android:background='#455eee' android:orientation='vertical'> </LinearLayout> </LinearLayout></android.support.constraint.ConstraintLayout>

創(chuàng)建布局文件,用來動態(tài)顯示每個線程的進(jìn)度條

layout.xml:

<?xml version='1.0' encoding='utf-8'?><ProgressBar xmlns:android='http://schemas.android.com/apk/res/android' android: android:layout_width='match_parent' android:layout_height='wrap_content' />

MainActivity.java:

import...;public class MainActivity extends AppCompatActivity { private EditText et_path; private EditText et_threadCount; private LinearLayout ll_pb; private String path; private static int runningThread;// 代表正在運(yùn)行的線程 private int threadCount; private List<ProgressBar> pbList;//集合存儲進(jìn)度條的引用 @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); et_path = findViewById(R.id.et_path); et_threadCount = findViewById(R.id.et_threadCount); ll_pb = findViewById(R.id.ll_pb); //添加一個進(jìn)度條的引用 pbList = new ArrayList<ProgressBar>(); } //點(diǎn)擊按鈕實(shí)現(xiàn)下載邏輯 public void click(View view) { //獲取下載路徑 path = et_path.getText().toString().trim(); //獲取線程數(shù)量 String threadCounts = et_threadCount.getText().toString().trim(); //移除以前的進(jìn)度條添加新的進(jìn)度條 ll_pb.removeAllViews(); threadCount = Integer.parseInt(threadCounts); pbList.clear(); for (int i = 0; i < threadCount; i++) { ProgressBar v = (ProgressBar) View.inflate(getApplicationContext(), R.layout.layout, null); //把v添加到幾何中 pbList.add(v); //動態(tài)獲取進(jìn)度條 ll_pb.addView(v); } //java邏輯移植 new Thread() { @Override public void run() {/*************/System.out.println('你好');try { URL url = new URL(path); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod('GET'); conn.setConnectTimeout(5000); int code = conn.getResponseCode(); if (code == 200) { int length = conn.getContentLength(); // 把運(yùn)行線程的數(shù)量賦值給runningThread runningThread = threadCount; System.out.println('length=' + length); // 創(chuàng)建一個和服務(wù)器的文件一樣大小的文件,提前申請空間 RandomAccessFile randomAccessFile = new RandomAccessFile(getFileName(path), 'rw'); randomAccessFile.setLength(length); // 算出每個線程下載的大小 int blockSize = length / threadCount; // 計(jì)算每個線程下載的開始位置和結(jié)束位置 for (int i = 0; i < length; i++) { int startIndex = i * blockSize;// 開始位置 int endIndex = (i + 1) * blockSize;// 結(jié)束位置 // 特殊情況就是最后一個線程 if (i == threadCount - 1) {// 說明是最后一個線程endIndex = length - 1; } // 開啟線程去服務(wù)器下載 DownLoadThread downLoadThread = new DownLoadThread(startIndex, endIndex, i); downLoadThread.start(); } }} catch (MalformedURLException e) { // TODO Auto-generated catch block e.printStackTrace();} catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace();}/*************/ } }.start(); } private class DownLoadThread extends Thread { // 通過構(gòu)造方法吧每個線程的開始位置和結(jié)束位置傳進(jìn)來 private int startIndex; private int endIndex; private int threadID; private int PbMaxSize;//代表當(dāng)前下載(進(jìn)度條)的最大值 private int pblastPosition;//如果中斷過,這是進(jìn)度條上次的位置 public DownLoadThread(int startIndex, int endIndex, int threadID) { this.startIndex = startIndex; this.endIndex = endIndex; this.threadID = threadID; } @Override public void run() { // 實(shí)現(xiàn)去服務(wù)器下載文件 try {//計(jì)算進(jìn)度條最大值PbMaxSize = endIndex - startIndex;URL url = new URL(path);HttpURLConnection conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod('GET');conn.setConnectTimeout(5000);// 如果中間斷過,接著上次的位置繼續(xù)下載,聰慧文件中讀取上次下載的位置File file = new File(getFileName(path) + threadID + '.txt');if (file.exists() && file.length() > 0) { FileInputStream fis = new FileInputStream(file); BufferedReader bufr = new BufferedReader(new InputStreamReader(fis)); String lastPosition = bufr.readLine(); int lastPosition1 = Integer.parseInt(lastPosition); //賦值給進(jìn)度條位置 pblastPosition = lastPosition1 - startIndex; // 改變一下startIndex的值 startIndex = lastPosition1 + 1; System.out.println('線程id:' + threadID + '真實(shí)下載的位置:' + lastPosition + '-------' + endIndex); bufr.close(); fis.close();}conn.setRequestProperty('Range', 'bytes=' + startIndex + '-' + endIndex);int code = conn.getResponseCode();if (code == 206) { // 隨機(jī)讀寫文件對象 RandomAccessFile raf = new RandomAccessFile(getFileName(path), 'rw'); // 每個線程從自己的位置開始寫 raf.seek(startIndex); InputStream in = conn.getInputStream(); // 把數(shù)據(jù)寫到文件中 int len = -1; byte[] buffer = new byte[1024]; int totle = 0;// 代表當(dāng)前線程下載的大小 while ((len = in.read(buffer)) != -1) { raf.write(buffer, 0, len); totle += len; // 實(shí)現(xiàn)斷點(diǎn)續(xù)傳就是把當(dāng)前線程下載的位置保存起來,下次再下載的時候按照上次下載的位置繼續(xù)下載 int currentThreadPosition = startIndex + totle;// 存到一個txt文本中 // 用來存儲當(dāng)前線程當(dāng)前下載的位置 RandomAccessFile raff = new RandomAccessFile(getFileName(path) + threadID + '.txt', 'rwd'); raff.write(String.valueOf(currentThreadPosition).getBytes()); raff.close(); //設(shè)置進(jìn)度條當(dāng)前的進(jìn)度 pbList.get(threadID).setMax(PbMaxSize); pbList.get(threadID).setProgress(pblastPosition + totle); } raf.close(); System.out.println('線程ID:' + threadID + '下載完成'); // 將產(chǎn)生的txt文件刪除,每個線程下載完成的具體時間不知道 synchronized (DownLoadThread.class) { runningThread--; if (runningThread == 0) { //說明線程執(zhí)行完畢 for (int i = 0; i < threadCount; i++) {File filedel = new File(getFileName(path) + i + '.txt');filedel.delete(); } } }} } catch (MalformedURLException e) {// TODO Auto-generated catch blocke.printStackTrace(); } catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace(); } } } public String getFileName(String path) { int start = path.lastIndexOf('/') + 1; String subString = path.substring(start); String fileName = '/data/data/com.lgqrlchinese.heima76android_11_mutildownload/' + subString; return fileName; }}

在清單文件中添加以下權(quán)限

<uses-permission android:name='android.permission.INTERNET'/> <uses-permission android:name='android.permission.WRITE_EXTERNAL_STORAGE'/>

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Android
相關(guān)文章:
主站蜘蛛池模板: 无菌实验室规划装修设计-一体化实验室承包-北京洁净净化工程建设施工-北京航天科恩实验室装备工程技术有限公司 | 广域铭岛Geega(际嘉)工业互联网平台-以数字科技引领行业跃迁 | 磁力反应釜,高压釜,实验室反应釜,高温高压反应釜-威海自控反应釜有限公司 | 玻璃钢板-玻璃钢防腐瓦-玻璃钢材料-广东壹诺 | 标准光源箱|对色灯箱|色差仪|光泽度仪|涂层测厚仪_HRC大品牌生产厂家 | 智能汉显全自动量热仪_微机全自动胶质层指数测定仪-鹤壁市科达仪器仪表有限公司 | 医用酒精_84消毒液_碘伏消毒液等医用消毒液-漓峰消毒官网 | 展厅设计-展馆设计-专业企业展厅展馆设计公司-昆明华文创意 | Jaeaiot捷易科技-英伟达AI显卡模组/GPU整机服务器供应商 | ZHZ8耐压测试仪-上海胜绪电气有限公司 | 云南外加剂,云南速凝剂,云南外加剂代加工-普洱澜湄新材料科技有限公司 | 定制异形重型钢格栅板/钢格板_定做踏步板/排水沟盖板_钢格栅板批发厂家-河北圣墨金属制品有限公司 | 北京开源多邦科技发展有限公司官网| 赛默飞Thermo veritiproPCR仪|ProFlex3 x 32PCR系统|Countess3细胞计数仪|371|3111二氧化碳培养箱|Mirco17R|Mirco21R离心机|仟诺生物 | IIS7站长之家-站长工具-爱网站请使用IIS7站长综合查询工具,中国站长【WWW.IIS7.COM】 | 合肥抖音SEO网站优化-网站建设-网络推广营销公司-百度爱采购-安徽企匠科技 | 密集柜_档案密集柜_智能密集架_密集柜厂家_密集架价格-智英伟业 密集架-密集柜厂家-智能档案密集架-自动选层柜订做-河北风顺金属制品有限公司 | 超声骨密度仪-骨密度检测仪-经颅多普勒-tcd仪_南京科进实业有限公司 | 南京兰江泵业有限公司-水解酸化池潜水搅拌机-絮凝反应池搅拌机-好氧区潜水推进器 | 水冷式工业冷水机组_风冷式工业冷水机_水冷螺杆冷冻机组-深圳市普威机械设备有限公司 | POS机办理_个人POS机免费领取 - 银联POS机申请首页 | 南昌旅行社_南昌国际旅行社_南昌国旅在线 | 江西自考网-江西自学考试网| 环讯传媒,永康网络公司,永康网站建设,永康小程序开发制作,永康网站制作,武义网页设计,金华地区网站SEO优化推广 - 永康市环讯电子商务有限公司 | 粉末冶金-粉末冶金齿轮-粉末冶金零件厂家-东莞市正朗精密金属零件有限公司 | 短信通106短信接口验证码接口群发平台_国际短信接口验证码接口群发平台-速度网络有限公司 | 智慧旅游_智慧景区_微景通-智慧旅游景区解决方案提供商 | 换网器_自动换网器_液压换网器--郑州海科熔体泵有限公司 | 校园气象站_超声波气象站_农业气象站_雨量监测站_风途科技 | 长沙一级消防工程公司_智能化弱电_机电安装_亮化工程专业施工承包_湖南公共安全工程有限公司 | 台式恒温摇床价格_大容量恒温摇床厂家-上海量壹科学仪器有限公司 | 桑茶-七彩贝壳桑叶茶 长寿茶 | 尾轮组_头轮组_矿用刮板_厢式刮板机_铸石刮板机厂家-双驰机械 | 广州中央空调回收,二手中央空调回收,旧空调回收,制冷设备回收,冷气机组回收公司-广州益夫制冷设备回收公司 | 气动隔膜阀_气动隔膜阀厂家_卫生级隔膜阀价格_浙江浙控阀门有限公司 | 蜘蛛车-高空作业平台-升降机-高空作业车租赁-臂式伸缩臂叉装车-登高车出租厂家 - 普雷斯特机械设备(北京)有限公司 | 水厂自动化-水厂控制系统-泵站自动化|控制系统-闸门自动化控制-济南华通中控科技有限公司 | pos机办理,智能/扫码/二维码/微信支付宝pos机-北京万汇通宝商贸有限公司 | 月嫂_保姆_育婴_催乳_母婴护理_产后康复_养老护理-吉祥到家家政 硫酸亚铁-聚合硫酸铁-除氟除磷剂-复合碳源-污水处理药剂厂家—长隆科技 | 小型单室真空包装机,食品单室真空包装机-百科 | 宁波普瑞思邻苯二甲酸盐检测仪,ROHS2.0检测设备,ROHS2.0测试仪厂家 |