您的位置：首页 > 理论基础 > 计算机网络

Android应用开发-网络编程(二)

2016-06-18 16:39 597 查看

ApacheHttpClient框架

GET方式请求提交数据

　　1.创建一个HttpClient

HttpClienthc=newDefaultHttpClient();


　　2.创建一个HttpGet，要提交给服务器的数据已经拼接在path中

HttpGethg=newHttpGet(path);


　　3.使用HttpClient对象发送GET请求，建立连接，返回响应头对象

HttpResponsehr=hc.execute(hg);


　　4.拿到响应头中的状态行，获取状态码，如果为200则说明请求成功

if(hr.getStatusLine().getStatusCode()==200){
//拿到响应头中实体里的内容，其实就是服务器返回的输入流
InputStreamis=hr.getEntity().getContent();
Stringtext=Utils.getTextFromStream(is);
}


POST方式请求提交数据

　　1.创建一个HttpClient

HttpClienthc=newDefaultHttpClient();


　　2.创建一个HttpPost，构造方法的参数就是网址

HttpPosthp=newHttpPost(path);


　　3.往HttpPost对象里放入要提交给服务器的数据

//要提交的数据以键值对的形式封装在BasicNameValuePair对象中
BasicNameValuePairbnvp=newBasicNameValuePair("name",name);
BasicNameValuePairbnvp2=newBasicNameValuePair("pass",pass);
List<NameValuePair>parameters=newArrayList<NameValuePair>();
parameters.add(bnvp);
parameters.add(bnvp2);
//要提交的数据都已经在集合中了，把集合传给实体对象，并指定进行URL编码的码表
UrlEncodedFormEntityentity=newUrlEncodedFormEntity(parameters,"utf-8");
//设置POST请求对象的实体，其实就是把要提交的数据封装至POST请求的输出流中
hp.setEntity(entity);


　　4.使用HttpClient对象发送POST请求，建立连接，返回响应头对象

HttpResponsehr=hc.execute(hp);


　　5.拿到响应头中的状态行，获取状态码，如果为200则说明请求成功

if(hr.getStatusLine().getStatusCode()==200){
//拿到响应头中实体里的内容，其实就是服务器返回的输入流
InputStreamis=hr.getEntity().getContent();
Stringtext=Utils.getTextFromStream(is);
}


android-async-http框架（基于ApacheHttpClient框架封装）


android-async-http框架是一个异步的HttpClient框架，不需要我们自己创建子线程，框架会为我们创建子线程去执行网络的交互



GET方式请求提交数据

　　1.创建异步HttpClient

AsyncHttpClientahc=newAsyncHttpClient();


　　2.发送GET请求提交数据，提交的数据拼接在path上

ahc.get(path,newMyResponseHandler());


POST方式请求提交数据

　　1.创建异步HttpClient

AsyncHttpClientahc=newAsyncHttpClient();


　　2.把要提交的数据封装至RequestParams

RequestParamsparams=newRequestParams();
params.add("name",name);
params.add("pass",pass);


　　3.发送POST请求提交数据

ahc.post(path,params,newMyResponseHandler());


响应处理器AsyncHttpResponseHandler

classMyResponseHandlerextendsAsyncHttpResponseHandler{

//请求服务器成功时(响应码是200)回调此方法
@Override
publicvoidonSuccess(intstatusCode,Header[]headers,
byte[]responseBody){
//responseBody的内容就是服务器返回的数据
Toast.makeText(MainActivity.this,newString(responseBody,"GBK"),Toast.LENGTH_SHORT).show();

}

//Http请求失败(返回码不为200)，系统回调此方法
@Override
publicvoidonFailure(intstatusCode,Header[]headers,
byte[]responseBody,Throwableerror){
Toast.makeText(MainActivity.this,newString(responseBody,"GBK"),Toast.LENGTH_SHORT).show();

}

}


多线程下载


服务器CPU分配给每个线程的时间片相同，服务器带宽平均分配给每个线程，所以客户端开启的线程越多，就能抢占到更多的服务器资源。实际上并不是客户端并发的下载线程越多，程序的下载速度就越快，因为当客户端开启太多的并发线程之后，应用程序需要维护每条线程的开销、线程同步的开销，这些开销反而会导致下载速度降低；并且无论开多少个线程抢占服务器资源，下载带宽也不会超过客户端的物理带宽


主线程首先发送HttpGET请求确定每个线程下载哪部分数据

获取资源文件总大小，然后创建大小一致的临时文件

