Android最基本的异步网络请求框架
本篇文章我们来一起写一个最基本的Android异步网络请求框架,借此来了解下Android中网络请求的相关知识。由于个人水平有限,文中难免存在疏忽和谬误,希望大家可以指出,谢谢大家。
1.同步网络请求
以HTTP的GET请求为例,我们来介绍一下Android中一个基本的同步请求框架的实现。直接贴代码:
publicclassHttpUtils{ publicstaticbyte[]get(StringurlString){ HttpURLConnectionurlConnection=null; try{ URLurl=newURL(urlString); urlConnection=(HttpURLConnection)url.openConnection(); //设置请求方法 urlConnection.setRequestMethod("GET"); //设置超时时间 urlConnection.setConnectTimeout(5000); urlConnection.setReadTimeout(3000); //获取响应的状态码 intresponseCode=urlConnection.getResponseCode(); if(responseCode==200){ ByteArrayOutputStreambos=newByteArrayOutputStream(); InputStreamin=urlConnection.getInputStream(); byte[]buffer=newbyte[4*1024]; intlen=-1; while((len=in.read(buffer))!=-1){ bos.write(buffer,0,len); } close(in); byte[]result=bos.toByteArray(); close(bos); returnresult; }else{ returnnull; } }catch(Exceptione){ e.printStackTrace(); }finally{ if(urlConnection!=null){ urlConnection.disconnect(); } } returnnull; } privatestaticvoidclose(Closeablestream){ if(stream!=null){ try{ stream.close(); }catch(IOExceptione){ e.printStackTrace(); } } } }
相信以上的代码我们大家都不陌生,以上代码就实现了基本的同步网络请求功能,get方法会返回一个byte[]数组,后续我们可以根据返回的相应类型(文本或图片)对这个字节数组作进一步处理。
2.异步网络请求
通常一个异步HTTPGET请求是这样的:发出get方法的调用后,相关任务会在后台线程中自动执行,而我们在主线程中继续处理其他工作,它成功获取GET请求的响应时,就会回调onSuccess方法。最直接的写法通常如下所示:
publicclassAsyncHttpUtils{publicstaticbyte[]get(Stringurl,ResponseHandlerhandler){ finalHandlermHandler=newHandler(); newThread(newRunnable(){ @Override publicvoidrun(){ finalbyte[]result=HttpUtils.get(url); handler.post(newRunnable(){ @Override publicvoidrun(){ responseHandler.onSuccess(result); } }); } }); } }
其中,ResponseHandler接口的定义如下:
publicinterfaceResponseHandler{ voidonSucess(bytep[]result); }
我们可以看到,以上实现异步GET请求的代码很直截了当,然而存在着以下问题:每次请求时都会创建一个线程,这样当请求比较频繁的情况下会创建大量大线程,这样的话创建、销毁线程以及线程调度的开销会很大。而且Thread对象是一个匿名内部类对象,会隐式持有外围类引用,可能会引起MemoryLeak。
针对以上问题,我们可以使用线程池来复用线程,以避免不必要的创建及销毁线程的开销,改进后AsyncHttpUtils类的代码如下:
publicclassAsyncHttpUtils{ //获取当前设备的CPU数 publicstaticfinalintCPU_COUNT=Runtime.getRuntime().availableProcessors(); //核心池大小设为CPU数加1 privatestaticfinalintCORE_POOL_SIZE=CPU_COUNT+1; //设置线程池的最大大小 privatestaticfinalintMAX_POOL_SIZE=2*CPU_COUNT+1; //存活时间 privatestaticfinallongKEEP_ALIVE=5L; //创建线程池对象 publicstaticfinalExecutorthreadPoolExecutor=newThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE,KEEP_ALIVE,TimeUnit.SECONDS,newLinkedBlockingQueue<Runnable>()); publicstaticvoidget(finalStringurl,finalResponseHandlerresponseHandler){ finalHandlermHandler=newHandler(Looper.getMainLooper()); //创建一个新的请求任务 RunnablerequestRunnable=newRunnable(){ @Override publicvoidrun(){ finalbyte[]result=HttpUtils.get(url); if(result!=null){ mHandler.post(newRunnable(){ @Override publicvoidrun(){ //result不为空表明请求成功,回调onSuccess方法 responseHandler.onSuccess(result); } }); } } }; threadPoolExecutor.execute(requestRunnable); } }
以上代码主要就是使用了线程池来达到线程的复用的目的,希望本文所述对大家学习Android软件编程有所帮助。