Android中使用HTTP服务

转至 http://blog.csdn.net/liuhe688/article/details/6425225

在Android中，除了使用java.net包下的API访问HTTP服务之外，我们还可以换一种途径去完成工作。Android SDK附带了Apache的HttpClient API。Apache HttpClient是一个完善的HTTP客户端，它提供了对HTTP协议的全面支持，可以使用HTTP GET和POST进行访问。下面我们就结合实例，介绍一下HttpClient的使用方法。

我们新建一个http项目，项目结构如图：

Android中使用HTTP服务

在这个项目中，我们不需要任何的Activity，所有的操作都在单元测试类HttpTest.java中完成。

因为使用到了单元测试，所以在这里先介绍一下如何配置Android中的单元测试。所有配置信息均在AndroidManifest.xml中完成：

[xhtml] view plain copy

<?xmlversion="1.0"encoding="utf-8"?>
<manifestxmlns:android="http://schemas.android.com/apk/res/android"
package="com.scott.http"
android:versionCode="1"
android:versionName="1.0">
<applicationandroid:icon="@drawable/icon"android:label="@string/app_name">
<uses-libraryandroid:name="android.test.runner"/>
</application>
<instrumentationandroid:name="android.test.InstrumentationTestRunner"
android:targetPackage="com.scott.http"/>
<uses-permissionandroid:name="android.permission.INTERNET"/>
<uses-sdkandroid:minSdkVersion="8"/>
</manifest>

然后，我们的单元测试类需要继承android.test.AndroidTestCase类，这个类本身是继承junit.framework.TestCase，并提供了getContext()方法，用于获取Android上下文环境，这个设计非常有用，因为很多Android API都是需要Context才能完成的。

现在让我们来看一下我们的测试用例，HttpTest.java代码如下：

[java] view plain copy

packagecom.scot.http.test;
importjava.io.ByteArrayOutputStream;
importjava.io.InputStream;
importjava.util.ArrayList;
importjava.util.List;
importjunit.framework.Assert;
importorg.apache.http.HttpEntity;
importorg.apache.http.HttpResponse;
importorg.apache.http.HttpStatus;
importorg.apache.http.NameValuePair;
importorg.apache.http.client.HttpClient;
importorg.apache.http.client.entity.UrlEncodedFormEntity;
importorg.apache.http.client.methods.HttpGet;
importorg.apache.http.client.methods.HttpPost;
importorg.apache.http.entity.mime.MultipartEntity;
importorg.apache.http.entity.mime.content.InputStreamBody;
importorg.apache.http.entity.mime.content.StringBody;
importorg.apache.http.impl.client.DefaultHttpClient;
importorg.apache.http.message.BasicNameValuePair;
importandroid.test.AndroidTestCase;
publicclassHttpTestextendsAndroidTestCase{
privatestaticfinalStringPATH="http://192.168.1.57:8080/web";
publicvoidtestGet()throwsException{
HttpClientclient=newDefaultHttpClient();
HttpGetget=newHttpGet(PATH+"/TestServlet?id=1001&name=john&age=60");
HttpResponseresponse=client.execute(get);
if(response.getStatusLine().getStatusCode()==HttpStatus.SC_OK){
InputStreamis=response.getEntity().getContent();
Stringresult=inStream2String(is);
Assert.assertEquals(result,"GET_SUCCESS");
}
}
publicvoidtestPost()throwsException{
HttpClientclient=newDefaultHttpClient();
HttpPostpost=newHttpPost(PATH+"/TestServlet");
List<NameValuePair>params=newArrayList<NameValuePair>();
params.add(newBasicNameValuePair("id","1001"));
params.add(newBasicNameValuePair("name","john"));
params.add(newBasicNameValuePair("age","60"));
HttpEntityformEntity=newUrlEncodedFormEntity(params);
post.setEntity(formEntity);
HttpResponseresponse=client.execute(post);
if(response.getStatusLine().getStatusCode()==HttpStatus.SC_OK){
InputStreamis=response.getEntity().getContent();
Stringresult=inStream2String(is);
Assert.assertEquals(result,"POST_SUCCESS");
}
}
publicvoidtestUpload()throwsException{
InputStreamis=getContext().getAssets().open("books.xml");
HttpClientclient=newDefaultHttpClient();
HttpPostpost=newHttpPost(PATH+"/UploadServlet");
InputStreamBodyisb=newInputStreamBody(is,"books.xml");
MultipartEntitymultipartEntity=newMultipartEntity();
multipartEntity.addPart("file",isb);
multipartEntity.addPart("desc",newStringBody("thisisdescription."));
post.setEntity(multipartEntity);
HttpResponseresponse=client.execute(post);
if(response.getStatusLine().getStatusCode()==HttpStatus.SC_OK){
is=response.getEntity().getContent();
Stringresult=inStream2String(is);
Assert.assertEquals(result,"UPLOAD_SUCCESS");
}
}
//将输入流转换成字符串
privateStringinStream2String(InputStreamis)throwsException{
ByteArrayOutputStreambaos=newByteArrayOutputStream();
byte[]buf=newbyte[1024];
intlen=-1;
while((len=is.read(buf))!=-1){
baos.write(buf,0,len);
}
returnnewString(baos.toByteArray());
}
}

