快捷導(dǎo)航

java遞歸實(shí)現(xiàn)拼裝多個(gè)api的結(jié)果操作方法

更新時(shí)間：2021年09月16日 11:55:18 作者：Mars.wang

本文給大家分享java遞歸實(shí)現(xiàn)拼裝多個(gè)api的結(jié)果的方法，說(shuō)白了就是好幾個(gè)API結(jié)果拼裝成的，本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友參考下吧

工作需要，經(jīng)常需要實(shí)現(xiàn)api接口，但每次都是大同小異，我就考慮是否可以將這種重復(fù)性的工作配置化。

我就寫一個(gè)模板api,然后所有的HTTP請(qǐng)求過(guò)來(lái)，根據(jù)不同的配置返回不同結(jié)果。

最開(kāi)始考慮的是比較簡(jiǎn)單的，來(lái)一個(gè)api需求，我就去MySQL查一條這個(gè)api對(duì)應(yīng)的SQL，然后拿SQL去取結(jié)果，返回。

這個(gè)不難。

關(guān)鍵是實(shí)際需求中，有很多api返回的數(shù)據(jù)很復(fù)雜，比如渲染地圖的接口，一般一條SQL搞不定。

那我就想，那我能不能實(shí)現(xiàn)api的拼裝呢，你看到我只是調(diào)用了一個(gè)API，但是我給你返回的結(jié)果，其實(shí)是好幾個(gè)API結(jié)果拼裝成的。

經(jīng)過(guò)研究，是可以實(shí)現(xiàn)的。

首先我們定義一個(gè)ApiConfig的模型

@Data
@Table(name = "api_config")
@AllArgsConstructor
public class ApiConfig implements Serializable {

    @ApiModelProperty("api名稱")
    private String apiName;

    @ApiModelProperty("數(shù)據(jù)源名稱")
    private String dsName;

    @ApiModelProperty("SQL")
    private String querySql;

    @ApiModelProperty("結(jié)果類型")
    private String resultType;

    @ApiModelProperty("結(jié)果描述")
    private String resultDesc;

    @ApiModelProperty("依賴api")
    private String dependApiName;
}

接下來(lái)就是我們的實(shí)現(xiàn)類，因?yàn)槭钦宫F(xiàn)可行性，所以我們不分層，在一個(gè)Test類中把所有邏輯實(shí)現(xiàn)

{"key1":"x/y/1",
"key2":"x/y/2"}

接下來(lái)就是我們的實(shí)現(xiàn)類，因?yàn)槭钦宫F(xiàn)可行性，所以我們不分層，在一個(gè)Test類中把所有邏輯實(shí)現(xiàn)

@Slf4j
public class Test {
    //測(cè)試數(shù)據(jù)的初始化
    public static List<ApiConfig> apiConfigList = new ArrayList<>();
    public static Map<String, String> sqlResultMap = ImmutableMap.of("sql1", "{\"a\":\"1\"}", "sql2", "{\"b\":\"2\"}", "sql3", "{\"c\":\"3\"}");

    static {
        ApiConfig api1 = new ApiConfig("p1", "d1", "sql1", "map", "", "{\"b\":\"p1/x1\"}");
        ApiConfig api2 = new ApiConfig("p1/x1", "d1", "sql2", "map", "", "{\"c\":\"p1/x2\"}");
        ApiConfig api3 = new ApiConfig("p1/x2", "d1", "sql3", "map", "", null);
        apiConfigList.add(api1);
        apiConfigList.add(api2);
        apiConfigList.add(api3);
    }

    /**
     * 我要進(jìn)行http:ip:port/p1這個(gè)請(qǐng)求，請(qǐng)返回我相關(guān)數(shù)據(jù)
     * @param args
     */
    public static void main(String[] args) {
        //根據(jù)api名稱獲取結(jié)果
        String apiName = "p1";
        JSONObject json = doGetResult(apiName);
        //result必須初始化，而且在方法內(nèi)部不能重新new，以保證遞歸方法內(nèi)更新的是同一個(gè)對(duì)象，否則拿不到更新數(shù)據(jù)后的result
        JSONVO result = null;
        if (json != null) {
            result = new JSONVO(json.toJSONString());
        } else {
            result = new JSONVO("{}");
        }
        //如有需要，遞歸獲取子api的結(jié)果，并存入result
        getApiResult(apiName, null, result);
        System.out.println(result);

    }

    /**
     * 從子api查詢結(jié)果，并更新到主result
     * @param apiName
     * @param dataKey
     * @param result
     */
    public static void getApiResult(String apiName, String dataKey, JSONVO result) {
        //dataKey在進(jìn)入方法時(shí)是等于null的，第二次進(jìn)入肯定不應(yīng)該為null,這個(gè)地方是更新result的關(guān)鍵位置
        if (dataKey != null) {
            JSONObject json = doGetResult(apiName);
            result.set(dataKey, json);
        }
        //進(jìn)入遞歸的入口
        String dependApiName = getApiConfig(apiName).getDependApiName();
        if (dependApiName != null) {
            JSONObject dependApi = JSONObject.parseObject(dependApiName);
            Set<String> keySet = dependApi.keySet();
            for (String key : keySet) {
                String subApi = dependApi.getString(key);
                getApiResult(subApi, key, result);
            }

        }
    }

    public static JSONObject doGetResult(String apiName) {
        String querySql = getApiConfig(apiName).getQuerySql();
        return doQuery(querySql);
    }

    /**
     * 根據(jù)api名稱獲取apiConfig
     *
     * @param api
     * @return
     */
    public static ApiConfig getApiConfig(String api) {
        for (ApiConfig apiConfig : apiConfigList) {
            if (apiConfig.getApiName().equals(api)) {
                return apiConfig;
            }
        }
        log.error("api not exists!");
        return null;
    }

    /**
     * 根據(jù)查詢SQL獲取結(jié)果
     *
     * @param sql
     * @return
     */
    public static JSONObject doQuery(String sql) {
        String s = sqlResultMap.get(sql);
        JSONObject jsonObject = JSONObject.parseObject(s);
        return jsonObject;
    }


}

輸出結(jié)果：