在Android开发中，网络请求必然是必不可少。一般而言，都是基于http的网络请求。有时候也会有SOCKET请求，这个后续的专题再讲。今天，我们就先讲讲常用的Http请求。
http请求自然是遵循http协议的，相关内容请转接：Java学习笔记之Http协议详解
好了，开始今天的正题。
一、基础HTTPURL请求方式
我们先来看一个最简单的例子，通过get方法请求拿到返回值
1、用get方式请求
URL url = new URL( "http://192.168.31.144:10010/MINATest/servlet/DataTestServlet?username=victor&password=strikefreedom"); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); conn.setConnectTimeout(TIME); conn.setReadTimeout(TIME); int responseCode = conn.getResponseCode(); if (responseCode == 200) { input = conn.getInputStream(); if (input != null) { //拿到流后处理 } }2、用post方式请求
String data = "username=justice&password=infiniteJustice"; URL url = new URL( "http://192.168.31.144:10010/MINATest/servlet/DataTestServlet"); conn = (HttpURLConnection) url.openConnection(); conn.setConnectTimeout(TIME); conn.setReadTimeout(TIME); conn.setDoInput(true);// 允许输入 conn.setDoOutput(true);// 允许输出 conn.setUseCaches(false);// 不使用Cache conn.setRequestProperty("Charset", ENCODING); conn.setRequestProperty("Content-Length", String.valueOf(data.length())); conn.setRequestProperty("Content-Type", "text/*;charset=utf-8"); conn.setRequestMethod("POST"); DataOutputStream outStream = new DataOutputStream( conn.getOutputStream()); outStream.write(data.getBytes()); outStream.flush(); outStream.close(); if (conn == null) { return; } int responseCode = conn.getResponseCode(); if (responseCode == 200) { input = conn.getInputStream(); if (input != null) { } }我们可以看到用post方式请求和用get方式传入参数有点不同。
二、http访问类的封装
1、封装逻辑
我们知道，在android开发中，网络访问的东西都是不能在UI线程中执行的，只能在子线程里面执行，得到结果后通知主线程刷新UI。这个消息通知机制博主就不在详细描述，有兴趣的朋友请转接：Android异步处理系列文章索引
在正常的开发中，我们不会每次请求，都像上面那样的简单去写，我们需要做一定的封装处理，来使代码更加的简洁，架构更加的清晰。那么我们需要这么四个东西
1、http访问管理者
2、消息通信管理者handler
3、http访问结果监听器
4、http访问结果事件处理回调接口。
整个逻辑关系为：http访问管理者采用get或者post请求方式请求，当产生结果后监听器告诉消息通信管理者应该发送什么消息给UI线程，UI线程更具消息通信管理者发送过来的消息，调用对应的事件处理回调接口。
那么我们来一一对应看这四个类该如何编写。
2、http访问管理者
http访问管理者，如其名，里面需要封装两种请求。正常情况下，在构造出http访问管理者的时候，需要传入一个通信协议的类进入，里面应该包含请求地址以及请求信息，这里博主为了方便省事，没有出入，直接写死了。有兴趣的同学可以根据自身实际需求更改。看代码：
package com.example.nettest;import java.io.ByteArrayOutputStream;import java.io.DataOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.UnsupportedEncodingException;import java.net.HttpURLConnection;import java.net.SocketException;import java.net.SocketTimeoutException;import java.net.URL;import java.net.URLEncoder;import java.util.HashMap;import java.util.Map;import android.content.Context;import android.text.TextUtils;import android.util.Log;/** * @ClassName: FreedomHttpUrlUtils * @author victor_freedom ([email protected]) * @createddate 2015-1-22 下午1:43:58 * @Description: http请求管理者 */public class FreedomHttpUrlUtils implements Runnable { private Context context; /** http访问结果监听器 */ private FreedomHttpListener listener; /** 当前访问线程 */ private Thread currentRequest = null; /** 访问链接 */ HttpURLConnection conn = null; /** 拿到的流 */ InputStream input = null; private static final String ENCODING = "UTF-8"; public static final int GET_MOTHOD = 1; private static final int TIME = 40 * 1000; public static final int POST_MOTHOD = 2; /** * 1： get请求 2： post请求 */ private int requestStatus = 1; /** * <p> * Title: * </p> * <p> * Description:构造方法，其实在这里可以传入一个传输协议包，博主是测试代码，所以请求中直接写死了。 * </p> * * @param mContext * @param listener * 监听器 * @param mRequeststatus * 请求方式 */ public FreedomHttpUrlUtils(Context mContext, FreedomHttpListener listener, int mRequeststatus) { this.context = mContext; this.requestStatus = mRequeststatus; this.listener = listener; } /** * @Title: postRequest * @Description:Post请求触发 * @throws */ public void postRequest() { requestStatus = 2; currentRequest = new Thread(this); currentRequest.start(); } /** * @Title: getRequeest * @Description:GET请求触发 * @throws */ public void getRequeest() { requestStatus = 1; currentRequest = new Thread(this); currentRequest.start(); } /** * 对请求的字符串进行编码 * * @return * @throws UnsupportedEncodingException */ public static String requestEncodeStr(String requestStr) throws UnsupportedEncodingException { return URLEncoder.encode(requestStr, ENCODING); } /** * @Title: sendGetRequest * @Description: 发送get请求 * @throws */ private void sendGetRequest() { try { URL url = new URL( "http://192.168.31.144:10010/MINATest/servlet/DataTestServlet?username=victor&password=strikefreedom"); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); conn.setConnectTimeout(TIME); conn.setReadTimeout(TIME); int responseCode = conn.getResponseCode(); if (responseCode == 200) { input = conn.getInputStream(); if (input != null) { listener.action(FreedomHttpListener.EVENT_GET_DATA_SUCCESS, readStream(input)); } } else { listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } } catch (SocketException e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_CLOSE_SOCKET, null); } catch (SocketTimeoutException e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } catch (IOException e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_GET_DATA_EEEOR, null); } catch (Exception e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } } /** * @Title: sendPostRequest * @Description: 发送post请求 * @throws */ private void sendPostRequest() { try { String data = "username=justice&password=infiniteJustice"; URL url = new URL( "http://192.168.31.144:10010/MINATest/servlet/DataTestServlet"); conn = (HttpURLConnection) url.openConnection(); conn.setConnectTimeout(TIME); conn.setReadTimeout(TIME); conn.setDoInput(true);// 允许输入 conn.setDoOutput(true);// 允许输出 conn.setUseCaches(false);// 不使用Cache conn.setRequestProperty("Charset", ENCODING); conn.setRequestProperty("Content-Length", String.valueOf(data.length())); conn.setRequestProperty("Content-Type", "text/*;charset=utf-8"); conn.setRequestMethod("POST"); DataOutputStream outStream = new DataOutputStream( conn.getOutputStream()); outStream.write(data.getBytes()); outStream.flush(); outStream.close(); if (conn == null) { return; } int responseCode = conn.getResponseCode(); if (responseCode == 200) { input = conn.getInputStream(); if (input != null) { listener.action(FreedomHttpListener.EVENT_GET_DATA_SUCCESS, readStream(input)); } } else if (responseCode == 404) { input = conn.getErrorStream(); if (input != null) { listener.action(FreedomHttpListener.EVENT_GET_DATA_SUCCESS, readStream(input)); } else { listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } } else { listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } } catch (SocketException e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_CLOSE_SOCKET, null); } catch (SocketTimeoutException e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } catch (IOException e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_GET_DATA_EEEOR, null); } catch (Exception e) { e.printStackTrace(); listener.action(FreedomHttpListener.EVENT_NETWORD_EEEOR, null); } } /** * @Title: isRunning * @Description: 判断是否正在访问 * @return * @throws */ public boolean isRunning() { if (currentRequest != null && currentRequest.isAlive()) { return true; } return false; } /** * 读取数据 * * @param inStream * 输入流 * @return * @throws Exception */ private Object readStream(InputStream inStream) throws Exception { String result; ByteArrayOutputStream outStream = new ByteArrayOutputStream(); byte[] buffer = new byte[1024]; int len = -1; while ((len = inStream.read(buffer)) != -1) { outStream.write(buffer, 0, len); } result = new String(outStream.toByteArray(), ENCODING); outStream.close(); inStream.close(); return result; } /** * 取消当前HTTP连接处理 */ public void cancelHttpRequest() { if (currentRequest != null && currentRequest.isAlive()) { if (input != null) { try { input.close(); } catch (Exception e) { e.printStackTrace(); } } input = null; if (conn != null) { try { conn.disconnect(); } catch (Exception e) { e.printStackTrace(); } } conn = null; currentRequest = null; System.gc(); } } /** * 发送请求 */ public void run() { // 判断是否有网络 boolean netType = NetUtils.checkNetWork(context); if (netType) { if (requestStatus == 1) { sendGetRequest(); } else if (requestStatus == 2) { sendPostRequest(); } } else { listener.action(FreedomHttpListener.EVENT_NOT_NETWORD, null); } }}
我们可以看到，当访问有结果以后，会出发监听器的action方法，那么我们再来看看监听器的定义
3、http访问结果监听器
package com.example.nettest;/** * @ClassName: FreedomHttpListener * @author victor_freedom ([email protected]) * @createddate 2015-1-24 下午4:28:31 * @Description: 监听器 */public interface FreedomHttpListener { public static final int EVENT_BASE = 0x100; /** * 没有网络的信息提示 * */ public static final int EVENT_NOT_NETWORD = EVENT_BASE + 1; /** * 网络异常的信息提示 * */ public static final int EVENT_NETWORD_EEEOR = EVENT_BASE + 2; /** * 获取网络数据失败 * */ public static final int EVENT_GET_DATA_EEEOR = EVENT_BASE + 3; /** * 获取网络数据成功 * */ public static final int EVENT_GET_DATA_SUCCESS = EVENT_BASE + 4; /** * 获取网络数据成功 * */ public static final int EVENT_CLOSE_SOCKET = EVENT_BASE + 5; public void action(int actionCode, Object object);}
我们可以看到，在触发action动作的时候，我们会传入一个code和一个对象，这个code表示当前访问是否成功，而对象就是要传输的访问结果。
我们再看看消息处理器是如何工作的
4、消息处理器
/** * @ClassName: BaseHandler * @author victor_freedom ([email protected]) * @createddate 2015-1-24 下午4:32:05 * @Description: 消息处理器 */ class BaseHandler extends Handler { private Context context; /** 事件回调接口处理 */ private FreedomDataCallBack callBack; public BaseHandler(Context context, FreedomDataCallBack callBack) { this.context = context; this.callBack = callBack; } public void handleMessage(Message msg) { // 根据不同的结果触发不同的动作 if (msg.what == FreedomHttpListener.EVENT_GET_DATA_SUCCESS) { if (msg.obj == null) { callBack.onFailed(); } else { // 后台处理数据 callBack.processData(msg.obj, true); } } else if (msg.what == FreedomHttpListener.EVENT_NOT_NETWORD) { callBack.onFailed(); // CommonUtil.showInfoDialog(context, // getString(R.string.net_error)); } else if (msg.what == FreedomHttpListener.EVENT_NETWORD_EEEOR) { callBack.onFailed(); } else if (msg.what == FreedomHttpListener.EVENT_GET_DATA_EEEOR) { callBack.onFailed(); } else if (msg.what == FreedomHttpListener.EVENT_CLOSE_SOCKET) { } callBack.onFinish(); } }
我们可以看到，在消息处理器中传入了一个回调接口类，在不同的返回结果中，触发不同的回调动作。
5、回调接口
package com.example.nettest;/** * @ClassName: FreedomDataCallBack * @author victor_freedom ([email protected]) * @createddate 2015-1-24 下午4:33:38 * @Description: 回调接口，处理返回数据 * @param <T> */public interface FreedomDataCallBack<T> { public abstract void onStart(); public abstract void processData(T paramObject, boolean paramBoolean); public abstract void onFinish(); public abstract void onFailed();}
因为我们不知道返回的结果是什么类型的，这里采用泛型来处理
三、http封装后的使用
1、从服务器拿数据的方法
所有的东西我们都已经封装好了之后，该怎么使用呢？我们来尝试写一个方法吧，从服务器获取数据并返回。我们先写一个getDataFromserver的方法在基类中
/** * @Title: getDataFromServer * @Description: 从服务器拿数据 * @param requestType * 请求方式 * @param callBack * 回调接口 * @throws */ protected void getDataFromServer(int requestType, FreedomDataCallBack callBack) { final BaseHandler handler = new BaseHandler(this, callBack); freedomHttpUrlUtils = new FreedomHttpUrlUtils(mContext, new FreedomHttpListener() { @Override public void action(int actionCode, Object object) { Message msg = new Message(); switch (actionCode) { case FreedomHttpListener.EVENT_NOT_NETWORD: msg.what = FreedomHttpListener.EVENT_NOT_NETWORD; break; case FreedomHttpListener.EVENT_NETWORD_EEEOR: msg.what = FreedomHttpListener.EVENT_NETWORD_EEEOR; break; case FreedomHttpListener.EVENT_CLOSE_SOCKET: msg.what = FreedomHttpListener.EVENT_CLOSE_SOCKET; break; case FreedomHttpListener.EVENT_GET_DATA_EEEOR: msg.what = FreedomHttpListener.EVENT_GET_DATA_EEEOR; msg.obj = null; break; case FreedomHttpListener.EVENT_GET_DATA_SUCCESS: msg.obj = object; msg.what = FreedomHttpListener.EVENT_GET_DATA_SUCCESS; break; default: break; } handler.sendMessage(msg); } }, requestType); callBack.onStart(); // 选择不同的请求方法 if (requestType == FreedomHttpUrlUtils.GET_MOTHOD) { freedomHttpUrlUtils.getRequeest(); } else if (requestType == FreedomHttpUrlUtils.POST_MOTHOD) { freedomHttpUrlUtils.postRequest(); } }2、方法的使用
我们在主Activity中启用一下这个方法。为了方便，博主这里是提交了什么参数就返回什么参数。这里提交的参数统一为username和password形式。请求详细参数请看FreedomHttpUrlUtils中。
我们先看服务端的处理方式：
@Override public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String parameter = request.getParameter("username"); String parameter2 = request.getParameter("password"); System.out.println(parameter + parameter2); response.setContentType("text/*;charset=utf-8"); response.getWriter().write(parameter + "-" + parameter2); } @Override public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { // doGet(request, response); System.out.println("post"); ServletInputStream inputStream = request.getInputStream(); ByteOutputStream b = new ByteOutputStream(); int len = -1; byte[] buf = new byte[1024]; while ((len = inputStream.read(buf)) != -1) { b.write(buf, 0, buf.length); } String s = b.toString(); String[] split = s.split("&"); System.out.println(split[0] + split[1]); response.setContentType("text/*;charset=utf-8"); response.getWriter().write( split[0].substring(split[0].lastIndexOf("=") + 1) + "-" + split[1].substring(split[1].lastIndexOf("=") + 1)); }我们在看在activity中的调用：
/*** @ClassName: MainActivity* @author victor_freedom ([email protected])* @createddate 2015-1-24 下午4:40:59* @Description: TODO */public class MainActivity extends BaseActivity { private TextView get; private TextView post; @Override protected void findViewById() { get = (TextView) findViewById(R.id.hello); post = (TextView) findViewById(R.id.post); } @Override protected void loadViewLayout() { setContentView(R.layout.activity_main); } @Override protected void processLogic() { } @Override protected void setListener() { } @Override protected void init() { getDataFromServer(1, new FreedomDataCallBack<String>() { @Override public void onStart() { } @Override public void processData(String paramObject, boolean paramBoolean) { get.setText(paramObject); } @Override public void onFinish() { } @Override public void onFailed() { } }); getDataFromServer(2, new FreedomDataCallBack<String>() { @Override public void onStart() { } @Override public void processData(String paramObject, boolean paramBoolean) { post.setText(paramObject); } @Override public void onFinish() { } @Override public void onFailed() { } }); }
我们这里分别采用了两种方法访问，传入参数也是不同的，我们看访问结果，两个textView均显示了访问返回的值。
好了，第一篇关于http访问的文章已经讲解完毕，希望能够帮助到看到此文的人。下一篇我们讲解如何使用httpclient类来实现http网络请求，并实现文件的上传和下载功能。