Android项目重构之路:实现篇(一)

public ApiImpl() {         httpEngine = HttpEngine.getInstance();     }
@Override
public ApiResponse<Void> sendSmsCode4Register(String phoneNum) {         Map<String, String> paramMap = new HashMap<String, String>();         paramMap.put("appKey", APP_KEY);         paramMap.put("method", SEND_SMS_CODE);         paramMap.put("phoneNum", phoneNum);          Type type = new TypeToken<ApiResponse<Void>>(){}.getType();
    try {
        return httpEngine.postHandle(paramMap, type);         } catch (IOException e) {
        return new ApiResponse(TIME_OUT_EVENT, TIME_OUT_EVENT_MSG);         }     }
@Override
public ApiResponse<Void> registerByPhone(String phoneNum, String code, String password) {         Map<String, String> paramMap = new HashMap<String, String>();         paramMap.put("appKey", APP_KEY);         paramMap.put("method", REGISTER);         paramMap.put("phoneNum", phoneNum);         paramMap.put("code", code);         paramMap.put("password", EncryptUtil.makeMD5(password));          Type type = new TypeToken<ApiResponse<List<CouponBO>>>(){}.getType();
    try {
        return httpEngine.postHandle(paramMap, type);         } catch (IOException e) {
        return new ApiResponse(TIME_OUT_EVENT, TIME_OUT_EVENT_MSG);         }     }
@Override
public ApiResponse<Void> loginByApp(String loginName, String password, String imei, int loginOS) {         Map<String, String> paramMap = new HashMap<String, String>();         paramMap.put("appKey", APP_KEY);         paramMap.put("method", LOGIN);         paramMap.put("loginName", loginName);         paramMap.put("password", EncryptUtil.makeMD5(password));         paramMap.put("imei", imei);         paramMap.put("loginOS", String.valueOf(loginOS));          Type type = new TypeToken<ApiResponse<List<CouponBO>>>(){}.getType();
    try {
        return httpEngine.postHandle(paramMap, type);         } catch (IOException e) {
        return new ApiResponse(TIME_OUT_EVENT, TIME_OUT_EVENT_MSG);         }     }
@Override
public ApiResponse<List<CouponBO>> listNewCoupon(int currentPage, int pageSize) {         Map<String, String> paramMap = new HashMap<String, String>();         paramMap.put("appKey", APP_KEY);         paramMap.put("method", LIST_COUPON);         paramMap.put("currentPage", String.valueOf(currentPage));         paramMap.put("pageSize", String.valueOf(pageSize));          Type type = new TypeToken<ApiResponse<List<CouponBO>>>(){}.getType();
    try {
        return httpEngine.postHandle(paramMap, type);         } catch (IOException e) {
        return new ApiResponse(TIME_OUT_EVENT, TIME_OUT_EVENT_MSG);         }     }  }

private static HttpEngine instance = null;
private HttpEngine() {     }
public static HttpEngine getInstance() {
    if (instance == null) {             instance = new HttpEngine();         }return instance;     }
public <T> T postHandle(Map<String, String> paramsMap, Type typeOfT) throws IOException {         String data = joinParams(paramsMap);         HttpUrlConnection connection = getConnection();         connection.setRequestProperty("Content-Length", String.valueOf(data.getBytes().length));         connection.connect();         OutputStream os = connection.getOutputStream();         os.write(data.getBytes());         os.flush();
    if (connection.getResponseCode() == 200) {
        // 获取响应的输入流对象
        InputStream is = connection.getInputStream();
        // 创建字节输出流对象
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        // 定义读取的长度
        int len = 0;
        // 定义缓冲区
        byte buffer[] = new byte[1024];
        // 按照缓冲区的大小，循环读取
        while ((len = is.read(buffer)) != -1) {
            // 根据读取的长度写入到os对象中
            baos.write(buffer, 0, len);             }
        // 释放资源
        is.close();             baos.close();             connection.disconnect();
        // 返回字符串
        final String result = new String(baos.toByteArray());             Gson gson = new Gson();
        return gson.fromJson(result, typeOfT);         } else {             connection.disconnect();
        return null;         }     }
private HttpURLConnection getConnection() {         HttpURLConnection connection = null;
    // 初始化connection
    try {
        // 根据地址创建URL对象
        URL url = new URL(SERVER_URL);
        // 根据URL对象打开链接
        connection = (HttpURLConnection) url.openConnection();
        // 设置请求的方式
        connection.setRequestMethod(REQUEST_MOTHOD);
        // 发送POST请求必须设置允许输入，默认为true
        connection.setDoInput(true);
        // 发送POST请求必须设置允许输出
        connection.setDoOutput(true);
        // 设置不使用缓存
        connection.setUseCaches(false);
        // 设置请求的超时时间
        connection.setReadTimeout(TIME_OUT);             connection.setConnectTimeout(TIME_OUT);             connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");             connection.setRequestProperty("Connection", "keep-alive");             connection.setRequestProperty("Response-Type", "json");             connection.setChunkedStreamingMode(0);         } catch (IOException e) {             e.printStackTrace();         }
    return connection;     }
private String joinParams(Map<String, String> paramsMap) {         StringBuilder stringBuilder = new StringBuilder();
    for (String key : paramsMap.keySet()) {             stringBuilder.append(key);             stringBuilder.append("=");
        try {                 stringBuilder.append(URLEncoder.encode(paramsMap.get(key), ENCODE_TYPE));             } catch (UnsupportedEncodingException e) {                 e.printStackTrace();             }             stringBuilder.append("&");         }
    return stringBuilder.substring(0, stringBuilder.length() - 1);     } }