因为此文件包含三个测试用例，所以我将会逐个介绍一下。

首先，需要注意的是，我们定位服务器地址时使用到了IP，因为这里不能用localhost，服务端是在windows上运行，而本单元测试运行在Android平台，如果使用localhost就意味着在Android内部去访问服务，可能是访问不到的，所以必须用IP来定位服务。

我们先来分析一下testGet测试用例。我们使用了HttpGet，请求参数直接附在URL后面，然后由HttpClient执行GET请求，如果响应成功的话，取得响应内如输入流，并转换成字符串，最后判断是否为GET_SUCCESS。

testGet测试对应服务端Servlet代码如下：

[java] view plain copy

@Override
protectedvoiddoGet(HttpServletRequestrequest,HttpServletResponseresponse)throwsServletException,IOException{
System.out.println("doGetmethodiscalled.");
Stringid=request.getParameter("id");
Stringname=request.getParameter("name");
Stringage=request.getParameter("age");
System.out.println("id:"+id+",name:"+name+",age:"+age);
response.getWriter().write("GET_SUCCESS");
}

然后再说testPost测试用例。我们使用了HttpPost，URL后面并没有附带参数信息，参数信息被包装成一个由NameValuePair类型组成的集合的形式，然后经过UrlEncodedFormEntity处理后调用HttpPost的setEntity方法进行参数设置，最后由HttpClient执行。

testPost测试对应的服务端代码如下：

[java] view plain copy

@Override
protectedvoiddoPost(HttpServletRequestrequest,HttpServletResponseresponse)throwsServletException,IOException{
System.out.println("doPostmethodiscalled.");
Stringid=request.getParameter("id");
Stringname=request.getParameter("name");
Stringage=request.getParameter("age");
System.out.println("id:"+id+",name:"+name+",age:"+age);
response.getWriter().write("POST_SUCCESS");
}

上面两个是最基本的GET请求和POST请求，参数都是文本数据类型，能满足普通的需求，不过在有的场合例如我们要用到上传文件的时候，就不能使用基本的GET请求和POST请求了，我们要使用多部件的POST请求。下面介绍一下如何使用多部件POST操作上传一个文件到服务端。

由于Android附带的HttpClient版本暂不支持多部件POST请求，所以我们需要用到一个HttpMime开源项目，该组件是专门处理与MIME类型有关的操作。因为HttpMime是包含在HttpComponents 项目中的，所以我们需要去apache官方网站下载HttpComponents，然后把其中的HttpMime.jar包放到项目中去，如图：

Android中使用HTTP服务

