在学习四大组件之一的service时,正好可以利用asyncTask 和OKhttp来进行断点续传,并在手机的前台显示下载进度。
尝试下载的是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<String,Integer,Integer> { 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); } }
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。