Base-Android快速开发框架(五)--网络操作之RequestModel、ResponeModel、CustomAsyncHttpClient

　在正式介绍CustomAsyncHttpClient之前，刚好最近有一个朋友找我帮忙给他们看下一个APP。我先上一段代码截图。一段检测版本更新的接口代码。

大家也看出问题所在了吧。1.网络操作、数据解析操作的业务出现在了activity。2.没有使用线程池 3.josn的解析，没有面向对象。代码高耦合，复用性差、可靠性差。下面开始进入主题，如何在业务层都看不到json的解析代码了，直接通过CustomAsyncHttpClient拿到目标对象进行操作。

/** * RequestModel.java *  * @author: allen * @Function: 网络请求模型 * @createDate: 2014-8-29 * @update: */

public class RequestModel {   private String url;// 请求网络地址   private RequestParams params;// 请求参数   private Class<?> cls;// 请求转换数据模型类   private boolean showDialog = true;// 是否显示网络加载对话框   private boolean showErrorMessage = false;// 是否显示错误的信息

   public String getUrl() {      return url;   }

   public void setUrl(String url) {      this.url = url;   }

   public RequestParams getParams() {      return params;   }

   public void setParams(RequestParams params) {      this.params = params;   }

   public Class<?> getCls() {      return cls;   }

   public void setCls(Class<?> cls) {      this.cls = cls;   }

   public boolean isShowDialog() {      return showDialog;   }

   public void setShowDialog(boolean showDialog) {      this.showDialog = showDialog;   }

   public boolean isShowErrorMessage() {      return showErrorMessage;   }

   public void setShowErrorMessage(boolean showErrorMessage) {      this.showErrorMessage = showErrorMessage;   }

}

