在AndroID中,除了使用Java.NET包下的API访问http服务之外,我们还可以换一种途径去完成工作。AndroID SDK附带了Apache的httpClIEnt API。Apache httpClIEnt是一个完善的http客户端,它提供了对http协议的全面支持,可以使用http GET和POST进行访问。下面我们就结合实例,介绍一下httpClIEnt的使用方法。
我们新建一个http项目,项目结构如图:
在这个项目中,我们不需要任何的Activity,所有的 *** 作都在单元测试类httpTest.java中完成。
因为使用到了单元测试,所以在这里先介绍一下如何配置AndroID中的单元测试。所有配置信息均在AndroIDManifest.xml中完成:
<?xml version="1.0" enCoding="utf-8"?> <manifest xmlns:androID="http://schemas.androID.com/apk/res/androID" package="com.scott.http" androID:versionCode="1" androID:versionname="1.0"> <application androID:icon="@drawable/icon" androID:label="@string/app_name"> <!-- 配置测试要使用的类库 --> <uses-library androID:name="androID.test.runner"/> </application> <!-- 配置测试设备的主类和目标包 --> <instrumentation androID:name="androID.test.InstrumentationTestRunner" androID:targetPackage="com.scott.http"/> <!-- 访问http服务所需的网络权限 --> <uses-permission androID:name="androID.permission.INTERNET"/> <uses-sdk androID:minSdkVersion="8" /> </manifest>
然后,我们的单元测试类需要继承androID.test.AndroIDTestCase类,这个类本身是继承junit.framework.TestCase,并提供了getContext()方法,用于获取AndroID上下文环境,这个设计非常有用,因为很多AndroID API都是需要Context才能完成的。
现在让我们来看一下我们的测试用例,httpTest.java代码如下:
package com.scot.http.test; import java.io.ByteArrayOutputStream; import java.io.inputStream; import java.util.ArrayList; import java.util.List; import junit.framework.Assert; import org.apache.http.httpentity; import org.apache.http.httpResponse; import org.apache.http.httpStatus; import org.apache.http.nameValuePair; import org.apache.http.clIEnt.httpClIEnt; import org.apache.http.clIEnt.entity.UrlEncodedFormEntity; import org.apache.http.clIEnt.methods.httpGet; import org.apache.http.clIEnt.methods.httpPost; import org.apache.http.entity.mime.multipartentity; import org.apache.http.entity.mime.content.inputStreamBody; import org.apache.http.entity.mime.content.StringBody; import org.apache.http.impl.clIEnt.DefaulthttpClIEnt; import org.apache.http.message.BasicnameValuePair; import androID.test.AndroIDTestCase; public class httpTest extends AndroIDTestCase { private static final String PATH = "http://192.168.1.57:8080/web"; public voID testGet() throws Exception { httpClIEnt clIEnt = new DefaulthttpClIEnt(); httpGet get = new httpGet(PATH + "/TestServlet?ID=1001&name=john&age=60"); httpResponse response = clIEnt.execute(get); if (response.getStatusline().getStatusCode() == httpStatus.SC_OK) { inputStream is = response.getEntity().getContent(); String result = inStream2String(is); Assert.assertEquals(result,"GET_SUCCESS"); } } public voID testPost() throws Exception { httpClIEnt clIEnt = new DefaulthttpClIEnt(); httpPost post = new httpPost(PATH + "/TestServlet"); List<nameValuePair> params = new ArrayList<nameValuePair>(); params.add(new BasicnameValuePair("ID","1001")); params.add(new BasicnameValuePair("name","john")); params.add(new BasicnameValuePair("age","60")); httpentity formEntity = new UrlEncodedFormEntity(params); post.setEntity(formEntity); httpResponse response = clIEnt.execute(post); if (response.getStatusline().getStatusCode() == httpStatus.SC_OK) { inputStream is = response.getEntity().getContent(); String result = inStream2String(is); Assert.assertEquals(result,"POST_SUCCESS"); } } public voID testUpload() throws Exception { inputStream is = getContext().getAssets().open("books.xml"); httpClIEnt clIEnt = new DefaulthttpClIEnt(); httpPost post = new httpPost(PATH + "/UploadServlet"); inputStreamBody isb = new inputStreamBody(is,"books.xml"); multipartentity multipartentity = new multipartentity(); multipartentity.addPart("file",isb); multipartentity.addPart("desc",new StringBody("this is description.")); post.setEntity(multipartentity); httpResponse response = clIEnt.execute(post); if (response.getStatusline().getStatusCode() == httpStatus.SC_OK) { is = response.getEntity().getContent(); String result = inStream2String(is); Assert.assertEquals(result,"UPLOAD_SUCCESS"); } } //将输入流转换成字符串 private String inStream2String(inputStream is) throws Exception { ByteArrayOutputStream baos = new ByteArrayOutputStream(); byte[] buf = new byte[1024]; int len = -1; while ((len = is.read(buf)) != -1) { baos.write(buf,len); } return new String(baos.toByteArray()); } }
因为此文件包含三个测试用例,所以我将会逐个介绍一下。
首先,需要注意的是,我们定位服务器地址时使用到了IP,因为这里不能用localhost,服务端是在windows上运行,而本单元测试运行在AndroID平台,如果使用localhost就意味着在AndroID内部去访问服务,可能是访问不到的,所以必须用IP来定位服务。
我们先来分析一下testGet测试用例。我们使用了httpGet,请求参数直接附在URL后面,然后由httpClIEnt执行GET请求,如果响应成功的话,取得响应内如输入流,并转换成字符串,最后判断是否为GET_SUCCESS。
testGet测试对应服务端Servlet代码如下:
@OverrIDe protected voID doGet(httpServletRequest request,httpServletResponse response) throws servletexception,IOException { System.out.println("doGet method is called."); String ID = request.getParameter("ID"); String name = request.getParameter("name"); String age = 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测试对应的服务端代码如下:
@OverrIDe protected voID doPost(httpServletRequest request,IOException { System.out.println("doPost method is called."); String ID = request.getParameter("ID"); String name = request.getParameter("name"); String age = request.getParameter("age"); System.out.println("ID:" + ID + ",age:" + age); response.getWriter().write("POST_SUCCESS"); }
上面两个是最基本的GET请求和POST请求,参数都是文本数据类型,能满足普通的需求,不过在有的场合例如我们要用到上传文件的时候,就不能使用基本的GET请求和POST请求了,我们要使用多部件的POST请求。下面介绍一下如何使用多部件POST *** 作上传一个文件到服务端。
由于AndroID附带的httpClIEnt版本暂不支持多部件POST请求,所以我们需要用到一个httpMime开源项目,该组件是专门处理与MIME类型有关的 *** 作。因为httpMime是包含在httpComponents 项目中的,所以我们需要去apache官方网站下载httpComponents,然后把其中的httpMime.jar包放到项目中去,如图:
然后,我们观察testUpload测试用例,我们用httpMime提供的inputStreamBody处理文件流参数,用StringBody处理普通文本参数,最后把所有类型参数都加入到一个multipartentity的实例中,并将这个multipartentity设置为此次POST请求的参数实体,然后执行POST请求。服务端Servlet代码如下:
package com.scott.web.servlet; import java.io.fileOutputStream; import java.io.IOException; import java.util.Iterator; import java.util.List; import javax.servlet.servletexception; import javax.servlet.http.httpServlet; import javax.servlet.http.httpServletRequest; import javax.servlet.http.httpServletResponse; import org.apache.commons.fileupload.fileItem; import org.apache.commons.fileupload.fileItemFactory; import org.apache.commons.fileupload.fileUploadException; import org.apache.commons.fileupload.disk.diskfileItemFactory; import org.apache.commons.fileupload.servlet.ServletfileUpload; @SuppressWarnings("serial") public class UploadServlet extends httpServlet { @OverrIDe @SuppressWarnings("rawtypes") protected voID doPost(httpServletRequest request,IOException { boolean isMultipart = ServletfileUpload.isMultipartContent(request); if (isMultipart) { fileItemFactory factory = new diskfileItemFactory(); ServletfileUpload upload = new ServletfileUpload(factory); try { List items = upload.parseRequest(request); Iterator iter = items.iterator(); while (iter.hasNext()) { fileItem item = (fileItem) iter.next(); if (item.isFormFIEld()) { //普通文本信息处理 String paramname = item.getFIEldname(); String paramValue = item.getString(); System.out.println(paramname + ":" + paramValue); } else { //上传文件信息处理 String filename = item.getname(); byte[] data = item.get(); String filePath = getServletContext().getRealPath("/files") + "/" + filename; fileOutputStream fos = new fileOutputStream(filePath); fos.write(data); fos.close(); } } } catch (fileUploadException e) { e.printstacktrace(); } } response.getWriter().write("UPLOAD_SUCCESS"); } }
服务端使用apache开源项目fileUpload进行处理,所以我们需要commons-fileupload和commons-io这两个项目的jar包,对服务端开发不太熟悉的朋友可以到网上查找一下相关资料。
介绍完上面的三种不同的情况之后,我们需要考虑一个问题,在实际应用中,我们不能每次都新建httpClIEnt,而是应该只为整个应用创建一个httpClIEnt,并将其用于所有http通信。此外,还应该注意在通过一个httpClIEnt同时发出多个请求时可能发生的多线程问题。针对这两个问题,我们需要改进一下我们的项目:
1.扩展系统默认的Application,并应用在项目中。
2.使用httpClIEnt类库提供的ThreadSafeClIEntManager来创建和管理httpClIEnt。
改进后的项目结构如图:
其中MyApplication扩展了系统的Application,代码如下:
package com.scott.http; import org.apache.http.httpVersion; import org.apache.http.clIEnt.httpClIEnt; import org.apache.http.conn.ClIEntConnectionManager; import org.apache.http.conn.scheme.PlainSocketFactory; import org.apache.http.conn.scheme.Scheme; import org.apache.http.conn.scheme.SchemeRegistry; import org.apache.http.conn.ssl.SSLSocketFactory; import org.apache.http.impl.clIEnt.DefaulthttpClIEnt; import org.apache.http.impl.conn.tsccm.ThreadSafeClIEntConnManager; import org.apache.http.params.BasichttpParams; import org.apache.http.params.httpParams; import org.apache.http.params.httpProtocolParams; import org.apache.http.protocol.http; import androID.app.Application; public class MyApplication extends Application { private httpClIEnt httpClIEnt; @OverrIDe public voID onCreate() { super.onCreate(); httpClIEnt = this.createhttpClIEnt(); } @OverrIDe public voID onLowMemory() { super.onLowMemory(); this.shutdownhttpClIEnt(); } @OverrIDe public voID onTerminate() { super.onTerminate(); this.shutdownhttpClIEnt(); } //创建httpClIEnt实例 private httpClIEnt createhttpClIEnt() { httpParams params = new BasichttpParams(); httpProtocolParams.setVersion(params,httpVersion.http_1_1); httpProtocolParams.setContentCharset(params,http.DEFAulT_CONTENT_CHARSET); httpProtocolParams.setUseExpectContinue(params,true); SchemeRegistry schReg = new SchemeRegistry(); schReg.register(new Scheme("http",PlainSocketFactory.getSocketFactory(),80)); schReg.register(new Scheme("https",SSLSocketFactory.getSocketFactory(),443)); ClIEntConnectionManager connMgr = new ThreadSafeClIEntConnManager(params,schReg); return new DefaulthttpClIEnt(connMgr,params); } //关闭连接管理器并释放资源 private voID shutdownhttpClIEnt() { if (httpClIEnt != null && httpClIEnt.getConnectionManager() != null) { httpClIEnt.getConnectionManager().shutdown(); } } //对外提供httpClIEnt实例 public httpClIEnt gethttpClIEnt() { return httpClIEnt; } }
我们重写了onCreate()方法,在系统启动时就创建一个httpClIEnt;重写了onLowMemory()和onTerminate()方法,在内存不足和应用结束时关闭连接,释放资源。需要注意的是,当实例化DefaulthttpClIEnt时,传入一个由ThreadSafeClIEntConnManager创建的一个ClIEntConnectionManager实例,负责管理httpClIEnt的http连接。
然后,想要让我们这个加强版的“Application”生效,需要在AndroIDManifest.xml中做如下配置:
<application androID:name=".MyApplication" ...> ... </application>
如果我们没有配置,系统默认会使用androID.app.Application,我们添加了配置,系统就会使用我们的com.scott.http.MyApplication,然后就可以在context中调用getApplication()来获取MyApplication实例。
有了上面的配置,我们就可以在活动中应用了,httpActivity.java代码如下:
package com.scott.http; import java.io.ByteArrayOutputStream; import java.io.inputStream; import org.apache.http.httpResponse; import org.apache.http.httpStatus; import org.apache.http.clIEnt.httpClIEnt; import org.apache.http.clIEnt.methods.httpGet; import androID.app.Activity; import androID.os.Bundle; import androID.vIEw.VIEw; import androID.Widget.button; import androID.Widget.Toast; public class httpActivity extends Activity { @OverrIDe protected voID onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentVIEw(R.layout.main); button btn = (button) findVIEwByID(R.ID.btn); btn.setonClickListener(new VIEw.OnClickListener() { @OverrIDe public voID onClick(VIEw v) { execute(); } }); } private voID execute() { try { MyApplication app = (MyApplication) this.getApplication(); //获取MyApplication实例 httpClIEnt clIEnt = app.gethttpClIEnt(); //获取httpClIEnt实例 httpGet get = new httpGet("http://192.168.1.57:8080/web/TestServlet?ID=1001&name=john&age=60"); httpResponse response = clIEnt.execute(get); if (response.getStatusline().getStatusCode() == httpStatus.SC_OK) { inputStream is = response.getEntity().getContent(); String result = inStream2String(is); Toast.makeText(this,result,Toast.LENGTH_LONG).show(); } } catch (Exception e) { e.printstacktrace(); } } //将输入流转换成字符串 private String inStream2String(inputStream is) throws Exception { ByteArrayOutputStream baos = new ByteArrayOutputStream(); byte[] buf = new byte[1024]; int len = -1; while ((len = is.read(buf)) != -1) { baos.write(buf,len); } return new String(baos.toByteArray()); } }
点击“execute”按钮,执行结果如下:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程小技巧。
总结以上是内存溢出为你收集整理的Android中使用HTTP服务的用法详解全部内容,希望文章能够帮你解决Android中使用HTTP服务的用法详解所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)