然后，我们观察testUpload测试用例，我们用HttpMime提供的InputStreamBody处理文件流参数，用StringBody处理普通文本参数，最后把所有类型参数都加入到一个MultipartEntity的实例中，并将这个multipartEntity设置为此次POST请求的参数实体，然后执行POST请求。服务端Servlet代码如下：

[java] view plain copy

packagecom.scott.web.servlet;
importjava.io.FileOutputStream;
importjava.io.IOException;
importjava.util.Iterator;
importjava.util.List;
importjavax.servlet.ServletException;
importjavax.servlet.http.HttpServlet;
importjavax.servlet.http.HttpServletRequest;
importjavax.servlet.http.HttpServletResponse;
importorg.apache.commons.fileupload.FileItem;
importorg.apache.commons.fileupload.FileItemFactory;
importorg.apache.commons.fileupload.FileUploadException;
importorg.apache.commons.fileupload.disk.DiskFileItemFactory;
importorg.apache.commons.fileupload.servlet.ServletFileUpload;
@SuppressWarnings("serial")
publicclassUploadServletextendsHttpServlet{
@Override
@SuppressWarnings("rawtypes")
protectedvoiddoPost(HttpServletRequestrequest,HttpServletResponseresponse)throwsServletException,IOException{
booleanisMultipart=ServletFileUpload.isMultipartContent(request);
if(isMultipart){
FileItemFactoryfactory=newDiskFileItemFactory();
ServletFileUploadupload=newServletFileUpload(factory);
try{
Listitems=upload.parseRequest(request);
Iteratoriter=items.iterator();
while(iter.hasNext()){
FileItemitem=(FileItem)iter.next();
if(item.isFormField()){
//普通文本信息处理
StringparamName=item.getFieldName();
StringparamValue=item.getString();
System.out.println(paramName+":"+paramValue);
}else{
//上传文件信息处理
StringfileName=item.getName();
byte[]data=item.get();
StringfilePath=getServletContext().getRealPath("/files")+"/"+fileName;
FileOutputStreamfos=newFileOutputStream(filePath);
fos.write(data);
fos.close();
}
}
}catch(FileUploadExceptione){
e.printStackTrace();
}
}
response.getWriter().write("UPLOAD_SUCCESS");
}
}

服务端使用apache开源项目FileUpload进行处理，所以我们需要commons-fileupload和commons-io这两个项目的jar包，对服务端开发不太熟悉的朋友可以到网上查找一下相关资料。

介绍完上面的三种不同的情况之后，我们需要考虑一个问题，在实际应用中，我们不能每次都新建HttpClient，而是应该只为整个应用创建一个HttpClient，并将其用于所有HTTP通信。此外，还应该注意在通过一个HttpClient同时发出多个请求时可能发生的多线程问题。针对这两个问题，我们需要改进一下我们的项目：

1.扩展系统默认的Application，并应用在项目中。

2.使用HttpClient类库提供的ThreadSafeClientManager来创建和管理HttpClient。

改进后的项目结构如图：

Android中使用HTTP服务

其中MyApplication扩展了系统的Application，代码如下：

[java] view plain copy

