android中多线程下载实例_Android

复制代码 代码如下:

public class MainActivity extends Activity {
// 声明控件
// 路径与线程数量
private EditText et_url, et_num;
// 进度条
public static ProgressBar pb_thread;
// 显示进度的操作
private TextView tv_pb;
// 线程的数量
public static int threadNum = 3;
// 每个线程负责下载的大小
public int blockSize;
public static int threadCount;// 数量
// 访问的path
public String path;
public static boolean flag = true;
// 记录进度条的值
public static int pb_count = 0;
public static Handler handler;
public static final int TEXTVALUE = 1;
public static int pb_num = 0;
public static int size = 0;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
et_url = (EditText) findViewById(R.id.et_path);
et_num = (EditText) findViewById(R.id.et_threadNum);
pb_thread = (ProgressBar) findViewById(R.id.pb_down);
tv_pb = (TextView) findViewById(R.id.tv_pb);
handler = new Handler() {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
switch (msg.what) {
case TEXTVALUE:
System.out.println("-----------------------"
+ MainActivity.pb_count + "//////"
+ MainActivity.size);

// 改变TEXTView
pb_num = (MainActivity.pb_count * 100) / MainActivity.size;
tv_pb.setText("当前进度是+" + pb_num + "%");
break;
default:
break;
}
}
};
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
// getMenuInflater().inflate(R.menu.down, menu);
return true;
}
//下载操作
public void downLoad(View v) {
// 改变变量值：
MainActivity.flag = true;
MainActivity.pb_count = 0;
path = et_url.getText().toString();
String threadNum_et = et_num.getText().toString();
if (TextUtils.isEmpty(path) || TextUtils.isEmpty(threadNum_et)) {
Toast.makeText(this, "不能为空", Toast.LENGTH_LONG).show();
return;
}
Toast.makeText(this, "url:" + path + "--" + threadNum_et,
Toast.LENGTH_LONG).show();
// 转换成数字
threadNum = Integer.valueOf(threadNum_et);
new Thread(new Runnable() {
@Override
public void run() {
try {
// 创建出URL对象
URL url = new URL(path);
// 创建出 HttpURLConnection对象
HttpURLConnection httpURLConnection = (HttpURLConnection) url
.openConnection();
// 设置 发请求发送的方式
httpURLConnection.setRequestMethod("GET");
// 设置请求是否超时时间
httpURLConnection.setConnectTimeout(5000);
// 设置
httpURLConnection
.setRequestProperty("User-Agent",
" Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Trident/6.0)");
// 是否响应成功
if (httpURLConnection.getResponseCode() == 200) {
// 获取文件的大小
size = httpURLConnection.getContentLength();
System.out.println("文件的大小" + size);
// 设置进度条的最大值
pb_thread.setMax(size);
// 创建文件 //保存到SD卡上
// 首先判断是否拥有sdcard
if (Environment.getExternalStorageState().equals(
Environment.MEDIA_MOUNTED)) {
// 获取sdCard文件目录对象
File sdFile = Environment
.getExternalStorageDirectory();
// 创建文件对象
File file = new File(sdFile, "youdao.exe");
RandomAccessFile accessFile = new RandomAccessFile(
file, "rwd");
// 设置文件的大小
accessFile.setLength(size);
// 每个线程下载的大小
blockSize = size / threadNum;
// 开三个线程 操作此文件
for (int i = 1; i <= threadNum; i++) {
// 1 2 3
// 计算出每个线程开始的位置
int startSize = (i - 1) * blockSize;
// 结束位置
int endSize = (i) * blockSize;
// 当线程是最后一个线程的时候
if (i == threadNum) {
// 判断文件的大小是否大于计算出来的结束位置
if (size > endSize) {
// 结束位置 等于 文件的大小
endSize = size;
}
}
// 为每个线程创建一个随机的读取
RandomAccessFile threadAccessFile = new RandomAccessFile(
file, "rwd");
new Thread(new DownLoadThread(i,
threadAccessFile, startSize, endSize,
path)).start();
}
}
}
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}).start();
}
//暂停操作
public void downPause(View v) {
Toast.makeText(this, "暂停", Toast.LENGTH_LONG).show();
this.flag = false;
}
}

复制代码 代码如下:

public class DownLoadThread implements Runnable {
// 下载文件的封装
public RandomAccessFile accessFile;
// 线程下载文件的起始位置
public int startSize;
public int endSize;
// 文件下载的path路径
public String path;
public int threadId; // 线程的标识
public DownLoadThread(int threadId, RandomAccessFile accessFile,
int startSize, int endSize, String path) {
this.threadId = threadId;
this.accessFile = accessFile;
this.startSize = startSize;
this.endSize = endSize;
this.path = path;
}
@Override
public void run() {
// 执行run方法
try {
// 创建文件到SD卡上去
// 首先判断是否拥有sdcard
if (Environment.getExternalStorageState().equals(
Environment.MEDIA_MOUNTED)) {
// 获取sdCard文件目录对象
File sdFile = Environment.getExternalStorageDirectory();
File threadFile = new File(sdFile, threadId + ".txt");
if (threadFile.exists()) {
// 读取该文件的内容
// 创建文件的输入流对象
FileInputStream fis = new FileInputStream(threadFile);
// 采用工具类读取
byte data[] = StreamTools.isToData(fis);
// 转化成字符串
String threadLen = new String(data);
if ((threadLen != null) && (!"".equals(threadLen))) {
startSize = Integer.valueOf(threadLen);
// 解决 416bug的错误
if (startSize > endSize) {
startSize = endSize - 1;
}
}
}
// 创建文件
// 创建URL对象
URL url = new URL(path);
// 创建HttpURLConnection对象
HttpURLConnection httpURLConnection = (HttpURLConnection) url
.openConnection();
// 设置请求的头
httpURLConnection.setRequestMethod("GET");
// 设置请求是否超时时间
httpURLConnection.setConnectTimeout(5000);
// 设置
httpURLConnection
.setRequestProperty("User-Agent",
" Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Trident/6.0)");
// 关键的设置
httpURLConnection.setRequestProperty("Range", "bytes="
+ startSize + "-" + endSize);
// 输出当前线程
System.out.println("当前线程" + threadId + " 下载开始位置:" + startSize
+ " 下载结束位置:" + endSize);
// 响应成功
// 设置随机读取文件的 开始位置
accessFile.seek(startSize);
// 获取相应流对象
InputStream is = httpURLConnection.getInputStream();
// 创建输出流对象
byte buffer[] = new byte[1024];
int len = 0;
int threadTotal = 0;// 每个线程下载后保存记录 /
while ((len = is.read(buffer)) != -1) {
accessFile.write(buffer, 0, len);
threadTotal += len;// 记录你写入的长度 //xml文件
//改变进度条：
setProgressBar(len);
// 通过文件记录文件下载的长度
FileOutputStream fos = new FileOutputStream(threadFile);
fos.write((threadTotal + "").getBytes());
fos.flush();
fos.close();
//发送handler消息
MainActivity.handler.sendEmptyMessage(MainActivity.TEXTVALUE);
if(!MainActivity.flag){
return;
}
}
accessFile.close();
is.close();
System.out.println(threadId + "线程执行完毕");
// 线程操作
synchronized (MainActivity.class) {
MainActivity.threadCount++;
if (MainActivity.threadCount >= MainActivity.threadNum) {
for (int i = 1; i <= MainActivity.threadNum; i++) {
// 获取sdCard上的文件
File deleteFile = new File(sdFile, i + ".txt");
if (deleteFile.exists()) {
// 文件删除
deleteFile.delete();
}
}
}
}
}
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

public synchronized void setProgressBar(int len){
MainActivity.pb_count+=len;
MainActivity.pb_thread.setProgress(MainActivity.pb_count);
}

}

复制代码 代码如下:

public class StreamTools {

public static byte[] isToData(InputStream is) throws IOException{
// 字节输出流
ByteArrayOutputStream bops = new ByteArrayOutputStream();
// 读取数据的缓存区
byte buffer[] = new byte[1024];
// 读取长度的记录
int len = 0;
// 循环读取
while ((len = is.read(buffer)) != -1) {
bops.write(buffer, 0, len);
}
// 把读取的内容转换成byte数组
byte data[] = bops.toByteArray();

bops.flush();
bops.close();
is.close();
return data;
}
}

完整源码

时间： 2024-09-19 09:34:09

android中多线程下载实例_Android的相关文章

android中多线程下载实例

复制代码 代码如下: public class MainActivity extends Activity { // 声明控件 // 路径与线程数量 private EditText et_url, et_num; // 进度条 public static ProgressBar pb_thread; // 显示进度的操作 private TextView tv_pb; // 线程的数量 public static int threadNum = 3; // 每个线程负责下载的大小 public

Android中TelephonyManager用法实例_Android

本文实例讲述了Android中TelephonyManager用法.分享给大家供大家参考,具体如下: 一.概述: TelephonyManager类主要提供了一系列用于访问与手机通讯相关的状态和信息的get方法.其中包括手机SIM的状态和信息.电信网络的状态及手机用户的信息.在应用程序中可以使用这些get方法获取相关数据. TelephonyManager类的对象可以通过Context.getSystemService(Context.TELEPHONY_SERVICE)方法来获得,需要注意的是

Android中OptionMenu用法实例_Android

本文实例讲述了Android中OptionMenu用法.分享给大家供大家参考.具体如下: 1.无需设置布局文件 2.创建一个类,基础Activity 3.重写onOptionsItemSelected方法,在这个方法里面添加菜单项 4.如果需要给菜单项添加单击事件,需要重写onOptionsItemSelected方法 MenuDemoActivity.java如下: package com.yyl; import Android.app.Activity; import Android.os.

在Android中调用WebService实例_Android

某些情况下我们可能需要与Mysql或者Oracle数据库进行数据交互,有些朋友的第一反应就是直接在Android中加载驱动然后进行数据的增删改查.我个人不推荐这种做法,一是手机毕竟不是电脑,操作大量数据费时费电:二是流量贵如金那.我个人比较推荐的做法是使用Java或PHP等开发接口或者编写WebService进行数据库的增删该查,然后Android调用接口或者WebService进行数据的交互.本文就给大家讲解在Android中如何调用远程服务器端提供的WebService. 既然是调用WebS

Android中多线程下载方面的知识点

1.多线程下载 //取得下载文件大小,并构建随机访问文件 HttpURLConnectionn.getConnectionLength(); RandomAccessFile file = new RandomAccessFile("QQWubiSetup.exe","rwd"); file.setLength(filesize);//设置本地文件的长度 //设置每个线程连接的请求属性range为指定范围 HttpURLConnection.setRequestPr

Android实现多线程下载文件的方法_Android

本文实例讲述了Android实现多线程下载文件的方法.分享给大家供大家参考.具体如下: 多线程下载大概思路就是通过Range 属性实现文件分段,然后用RandomAccessFile 来读写文件,最终合并为一个文件 首先看下效果图: 创建工程 ThreadDemo 首先布局文件 threaddemo.xml <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android=&quo

Android版多线程下载 仿下载助手（最新）_Android

首先声明一点: 这里的多线程下载并不是指多个线程下载一个 文件,而是每个线程负责一个文件,今天给大家分享一个多线程下载的 例子.先看一下效果,点击下载开始下载,同时显示下载进度,下载完成,变成程安装,点击安装提示安装应用. 界面效果图: 线程池ThreadPoolExecutor ,先简单学习下这个线程池的使用 /** * Parameters: corePoolSize the number of threads to keep in the pool, even if they are id

Android实现多线程下载文件的方法

本文实例讲述了Android实现多线程下载文件的方法.分享给大家供大家参考.具体如下: 多线程下载大概思路就是通过Range 属性实现文件分段,然后用RandomAccessFile 来读写文件,最终合并为一个文件 首先看下效果图: 创建工程 ThreadDemo 首先布局文件 threaddemo.xml <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android=&quo

class-如何简洁明了的描述Android中活动、实例、对象、类、抽象类、接口之间的关系?

问题描述 如何简洁明了的描述Android中活动.实例.对象.类.抽象类.接口之间的关系? 如何简洁明了的描述Android中活动.实例.对象.类.抽象类.接口之间的关系? 解决方案 实例.对象.类.抽象类.接口是java的语法,和android没有关系. 抽象类是不可以实例化并且包含抽象成员的类,一种特殊的类. 类的实例叫做对象 接口约定了一个类必须实现哪些方法 android的活动(activity)是一个应用程序组件,提供一个屏幕,用户可以用来交互为了完成某项任务 解决方案二: 抽象类和接