Android開發(fā)技術(shù) - - 文件上傳下載

本章教學目標上傳下載用戶權(quán)限多線程實現(xiàn)Android上傳下載文件HandlerAsyncTask上傳文件Android端使用HttpClient上傳文件服務(wù)器端構(gòu)建SpringBoot工程編寫上傳Controller使用MultipartFile保存上傳文件下載文件Android端使用HttpClient下載文件服務(wù)器端使用HttpServletResponse以流的方式提供文件下載功能上傳下載進度更新多線程實現(xiàn)Android上傳下載文件Handler是一套Android消息傳遞機制,主要用于線程間通信。

handler其實就是主線程在起了一個子線程，子線程運行并生成Message，Looper獲取message并傳遞給Handler，Handler逐個獲取子線程中的Message.Binder/Socket用于進程間通信，而Handler消息機制用于同進程的線程間通信可以說只要有異步線程與主線程通信的地方就一定會有Handler。在多線程的應(yīng)用場景中，將工作線程中需更新UI的操作信息傳遞到UI主線程，從而實現(xiàn)工作線程對UI的更新處理，最終實現(xiàn)異步消息的處理使用Handler消息傳遞機制主要是為了多個線程并發(fā)更新UI的同時，保證線程安全多線程實現(xiàn)Android上傳下載文件Handler多線程實現(xiàn)Android上傳下載文件Handler相關(guān)概念解釋Message：代表一個行為what或者一串動作Runnable,每一個消息在加入消息隊列時,都有明確的目標HandlerThreadLocal：線程本地存儲區(qū)（ThreadLocalStorage，簡稱為TLS），每個線程都有自己的私有的本地存儲區(qū)域，不同線程之間彼此不能訪問對方的TLS區(qū)域。ThreadLocal的作用是提供線程內(nèi)的局部變量TLS,這種變量在線程的生命周期內(nèi)起作用,每一個線程有他自己所屬的值(線程隔離)MessageQueue(C層與Java層都有實現(xiàn))：以隊列的形式對外提供插入和刪除的工作,其內(nèi)部結(jié)構(gòu)是以雙向鏈表的形式存儲消息的Looper(C層與Java層都有實現(xiàn))：Looper是循環(huán)的意思,它負責從消息隊列中循環(huán)的取出消息然后把消息交給Handler處理Handler：消息的真正處理者,具備獲取消息、發(fā)送消息、處理消息、移除消息等功能多線程實現(xiàn)Android上傳下載文件HandlerAndroid消息機制以Handler的sendMessage方法為例，當發(fā)送一個消息后，會將此消息加入消息隊列MessageQueue中。Looper負責去遍歷消息隊列并且將隊列中的消息分發(fā)給對應(yīng)的Handler進行處理。在Handler的handleMessage方法中處理該消息，這就完成了一個消息的發(fā)送和處理過程。多線程實現(xiàn)Android上傳下載文件Handler基本使用創(chuàng)建Handler(將Handler定義成靜態(tài)的內(nèi)部類)staticclassMyHandlerextendsHandler{

//弱引用持有HandlerActivity,GC回收時會被回收掉

privateWeakReference<MainActivity>weakReference;

publicMyHandler(MainActivityactivity){

this.weakReference=newWeakReference(activity);

}

@Override

publicvoidhandleMessage(Messagemsg){

MainActivityactivity=weakReference.get();

super.handleMessage(msg);

if(null!=activity){

//執(zhí)行業(yè)務(wù)邏輯

Toast.makeText(activity,"handleMessage",Toast.LENGTH_SHORT).show();

}

}

}多線程實現(xiàn)Android上傳下載文件Handler基本使用Message獲取Messagemessage=newMyHandler().obtainMessage();//通過

Handler實例獲取

Messagemessage1=Message.obtain();//通過

Message獲取

Messagemessage2=newMessage();//直接創(chuàng)建新的

Message實例

多線程實現(xiàn)Android上傳下載文件Handler基本使用發(fā)送MessagesendEmptyMessage(int)sendEmptyMessageDelayed(int,int)sendMessageAtTime(Message,long)多線程實現(xiàn)Android上傳下載文件AsyncTaskAsynctask是一個抽象類，它是Android封裝的一個輕量級異步類（輕量級體現(xiàn)在使用方便，代碼簡潔）,它可以在線程池中執(zhí)行后臺任務(wù)，然后把執(zhí)行的進度和最終的結(jié)果呈現(xiàn)給主線程，并且更新UI。

AsyncTask的泛型參數(shù)publicabstractclassAsyncTask<Params,Progress,Result>{}Params：開始異步任務(wù)執(zhí)行時傳入的參數(shù)類型。Progress：異步任務(wù)執(zhí)行過程中，返回下載進度值的類型。Result：異步任務(wù)執(zhí)行完成，返回的結(jié)果類型。如果AsyncTask確定不需要傳遞具體參數(shù)，那么這三個泛型參數(shù)可以用Void來代替。多線程實現(xiàn)Android上傳下載文件AsyncTaskAsyncTask的核心方法onPreExecute()（主線程中執(zhí)行）：這個方法會在后臺任務(wù)開始執(zhí)行前調(diào)用，在主線程執(zhí)行。用于進行一些界面上的初始化操作，比如顯示一個對話框列表什么的。doInBackground(Params...)（子線程中執(zhí)行）：這個方法在子線程中執(zhí)行，負責處理耗時操作。任務(wù)一旦完成就可以通過return語句來將任務(wù)的執(zhí)行結(jié)果進行返回，如果AsyncTask的第三個參數(shù)指定的是Void，就可以不返回執(zhí)行結(jié)果。如果要更新UI，可以通過調(diào)用publishProgress(Progess...)方法來完成比如反饋當前的進度。