packagecom.scott.http;
importorg.apache.http.HttpVersion;
importorg.apache.http.client.HttpClient;
importorg.apache.http.conn.ClientConnectionManager;
importorg.apache.http.conn.scheme.PlainSocketFactory;
importorg.apache.http.conn.scheme.Scheme;
importorg.apache.http.conn.scheme.SchemeRegistry;
importorg.apache.http.conn.ssl.SSLSocketFactory;
importorg.apache.http.impl.client.DefaultHttpClient;
importorg.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
importorg.apache.http.params.BasicHttpParams;
importorg.apache.http.params.HttpParams;
importorg.apache.http.params.HttpProtocolParams;
importorg.apache.http.protocol.HTTP;
importandroid.app.Application;
publicclassMyApplicationextendsApplication{
privateHttpClienthttpClient;
@Override
publicvoidonCreate(){
super.onCreate();
httpClient=this.createHttpClient();
}
@Override
publicvoidonLowMemory(){
super.onLowMemory();
this.shutdownHttpClient();
}
@Override
publicvoidonTerminate(){
super.onTerminate();
this.shutdownHttpClient();
}
//创建HttpClient实例
privateHttpClientcreateHttpClient(){
HttpParamsparams=newBasicHttpParams();
HttpProtocolParams.setVersion(params,HttpVersion.HTTP_1_1);
HttpProtocolParams.setContentCharset(params,HTTP.DEFAULT_CONTENT_CHARSET);
HttpProtocolParams.setUseExpectContinue(params,true);
SchemeRegistryschReg=newSchemeRegistry();
schReg.register(newScheme("http",PlainSocketFactory.getSocketFactory(),80));
schReg.register(newScheme("https",SSLSocketFactory.getSocketFactory(),443));
ClientConnectionManagerconnMgr=newThreadSafeClientConnManager(params,schReg);
returnnewDefaultHttpClient(connMgr,params);
}
//关闭连接管理器并释放资源
privatevoidshutdownHttpClient(){
if(httpClient!=null&&httpClient.getConnectionManager()!=null){
httpClient.getConnectionManager().shutdown();
}
}
//对外提供HttpClient实例
publicHttpClientgetHttpClient(){
returnhttpClient;
}
}

我们重写了onCreate()方法，在系统启动时就创建一个HttpClient；重写了onLowMemory()和onTerminate()方法，在内存不足和应用结束时关闭连接，释放资源。需要注意的是，当实例化DefaultHttpClient时，传入一个由ThreadSafeClientConnManager创建的一个ClientConnectionManager实例，负责管理HttpClient的HTTP连接。

然后，想要让我们这个加强版的“Application”生效，需要在AndroidManifest.xml中做如下配置：

[c-sharp] view plain copy

<applicationandroid:name=".MyApplication"...>
...
</application>

如果我们没有配置，系统默认会使用android.app.Application，我们添加了配置，系统就会使用我们的com.scott.http.MyApplication，然后就可以在context中调用getApplication()来获取MyApplication实例。

有了上面的配置，我们就可以在活动中应用了，HttpActivity.java代码如下：

[c-sharp] view plain copy

packagecom.scott.http;
importjava.io.ByteArrayOutputStream;
importjava.io.InputStream;
importorg.apache.http.HttpResponse;
importorg.apache.http.HttpStatus;
importorg.apache.http.client.HttpClient;
importorg.apache.http.client.methods.HttpGet;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.view.View;
importandroid.widget.Button;
importandroid.widget.Toast;
publicclassHttpActivityextendsActivity{
@Override
protectedvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
Buttonbtn=(Button)findViewById(R.id.btn);
btn.setOnClickListener(newView.OnClickListener(){
@Override
publicvoidonClick(Viewv){
execute();
}
});
}
privatevoidexecute(){
try{
MyApplicationapp=(MyApplication)this.getApplication();//获取MyApplication实例
HttpClientclient=app.getHttpClient();//获取HttpClient实例
HttpGetget=newHttpGet("http://192.168.1.57:8080/web/TestServlet?id=1001&name=john&age=60");
HttpResponseresponse=client.execute(get);
if(response.getStatusLine().getStatusCode()==HttpStatus.SC_OK){
InputStreamis=response.getEntity().getContent();
Stringresult=inStream2String(is);
Toast.makeText(this,result,Toast.LENGTH_LONG).show();
}
}catch(Exceptione){
e.printStackTrace();
}
}
//将输入流转换成字符串
privateStringinStream2String(InputStreamis)throwsException{
ByteArrayOutputStreambaos=newByteArrayOutputStream();
byte[]buf=newbyte[1024];
intlen=-1;
while((len=is.read(buf))!=-1){
baos.write(buf,0,len);
}
returnnewString(baos.toByteArray());
}
}

点击“execute”按钮，执行结果如下：

Android中使用HTTP服务

更多相关文章

随机推荐