/** * @className：ResponeModel.java * @author: allen * @Function: 网络响应模型 * @createDate: 2014-8-29 * @update: */public class ResponeModel {    private Object resultObj;// 转换的Json    private JSONObject dataResult;// 转化为对象的json    private String json;// 服务器返回的整体Json    private Integer code = 0;// 错误码    private boolean status;// 状态    private String msg = "";// 错误信息    private String result = "";// 数据    private int totalCount;// 总条数    private Class<?> cls;// 请求转换数据模型类    private String easyName;// 直接解析的名字    private boolean isList = false;// 是否是数组,默认是对象    private String listCountKey = "totalCount";// 获取总条数的key    private boolean isNew = true;// 是否新的解析    private int buyCount;

    public boolean isNew() {        return isNew;    }

    public void setNew(boolean isNew) {        this.isNew = isNew;    }

    public String getListCountKey() {        return listCountKey;    }

    public void setListCountKey(String listCountKey) {        this.listCountKey = listCountKey;    }

    public boolean isList() {        return isList;    }

    public void setList(boolean isList) {        this.isList = isList;    }

    public String getEasyName() {        return easyName;    }

    public void setEasyName(String easyName) {        this.easyName = easyName;    }

    public Class<?> getCls() {        return cls;    }

    public void setCls(Class<?> cls) {        this.cls = cls;    }

    public Object getResultObj() {        return resultObj;    }

    public void setResultObj(Object resultObj) {        this.resultObj = resultObj;    }

    public String getResult() {        return result;    }

    public void setResult(String result) {        this.result = result;    }

    public JSONObject getDataResult() {        return dataResult;    }

    public void setDataResult(JSONObject dataResult) {        this.dataResult = dataResult;    }

    public String getJson() {        return json;    }

    public void setJson(String json) {        this.json = json;    }

    public Integer getCode() {        return code;    }

    public void setCode(Integer code) {        this.code = code;    }

    public boolean isStatus() {        return status;    }

    public void setStatus(boolean status) {        this.status = status;    }

    public String getMsg() {        return msg;    }

    public void setMsg(String msg) {        if (StringUtils.isEmpty(msg)) {            this.msg = "服务器发生未知错误！";        } else {            this.msg = msg;        }    }

    public int getTotalCount() {        return totalCount;    }

    public void setTotalCount(int totalCount) {        this.totalCount = totalCount;    }

    /**     * 初始化所有数据     */    public void init() {

        initResult();    }

    /**     * 获取某一字段     *     * @return     */    public String parseByName(String name) {        try {            if (!getDataResult().isNull(name)                    && !TextUtils                    .isEmpty((getDataResult().get(name).toString()))) {                return (getDataResult().get(name).toString());            }        } catch (JSONException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return "";        }        return "";    }

    public JSONObject parseJsonToJSONObject(String json) {        try {            return new JSONObject(json);        } catch (JSONException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return new JSONObject();        }    }

 /**     * 获取某一字段     *     * @return     */    public String parseByName(JSONObject object, String name) {        try {            if (!object.isNull(name)                    && !TextUtils.isEmpty((object.get(name).toString()))) {                return (object.get(name).toString());            }        } catch (JSONException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return "";        }        return "";    }

    /**     * 处理返回的结果，做一些简单的处理     */    private void initResult() {        if (isStatus()) {            if (getResult() != null && getResult().length() > 0) {                String Head = getResult().substring(0, 1);                // 注：自动快捷解析的情况                // 1.data直接是对象                // 2.data直接是数组（不含条数）                // 3.data直接是对象，对象里面包含“result”数组（条数可选）                // 其它情况均需返回对象，在你的service中进行处理

                // Data是对象                if ("{".equals(Head)) {                    JSONObject object;                    try {                        object = new JSONObject(getResult());

                        setDataResult(object);                        if (isList) {                            // 带分页                            setResultObj(JsonUtil.convertJsonToList(                                    object.get(getEasyName()).toString(),                                    getCls()));                            if (!object.isNull(getListCountKey())) {// list                                // 带总条数                                try {                                    setTotalCount(Integer.parseInt(object                                            .getString(getListCountKey())));                                } catch (Exception e) {                                    // TODO: handle exception                                    setTotalCount(0);                                }                                // 设置其他分页信息                            }                            return;                        }

                        setResultObj(JsonUtil.convertJsonToObject(                                getResult(), getCls()));

                    } catch (Exception e) {                        e.printStackTrace();                    }

                } else if ("[".equals(Head)) {// data是数组                    setResultObj(JsonUtil.convertJsonToList(getResult(),                            getCls()));                }            }        }    }}

RequestModel、ResponeModel封装了网络操作的输入模型和输出模型。RequestModel根据AsyncHttpClient的输入要求做的封装，同时可以控制是否要显示服务器的错误提示信息，是否弹出对话框。ResponeModel封装了业务层所需要的实体对象。接下来看下关键的CustomAsyncHttpClient处理。

public class CustomAsyncResponehandler extends AsyncHttpResponseHandler {

   private CustomAsyncResponehandler customAsyncResponehandler;

   public CustomAsyncResponehandler() {      customAsyncResponehandler = null;   }

   public CustomAsyncResponehandler(         CustomAsyncResponehandler customAsyncResponehandler) {      if (customAsyncResponehandler != null)         this.customAsyncResponehandler = customAsyncResponehandler;   }

   public void onSuccess(ResponeModel baseModel) {      if (customAsyncResponehandler != null)         customAsyncResponehandler.onSuccess(baseModel);   }

   @Override   public void onStart() {      super.onStart();      if (customAsyncResponehandler != null)         customAsyncResponehandler.onStart();   }

   @Override   public void onFinish() {      super.onFinish();      if (customAsyncResponehandler != null)         customAsyncResponehandler.onFinish();   }

   @Override   public void onFailure(Throwable error, String content) {      super.onFailure(error, content);      if (customAsyncResponehandler != null)         customAsyncResponehandler.onFailure(error, content);   }}

public class CustomAsyncHttpClient {    private String TAG = "CustomAsyncHttpClient";    private boolean isTag = true;

    private AsyncHttpClient asyncHttpClient;    private MyProgressDialog dialog;    private Context mContext;    private ResponeModel baseModel;

    public CustomAsyncHttpClient(Context context) {        asyncHttpClient = new AsyncHttpClient();        mContext = context;        if (mContext != null) {            dialog = new MyProgressDialog(mContext, "", true);            dialog.tv_value.setVisibility(View.GONE);        }        baseModel = new ResponeModel();    }

    public void post(final RequestModel requestModel,                     final CustomAsyncResponehandler responseHandler) {

        RequestParams newParams = new RequestParams();        com.alibaba.fastjson.JSONObject jsonObject = new                com.alibaba.fastjson.JSONObject();        for (BasicNameValuePair param :                requestModel.getParams().getParamsList()) {            jsonObject.put(param.getName(), param.getValue());        }        newParams.fileParams=requestModel.getParams().fileParams;

        newParams.put("p", jsonObject.toString());

        LogUtil.d(TAG, requestModel.getUrl() + "?"                + newParams.toString(), isTag);        asyncHttpClient.post(requestModel.getUrl(), newParams,                new AsyncHttpResponseHandler() {                    @Override                    public void onStart() {                        super.onStart();                        LogUtil.d(TAG, "onStart___", isTag);                        if (requestModel.isShowDialog()) {// 显示网络对话框                            if (mContext != null) {                                dialog.show();                            }                        }                        responseHandler.onStart();                    }

                    @Override                    public void onFinish() {                        super.onFinish();                        LogUtil.d(TAG, "onFinish___", isTag);                        if (requestModel.isShowDialog()) {// 隐藏网络对话框                            if (mContext != null) {                                dialog.dismiss();                            }                        }                        responseHandler.onFinish();                    }

                    @Override                    public void onSuccess(String content) {                        super.onSuccess(content);                        LogUtil.d(TAG, "onSuccess___" + content, isTag);

                        // TODO:解密返回的参数                        baseModel = JsonUtil.convertJsonToObject(content,                                ResponeModel.class);

                        if (baseModel != null) {                            baseModel.setCls(requestModel.getCls());                            baseModel.setJson(content);                            baseModel.init();                            if(baseModel.isStatus()){                                baseModel.setMsg("操作成功");                            }                        }

                        if (requestModel.isShowErrorMessage()&&!baseModel.isStatus()) {                            if (mContext != null) {                                UIHelper.ShowMessage(mContext,                                        baseModel.getMsg());                            }                        }

                        responseHandler.onSuccess(baseModel);                    }

                    @Override                    public void onFailure(Throwable error, String content) {                        super.onFailure(error, content);                        LogUtil.d(TAG, "onFailure___" + content, isTag);                        if (mContext != null) {                            UIHelper.ShowMessage(mContext,                                   "网络异常");                        }                        responseHandler.onFailure(error, content);                    }                });    }}

以后无须再为网络操作而操碎心，下一步希望在Base里面加入支持xml的自动对象转换以及webservice服务器调用的封装支持，希望有兴趣的、或者有更好方案的大神联系我。下面再上一下上一节的使用案例，网络操作的登陆方法：

public void login(final String userName, final String password, final CustomAsyncResponehandler handler) {    RequestModel requestModel = new RequestModel();    RequestParams params = new RequestParams();    params.put("userName", userName);    params.put("password", password);    requestModel.setParams(params);    requestModel.setCls(User.class);    requestModel.setShowErrorMessage(true);    requestModel.setUrl(Urls.userLogin);    httpClient.post(requestModel, new CustomAsyncResponehandler() {        @Override        public void onSuccess(ResponeModel baseModel) {            super.onSuccess(baseModel);

            if (baseModel != null && baseModel.isStatus()) {                AppContext.currentUser = (User) baseModel.getResultObj();                AppContext.currentUser.setUserName(userName);                if (userDao != null) {                    userDao.insert(AppContext.currentUser);                }            }            handler.onSuccess(baseModel);        }    });}