안 드 로 이 드 는 AsyncTask 를 사용 하여 다 중 스 레 드 다운로드 인 스 턴 스 를 실현 합 니 다.
01 효과 도
02 핵심 클래스-DownloadTask.class
public class DownloadTask extends AsyncTask<String, Integer, Integer> {
public static final int TYPE_SUCCESS = 0;
public static final int TYPE_FAILURE = 1;
public static final int TYPE_PAUSE = 2;
public static final int TYPE_CANCEL = 3;
public int positionDownload;
private boolean isPaused = false;
private boolean isCancelled = false;
private DownloadListener downloadListener;
private int lastProgress;
public DownloadTask(DownloadListener downloadListener){
this.downloadListener = downloadListener;
}
public void setDownloadListener(DownloadListener downloadListener){
this.downloadListener = downloadListener;
}
@Override
protected Integer doInBackground(String... params) {
InputStream is = null;
RandomAccessFile savedFile = null;
File file = null;
long downloadLength = 0;
String downloadUrl = params[0];
positionDownload = Integer.parseInt(params[1]);
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_FAILURE;
} else if(contentLength == downloadLength){
return TYPE_SUCCESS;
}
OkHttpClient client = new OkHttpClient();
Request request = new Request.Builder()
.addHeader("RANGE", "bytes="+downloadLength+"-")
.url(downloadUrl)
.build();
try {
Response response = client.newCall(request).execute();
if(response != null){
is = response.body().byteStream();
savedFile = new RandomAccessFile(file, "rw");
savedFile.seek(downloadLength);
byte[] buffer = new byte[1024];
int total = 0;
int length;
while((length = is.read(buffer)) != -1){
if(isCancelled){
response.body().close();
return TYPE_CANCEL;
} else if(isPaused) {
response.body().close();
return TYPE_PAUSE;
}
total += length;
savedFile.write(buffer, 0, length);
int progress = (int) ((total + downloadLength) * 100 / contentLength);
int currentDownload = (int) (total + downloadLength);
publishProgress(positionDownload, progress, currentDownload, (int) contentLength);
}
response.body().close();
return TYPE_SUCCESS;
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if(is != null) is.close();
if(savedFile != null) savedFile.close();
if(isCancelled && file != null) file.delete();
} catch (IOException e) {
e.printStackTrace();
}
}
return TYPE_FAILURE;
}
@Override
protected void onProgressUpdate(Integer... values) {
int progress = values[1];
if(progress > lastProgress){
downloadListener.onProgress(values[0], progress, values[2], values[3]);
lastProgress = progress;
}
}
@Override
protected void onPostExecute(Integer status) {
switch (status){
case TYPE_SUCCESS:
downloadListener.onSuccess(positionDownload);
break;
case TYPE_FAILURE:
downloadListener.onFailure();
break;
case TYPE_PAUSE:
downloadListener.onPause();
break;
case TYPE_CANCEL:
downloadListener.onCancel();
break;
}
}
public void pauseDownload(){
isPaused = true;
}
public void cancelDownload(){
isCancelled = true;
}
private long getContentLength(String downloadUrl) {
OkHttpClient client = new OkHttpClient();
Request request = new Request.Builder()
.url(downloadUrl)
.build();
Response response = null;
try {
response = client.newCall(request).execute();
if(response != null && response.isSuccessful()){
long contentLength = response.body().contentLength();
response.body().close();
return contentLength;
}
} catch (IOException e) {
e.printStackTrace();
}
return 0;
}
}
public class DownloadService extends Service {
private Map<String, DownloadTask> downloadTaskMap = new HashMap<>();
private DownloadBinder mBinder = new DownloadBinder();
@Override
public IBinder onBind(Intent intent) {
return mBinder;
}
private Notification getNotification(String title, int progress) {
Intent intent = new Intent(this, MainActivity.class);
PendingIntent pendingIntent = 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(pendingIntent);
builder.setContentTitle(title);
if(progress > 0){
builder.setContentText(progress + "%");
builder.setProgress(100, progress, false);
}
return builder.build();
}
private NotificationManager getNotificationManager() {
return (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
}
class DownloadBinder extends Binder {
public void startDownload(String url, int position, DownloadListener listener){
if(!downloadTaskMap.containsKey(url)){
DownloadTask downloadTask = new DownloadTask(listener);
downloadTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, url, position+"");
downloadTaskMap.put(url, downloadTask);
if(downloadTaskMap.size() == 1){
startForeground(1, getNotification(" " + downloadTaskMap.size(), -1));
} else{
getNotificationManager().notify(1, getNotification(" " + downloadTaskMap.size(), -1));
}
}
}
public void updateDownload(String url, DownloadListener listener){
if(downloadTaskMap.containsKey(url)){
DownloadTask downloadTask = downloadTaskMap.get(url);
if(downloadTask != null){
downloadTask.setDownloadListener(listener);
}
}
}
public void pauseDownload(String url){
if(downloadTaskMap.containsKey(url)){
DownloadTask downloadTask = downloadTaskMap.get(url);
if(downloadTask != null){
downloadTask.pauseDownload();
}
downloadTaskMap.remove(url);
if(downloadTaskMap.size() > 0){
getNotificationManager().notify(1, getNotification(" " + downloadTaskMap.size(), -1));
} else {
stopForeground(true);
getNotificationManager().notify(1, getNotification(" ", -1));
}
}
}
public void downloadSuccess(String url){
if(downloadTaskMap.containsKey(url)){
DownloadTask downloadTask = downloadTaskMap.get(url);
downloadTaskMap.remove(url);
if(downloadTask != null){
downloadTask = null;
}
if(downloadTaskMap.size() > 0){
getNotificationManager().notify(1, getNotification(" " + downloadTaskMap.size(), -1));
} else {
stopForeground(true);
getNotificationManager().notify(1, getNotification(" ", -1));
}
}
}
public boolean isDownloading(String url){
if(downloadTaskMap.containsKey(url)){
return true;
}
return false;
}
public void cancelDownload(String url){
if(downloadTaskMap.containsKey(url)){
DownloadTask downloadTask = downloadTaskMap.get(url);
if(downloadTask != null){
downloadTask.cancelDownload();
}
downloadTaskMap.remove(url);
if(downloadTaskMap.size() > 0){
getNotificationManager().notify(1, getNotification(" " + downloadTaskMap.size(), -1));
} else {
stopForeground(true);
getNotificationManager().notify(1, getNotification(" ", -1));
}
}
if(url != null){
String fileName = url.substring(url.lastIndexOf("/"));
String directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath();
File file = new File(directory + fileName);
if(file.exists()){
file.delete();
Toast.makeText(DownloadService.this, "Deleted", Toast.LENGTH_SHORT).show();
}
}
}
}
}
다운로드 주소
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Kotlin의 기초 - 2부지난 글에서는 Kotlin이 무엇인지, Kotlin의 특징, Kotlin에서 변수 및 데이터 유형을 선언하는 방법과 같은 Kotlin의 기본 개념에 대해 배웠습니다. 유형 변환은 데이터 변수의 한 유형을 다른 데이터...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
