基于PHP的轻量级开源接口框架PhalApi设计源码

package net.phalapi.sdk; import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.util.HashMap; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry; import org.json.JSONObject; import android.util.Log; /** * PhalApi客户端SDK包（JAVA版） * * - 以接口查询语言（ASQL）的方式来实现接口请求 * - 出于简明客户端，将全部的类都归于同一个文件，避免过多的加载 * * <br>使用示例：<br> ``` * PhalApiClientResponse response = PhalApiClient.create() * .withHost("http://demo.phalapi.net/") * .withService("Default.Index") * .withParams("name", "dogstar") * .withTimeout(3000) * .request(); * * Log.v("response ret", response.getRet() + ""); * Log.v("response data", response.getData()); * Log.v("response msg", response.getMsg()); ``` * * @package PhalApi\Response * @license http://www.phalapi.net/license GPL 协议 * @link http://www.phalapi.net/ * @author dogstar <[email protected]> 2015-10-16 */ public class PhalApiClient { protected String host; protected PhalApiClientFilter filter; protected PhalApiClientParser parser; protected String service; protected int timeoutMs; protected Map<String, String> params; /** * 创建一个接口实例，注意：不是单例模式 * @return PhalApiClient */ public static PhalApiClient create() { return new PhalApiClient(); } protected PhalApiClient() { this.host = ""; this.reset(); this.parser = new PhalApiClientParserJson(); } /** * 设置接口域名 * @param String host * @return PhalApiClient */ public PhalApiClient withHost(String host) { this.host = host; return this; } /** * 设置过滤器，与服务器的DI().filter对应 * @param PhalApiClientFilter filter 过滤器 * @return PhalApiClient */ public PhalApiClient withFilter(PhalApiClientFilter filter) { this.filter = filter; return this; } /** * 设置结果解析器，仅当不是JSON返回格式时才需要设置 * @param PhalApiClientParser parser 结果解析器 * @return PhalApiClient */ public PhalApiClient withParser(PhalApiClientParser parser) { this.parser = parser; return this; } /** * 重置，将接口服务名称、接口参数、请求超时进行重置，便于重复请求 * @return PhalApiClient */ public PhalApiClient reset() { this.service = ""; this.timeoutMs = 3000; this.params = new HashMap<String, String>(); return this; } /** * 设置将在调用的接口服务名称，如：Default.Index * @param String service 接口服务名称 * @return PhalApiClient */ public PhalApiClient withService(String service) { this.service = service; return this; } /** * 设置接口参数，此方法是唯一一个可以多次调用并累加参数的操作 * @param String name 参数名字 * @param String value 值 * @return PhalApiClient */ public PhalApiClient withParams(String name, String value) { this.params.put(name, value); return this; } /** * 设置超时时间，单位毫秒 * @param int timeoutMS 超时时间，单位毫秒 * @return PhalApiClient */ public PhalApiClient withTimeout(int timeoutMS) { this.timeoutMs = timeoutMS; return this; } /** * 发起接口请求 * @return PhalApiClientResponse */ public PhalApiClientResponse request() { String url = this.host; if (this.service != null && this.service.length() > 0) { url += "?service=" + this.service; } if (this.filter != null) { this.filter.filter(this.service, this.params); } try { String rs = this.doRequest(url, this.params, this.timeoutMs); return this.parser.parse(rs); } catch (Exception ex) { return new PhalApiClientResponse(408, "", ex.getMessage()); } } protected String doRequest(String requestUrl, Map<String, String> params, int timeoutMs) throws Exception { String result = null; URL url = null; HttpURLConnection connection = null; InputStreamReader in = null; url = new URL(requestUrl); connection = (HttpURLConnection) url.openConnection(); connection.setDoInput(true); connection.setDoOutput(true); connection.setRequestMethod("POST"); // 请求方式 connection.setUseCaches(false); connection.setConnectTimeout(timeoutMs); DataOutputStream out = new DataOutputStream(connection.getOutputStream()); //POST参数 String postContent = ""; Iterator<Entry<String, String>> iter = params.entrySet().iterator(); while (iter.hasNext()) { Map.Entry<String, String> entry = (Map.Entry<String, String>) iter.next(); postContent += "&" + entry.getKey() + "=" + entry.getValue(); } out.writeBytes(postContent); out.flush(); out.close(); Log.d("[PhalApiClient requestUrl]", requestUrl + postContent); in = new InputStreamReader(connection.getInputStream()); BufferedReader bufferedReader = new BufferedReader(in); StringBuffer strBuffer = new StringBuffer(); String line = null; while ((line = bufferedReader.readLine()) != null) { strBuffer.append(line); } result = strBuffer.toString(); Log.d("[PhalApiClient apiResult]", result); if (connection != null) { connection.disconnect(); } if (in != null) { try { in.close(); } catch (IOException e) { e.printStackTrace(); } } return result; } }