Stringpath="http://dldir1.qq.com/music/clntupate/QQMusic.apk";
URLurl=newURL(path);
HttpURLConnectionconn=(HttpURLConnection)url.openConnection();
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
conn.setReadTimeout(5000);
if(conn.getResponseCode()==200){
intlength=conn.getContentLength();　　//获得服务器流中数据的长度
RandomAccessFileraf=newRandomAccessFile(getFileName(path),"rwd");//创建一个临时文件存储下载的数据
raf.setLength(length);//设置临时文件的大小
raf.close();


计算每个线程下载多少数据

intblockSize=length/THREAD_COUNT;


计算每个线程下载数据的开始位置和结束位置，然后开启下载子线程

for(intid=0;id<threadCount;id++){
//计算每个线程下载数据的开始位置和结束位置
intstartIndex=id*blockSize;
intendIndex=(id+1）*blockSize-1;
//如果是最后一个线程，结束位置为资源文件的结尾
if(id==threadCount-1){
endIndex=length-1;
}
//开启线程，按照计算出来的开始结束位置开始下载数据
newDownLoadThread(startIndex,endIndex,id).start();
}


每个下载线程再次发送HttpGET请求，请求自己负责下载的那部分数据

请求自己负责的那部分数据，同步写入到临时文件相应的位置

Stringpath="http://dldir1.qq.com/music/clntupate/QQMusic.apk";
URLurl=newURL(path);
HttpURLConnectionconn=(HttpURLConnection)url.openConnection();
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
conn.setReadTimeout(5000);
conn.setRequestProperty("Range","bytes="+startIndex+"-"+endIndex);//设置本次Http请求的数据区间
conn.connect();
//请求部分数据，成功的响应码是206
if(conn.getResponseCode()==206){
InputStreamis=conn.getInputStream();//流里此时只有1/ThreadCount资源文件里的数据
RandomAccessFileraf=newRandomAccessFile(getFileName(path),"rwd");
raf.seek(startIndex);//把文件的写入位置移动至startIndex
byte[]b=newbyte[1024];
intlen;
while((len=is.read(b))!=-1){
raf.write(b,0,len);
}
raf.close();
}


带断点续传的多线程下载

每个下载线程定义了一个threadProgress成员变量记录当前线程下载的进度，线程在往资源临时文件中写入数据的同时记录下threadProgress，并存入进度缓存文件

while((len=is.read(b))!=-1){
raf.write(b,0,len);
threadProgress+=len;
RandomAccessFileprogressRaf=newRandomAccessFile(progressFile,"rwd");
progressRaf.write((threadProgress+"").getBytes());
progressRaf.close();
}


下次下载开始时，先读取缓存文件中的值，得到的值就是该线程新的开始位置

FileInputStreamfis=newFileInputStream(progressFile);
BufferedReaderbr=newBufferedReader(newInputStreamReader(fis));
threadProgress=Integer.parseInt(br.readLine());//从进度临时文件中读取出上一次下载的总进度
startIndex+=threadProgress;　　//与原本的开始位置相加，得到新的开始位置，完成断点续传
fis.close();




所有线程都下载完毕之后，删除缓存文件

finishedThread++;
if(finishedThread==threadCount){
for(inti=0;i<threadCount;i++){
Filef=newFile(target,i+".txt");
f.delete();
}
}


手机版的断点续传多线程下载器
用进度条显示下载进度
拿到下载文件总大小时，设置进度条的最大值

pb.setMax(length);//设置进度条的最大值


进度条需要显示所有线程的整体下载进度，所以各条线程每下载一次，就要把新下载的长度加入进度条

定义一个int全局变量，记录三条线程的总下载长度

inttotalProgress;


刷新进度条

while((len=is.read(b))!=-1){
raf.write(b,0,len);
//每次读取流里数据之后，把每次读取数据的长度显示至进度条
totalProgress+=len;
pb.setProgress(totalProgress);


每次断点下载时，从新的开始位置开始下载，进度条也要从新的位置开始显示，在读取缓存文件获取新的下载开始位置时，也要处理进度条进度

FileInputStreamfis=newFileInputStream(progressFile);
BufferedReaderbr=newBufferedReader(newInputStreamReader(fis));
//从进度临时文件中读取出上一次下载的总进度
//然后与原本的开始位置相加，得到新的开始位置，完成断点续传
threadProgress=Integer.parseInt(br.readLine());
startIndex+=threadProgress;
//把上次多线程下载的总进度显示至进度条
totalProgress+=threadProgress;
pb.setProgress(totalProgress);


添加文本框显示百分比进度
tv.setText((long)pb.getProgress()*100/pb.getMax()+"%");//文本进度与进度条是同步的，转换成long类型防止整型溢出


使用开源框架xUtils下载文件

开源框架xUtils是基于原来的开源框架afinal开发的，主要有四大模块，其中HttpUtils模块支持断点续传，随时停止下载任务，开始任务



创建HttpUtils对象

HttpUtilshttp=newHttpUtils();


下载文件

http.download(path,//下载地址
target,//下载数据保存的路径和文件名
true,//是否支持断点续传
true,//如果请求地址中没有文件名，则文件名在响应头中，下载完成后自动重命名
newRequestCallBack<File>(){//侦听下载状态

//下载成功后回调
@Override
publicvoidonSuccess(ResponseInfo<File>responseInfo){
Toast.makeText(MainActivity.this,responseInfo.result.getPath(),Toast.LENGTH_SHORT).show();
}

//下载失败时回调，比如文件已经下载、没有网络权限、文件访问不到，方法传入一个字符串s告知失败原因
@Override
publicvoidonFailure(HttpExceptione,Strings){
tv_failure.setText(s);
}

//在下载过程中不断的调用，用于刷新进度条
@Override
publicvoidonLoading(longtotal,longcurrent,booleanisUploading){
super.onLoading(total,current,isUploading);
pb.setMax((int)total);　　//设置进度条总长度
pb.setProgress((int)current);//设置进度条当前进度
tv_progress.setText(current*100/total+"%");//文本进度
}
});

                                            

                                        

                        
                        内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息 
                    

                    

                    

                        

                         标签： 
                                                

                        

                    


                

            


            

                
相关文章推荐

                

                

                    
                

            

        
        

            

            
            

                

                    
新的分享

                    

                        
                    

                

            


            

                

                    
章节导航