onProgressUpdate(Progress...)(主線程中執(zhí)行)：當在后臺進程中調(diào)用publishProgress（Progress...）方法后，這個方法就會被調(diào)用，方法中攜帶的參數(shù)就是后臺任務(wù)中傳遞過來的。在這個方法中可以對UI進行更新操作。多線程實現(xiàn)Android上傳下載文件AsyncTaskAsyncTask的核心方法onPostExecute(Result)（主線程中執(zhí)行）：當doInBackground(Params...)執(zhí)行完畢并通過return語句進行返回時，這個方法就很快會被調(diào)用。返回的數(shù)據(jù)會作為參數(shù)傳遞到這個方法里面。利用參數(shù)的數(shù)據(jù)，就可以進行UI的修改。上面幾個方法的調(diào)用順序：onPreExcute()-->doInBackground()-->publishProgress()-->onProgressUpdate()-->onPostExcute()onCancelled()（主線程中執(zhí)行）：該方法被調(diào)用，onPostExecute()方法將不會被執(zhí)行，需要注意的是，AsncTask中的cancel()不是真正的取消任務(wù)，只是將任務(wù)標記為取消狀態(tài)，我們需要在doInBackground()內(nèi)判斷終止任務(wù)。多線程實現(xiàn)Android上傳下載文件AsyncTaskAsyncTask的簡單使用多線程實現(xiàn)Android上傳下載文件AsyncTaskAsyncTask的簡單使用publicclassDownloadTaskextendsAsyncTask<Void,Integer,Boolean>{

@Override

protectedvoidonPreExecute(){

progressDialog.show();

}

@Override

protectedBooleandoInBackground(Void...voids){

try{

while(true){

intdownloadPercent=doDownload();

publishProgress(downloadPercent);

if(downloadPercent>=100){

break;

}

}

}catch(Exceptione){

returnfalse;

}

returntrue;

}

@Override

protectedvoidonProgressUpdate(Integer...values){

progressDialog.setMessage("當前下載進度：

"+values[0]+"%");

}

@Override

protectedvoidonPostExecute(Booleanresult){

progressDialog.dismiss();

if(result){

Toast.makeText(context,"下載成功",Toast.LENGTH_SHORT).show();

}else{

Toast.makeText(context,"下載失敗",Toast.LENGTH_SHORT).show();

}

}

}上傳文件Android端使用HttpClient上傳文件添加依賴發(fā)送上傳請求compile'org.apache.httpcomponents:httpcore:4.3.3'

compile'org.apache.httpcomponents:httpmime:4.3.6'上傳文件

HttpClienthc=newDefaultHttpClient();

hc.getParams().setParameter(

CoreProtocolPNames.PROTOCOL_VERSION,HttpVersion.HTTP_1_1);

HttpPosthp=newHttpPost(uploadUrl);

Filefile=newFile(filePath);

finalMultipartEntityentity=newMultipartEntity();

ContentBodycontentBody=newFileBody(file);

entity.addPart(“file”,contentBody);

hp.setEntity(entity);

HttpResponsehr=hc.execute(hp);

HttpEntityhe=hr.getEntity();

intstatusCode=hr.getStatusLine().getStatusCode();

if(statusCode!=HttpStatus.SC_OK)

thrownewException(“HTTPRequestError!”);

result=EntityUtils.toString(he,HTTP.UTF_8);上傳文件服務(wù)端構(gòu)建SpringBoot工程編寫上傳Controller使用MultipartFile保存上傳文件@RestController

publicclassFileUploadController{

@RequestMapping("/upload")

publicStringupload(@RequestParam(value="file")MultipartFileuploadfile)throwsIOException{

Stringfilename=uploadfile.getOriginalFilename();

uploadfile.transferTo(newFile("D://mp3//"+filename));

return"OK";

}}下載文件Android端使用HttpClient下載文件HttpClientclient=newHttpClient();

GetMethodget=null;

FileOutputStreamoutput=null;

try{

get=newGetMethod(url+“?fileName=”+fileName);

inti=client.executeMethod(get);

if(200==i){

FilestoreFile=newFile(“pic//”+fileName);

output=newFileOutputStream(storeFile);

//得到網(wǎng)絡(luò)資源的字節(jié)數(shù)組,并寫入文件

output.write(get.getResponseBody());

}else{}

}catch(Exceptione){

e.printStackTrace();

}下載文件服務(wù)器端使用HttpServletResponse以流的方式提供文件下載功能InputStreaminputStream=newBufferedInputStream(newFileInputStream(file));

//創(chuàng)建緩沖區(qū)

byte[]buffer=newbyte[inputStream.available()];

inputStream.read(buffer);

inputStream.close();

OutputStreamoutputStream=newBufferedOutputStream(response

.getOutputStream());

outputStream.write(buffer);

outputStream.flush();

outputStream.close();上傳下載進度更新定義上傳進度監(jiān)聽器ListenerpublicstaticinterfaceOnUploadProcessListe