在学习四大组件之一的service时，正好可以利用asyncTask 和OKhttp来进行断点续传，并在手机的前台显示下载进度。
成都创新互联公司主营福建网站建设的网络公司,主营网站建设方案,app软件定制开发,福建h5重庆小程序开发搭建,福建网站营销推广欢迎福建等地区企业咨询
尝试下载的是Oracle官网上的jdk1.7
在AS中使用OKhttp，只需要简单的在app/build.gradle里加入一句就可以了，如下代码，就最后一行加入即可
dependencies {
compile fileTree(dir: 'libs', include: ['*.jar'])
androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', {
exclude group: 'com.android.support', module: 'support-annotations'
})
compile 'com.android.support:appcompat-v7:25.3.1'
compile 'com.android.support.constraint:constraint-layout:1.0.2'
testCompile 'junit:junit:4.12'
compile 'com.squareup.okhttp3:okhttp:3.8.1'
}1、DownloadTask.java
在该类里主要进行了文件是否存在，存在的话是否已经下载完成等判断，还有利用OKhttp进行文件下载，最经典是是在文件写入RandomAccessFile里时，判断的当前状态，如果是isPaused是true,表示点了暂停键，那么就要暂停下载等等判断；还有使用asyncTask的方法，传递进度给前置通知显示下载进度。
package com.yuanlp.servicebestproject;
import android.os.AsyncTask;
import android.os.Environment;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
/**
* Created by 原立鹏 on 2017/7/1.
*/
public class DownloadTask extends AsyncTask {
private static final String TAG = "DownloadTask";
public static final int TYPE_SUCCESS=0;
public static final int TYPE_FAILED=1;
public static final int TYPE_PAUSED=2;
public static final int TYPE_CANCELD=3;
private DownLoadListener listener;
private boolean isCanceld=false;
private boolean isPaused=false;
private int lastProgress;
public DownloadTask(DownLoadListener downloadListener){
this.listener=downloadListener;
}
@Override
protected Integer doInBackground(String... params) {
InputStream is=null;
RandomAccessFile savedFile=null; //RandomAccessFile 用来访问指定的文件的
File file=null;
try{
long downloadLength=0; //记录已经下载的文件中长度
String downloadUrl=params[0];
String fileName=downloadUrl.substring(downloadUrl.lastIndexOf("/")); //获取文件名
String directory= Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath(); //获取文件保存路径
file=new File(directory+fileName); //创建文件
//如果文件存在
if (file.exists()){
downloadLength=file.length(); //获取已经存在的文件大小
}
long contentLength=getContentLength(downloadUrl); //获取文件总大小
if (contentLength==0){
return TYPE_FAILED; //已下载的文件异常，返回失败
}else if (downloadLength==contentLength){
return TYPE_SUCCESS; //说明下载的文件和总长度一样，返回成功
}
OkHttpClient client=new OkHttpClient();
Request request=new Request.Builder()
.header("RANGE","bytes="+downloadLength+"-") //从下载之后的地方开始
.url(downloadUrl)
.build();
Response response=client.newCall(request).execute();
if (response!=null){
is=response.body().byteStream(); //获取response中的输入流
savedFile=new RandomAccessFile(file,"rw"); //开始访问指定的文件
savedFile.seek(downloadLength); //跳过已经下载的文件长度
byte[] b=new byte[1024];
long total=0;
int len;
while ((len=is.read(b))!=-1){ //这个时候说明还没有读取到输入流的最后
if (isCanceld){ //说明取消了下载
return TYPE_FAILED;
}else if (isPaused){
return TYPE_PAUSED;
}else{
total+=len;
savedFile.write(b,0,len);
int progress= (int) ((total+downloadLength)*100/contentLength); //计算下载的百分比
publishProgress(progress); //调用onProgressUpdate()更新下载进度
}
}
response.body().close(); //关闭reponse
return TYPE_SUCCESS; //返回下载成功
}
}catch (Exception e){
e.printStackTrace();
}finally {
try{
if (is!=null){
is.close(); //关闭输入流
}
if (savedFile!=null){
savedFile.close(); //关闭查看文件
}
if (isCanceld&&file!=null){
file.delete(); //如果点击取消下载并且已经下载的文件存在，就删除文件
}
}catch(Exception e){
e.printStackTrace();
}
}
return TYPE_FAILED;
}
/**
* 在doInBackground 里调用ublishProgress时调用此方法，更新UI进度
* @param values
*/
public void onProgressUpdate(Integer... values){
int progress=values[0]; //获取传过来的百分比值
if (progress>lastProgress){
listener.onProgress(progress);
}
}
/**
* 当doInBackground 执行完成时，调用此方法
* @param status
*/
public void onPostExecute(Integer status){
switch (status){
case TYPE_SUCCESS:
listener.onSuccess();
break;
case TYPE_FAILED:
listener.onFailed();
break;
case TYPE_PAUSED:
listener.onPause();
break;
case TYPE_CANCELD:
listener.onCancled();
break;
default:
break;
}
}
/**
* 按下暂停键时调用,暂停下载
*/
public void pausedDownload(){
isPaused=true;
}
public void canceledDownload(){
isCanceld=true;
}
/**
* 根据传入的rul地址，获取文件总长度
* @param url
* @return
*/
public long getContentLength(String url) throws IOException {
OkHttpClient client=new OkHttpClient();
Request request=new Request.Builder()
.url(url)
.build();
Response reponse=client.newCall(request).execute();
if (reponse!=null&&reponse.isSuccessful()){ //成功返回reponse
long contentLength=reponse.body().contentLength(); //获取文件中长度
return contentLength;
}
return 0;
}
}
2、DownloadService.java
在这个里面，主要是根据Mainactivity里的指令，进行调用downloadTask类里的方法，以及调用前置通知，显示进度。
package com.yuanlp.servicebestproject;
import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.app.Service;
import android.content.Intent;
import android.graphics.BitmapFactory;
import android.os.Binder;
import android.os.Environment;
import android.os.IBinder;
import android.support.v4.app.NotificationCompat;
import android.widget.Toast;
import java.io.File;
public class DownloadService extends Service {
private static final String TAG = "DownloadService";
private DownloadTask downloadTask;
private String downloadUrl;
public DownloadService() {
}
@Override
public IBinder onBind(Intent intent) {
return mBinder;
}
private DownLoadListener listener=new DownLoadListener() {
@Override
public void onProgress(int progress) {
getNotifactionManager().notify(1,getNotification("Downloading....",progress));
}
@Override
public void onSuccess() {
downloadTask=null;
//下载成功后，将前台通知关闭，并创建一个下载成功的通告
stopForeground(true);
getNotifactionManager().notify(1,getNotification("Download Success",-1));
Toast.makeText(DownloadService.this,"Download Success",Toast.LENGTH_SHORT).show();
}
@Override
public void onFailed() {
downloadTask=null;
stopForeground(true);
getNotifactionManager().notify(1,getNotification("Down Failed",-1));
Toast.makeText(DownloadService.this,"Down Failed",Toast.LENGTH_SHORT).show();
}
@Override
public void onPause() {
downloadTask=null;
Toast.makeText(DownloadService.this,"Paused",Toast.LENGTH_SHORT).show();
}
@Override
public void onCancled() {
downloadTask=null;
Toast.makeText(DownloadService.this,"Canceled",Toast.LENGTH_SHORT).show();
}
};
private DownloadBinder mBinder=new DownloadBinder();
class DownloadBinder extends Binder{
public void startDownload(String url){
if (downloadTask==null){
downloadUrl=url;
downloadTask=new DownloadTask(listener);
Toast.makeText(DownloadService.this, "Downloading....", Toast.LENGTH_SHORT).show();
downloadTask.execute(downloadUrl);
startForeground(1,getNotification("Downloading...",0));
}
}
public void pauseDownload(){
if (downloadTask==null){
downloadTask.pausedDownload();
}
}
public void cancelDownload(){
if (downloadTask==null){
downloadTask.canceledDownload();
}else{
if (downloadUrl!=null){
String filename=downloadUrl.substring(downloadUrl.lastIndexOf("/"));
String directory= Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath();
File file=new File(directory);
if (file.exists()){
file.delete();
}
getNotifactionManager().cancel(1);
stopForeground(true);
Toast.makeText(DownloadService.this,"Canceled",Toast.LENGTH_SHORT).show();
}
}
}
}
private NotificationManager getNotifactionManager(){
return (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
}
private Notification getNotification(String title,int progress){
Intent intent =new Intent(this,MainActivity.class);
PendingIntent pi=PendingIntent.getActivity(this,0,intent,0);
NotificationCompat.Builder builder=new NotificationCompat.Builder(this);
builder.setSmallIcon(R.mipmap.ic_launcher);
builder.setLargeIcon(BitmapFactory.decodeResource(getResources(),R.mipmap.ic_launcher));
builder.setContentIntent(pi);
builder.setContentTitle(title);
if (progress>=0){
builder.setContentText(progress+"%");
builder.setProgress(100,progress,false);
}
return builder.build();
}
}3、MainActivity.java
主要是进行了开启服务和绑定服务，对应按钮的操作，以及运行时权限申请。
package com.yuanlp.servicebestproject;
import android.Manifest;
import android.content.ComponentName;
import android.content.Intent;
import android.content.ServiceConnection;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.os.IBinder;
import android.support.v4.app.ActivityCompat;
import android.support.v4.content.ContextCompat;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Toast;
public class MainActivity extends AppCompatActivity {
private static final String TAG = "MainActivity";
private DownloadService.DownloadBinder mDownloadBinder;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Intent intent=new Intent(this,DownloadService.class);
startService(intent);
bindService(intent,conn,BIND_AUTO_CREATE);
if (ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.WRITE_EXTERNAL_STORAGE)!= PackageManager.PERMISSION_GRANTED);
ActivityCompat.requestPermissions(MainActivity.this,new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE},1);
}
private ServiceConnection conn=new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
mDownloadBinder= (DownloadService.DownloadBinder) service;
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
/**
* 点击开始下载
* @paam view
*/
public void startService(View view){
Toast.makeText(this,"点击下载",Toast.LENGTH_SHORT).show();
if (mDownloadBinder==null){
return;
}
String url="http://download.java.net/java/jdk9/archive/176/binaries/jdk-9+176_windows-x86_bin.exe";
mDownloadBinder.startDownload(url);
}
public void pauseService(View view){
if (mDownloadBinder==null){
return;
}
mDownloadBinder.pauseDownload();
}
public void cancelSerivce(View view){
if (mDownloadBinder==null){
return;
}
mDownloadBinder.cancelDownload();
}
public void onRequestPermissiosResult(int requestCode,String[] permissions,int[] grantResult){
switch (requestCode){
case 1:
if (grantResult.length>0&&grantResult[0]!=PackageManager.PERMISSION_GRANTED){
Toast.makeText(this,"拒绝授权将无法使用程序",Toast.LENGTH_SHORT).show();
finish();
}
break;
default:
}
}
public void onDestroy(){
super.onDestroy();
unbindService(conn);
}
}
文章标题：用AsyncTask实现断点续传
网页URL：
http://cdweb.net/article/pijgpd.html
