本篇文章只涉及到應用層面，沒有涉及到什么底層原理之類的，我目前的實力還沒有達到那個級別。如果是大神級別的人看到這篇文章，請跳過。
項目框架也已經是搭建好了的，springboot版本為1.5，數據庫操作使用的是Mybatis，數據庫使用的Oracle，前端使用VUE，Node.js打包之類的。由於
實際需要，要在多個項目之間相互調用，其中一種方式是訪問一個固定的項目，只有一台服務器；還有一種方式是調用一個項目，該項目部署了多台服
務器。
調用方式一
通過一個項目調用另外一個項目，調用地址固定，調用方式為通過 RestTemplate 這個類來進行調用，由spring提供。這樣調用的原因是當前這個
項目中有不同的數據源，除了Oracle的還有其他的數據庫，可是其他的數據庫連接資源有限，除了我們負責的子項目在調用外，其他人也在進行調用。
所以最后就將被調用方做成了一個單獨的服務，讓其他系統之間可以直接調用。大致的實現方式為拿到傳遞的參數，通過反射的方式拿到對應的service
實現類，然后通過serviceImpl調用Mapper.java中的方法執行增、刪、改、查操作，最后將返回的結果返回給調用方。請求時參數的傳遞方式為通過
Map<String, String>傳輸，被調用方通過Map<String, String>可以直接獲取到參數信息。然后通過自定義的JSON工具類來解析數據，分為單個對象
數據、列表數據、分頁數據。經過反復的調試，最終很好的實現了需求，解決了當前項目中存在的問題。
解析返回參數的工具類為//
@Slf4j
@Component
@Scope(value = "singleton")//顯示單例
public class AnalysisGBaseDataUtils implements InitializingBean {
//私有化構造方法
private AnalysisGBaseDataUtils(){}
private static RestTemplate restTemplate = new RestTemplate();
private static String gbaseApi;
@Value("${gbase.api.prefix}")
private String getGbaseApi;
@Override
public void afterPropertiesSet() throws Exception {
AnalysisGBaseDataUtils.gbaseApi = this.getGbaseApi;
}
/**
* @Description: 方法參數校驗
* @author: 1
* @date: 2020-9-5 10:13:10
* @param: @param <E>
* @param: @param dataMap
* @param: @param e
* @param: @return
* @return: String
*/
private static <E> String paramValidate(Map<String, Object> dataMap, E e) {
if(Objects.equal(dataMap, null)) {
throw new BaseException(MessageConstant.A000001, "dataMap參數錯誤");
}
if(Objects.equal(e, null)) {
throw new BaseException(MessageConstant.A000001, "E類型參數錯誤");
}
if(Objects.equal(dataMap.get("methodName"), null)) {
throw new BaseException(MessageConstant.A000001, "dataMap中methodName參數不能為null!");
}
if(Objects.equal(dataMap.get("serviceId"), null)) {
throw new BaseException(MessageConstant.A000001, "dataMap中serviceId參數不能為null!");
}
String methodName = (String)dataMap.get("methodName");
String serviceId = (String)dataMap.get("serviceId");
if(StringUtils.isBlank(methodName)) {
throw new BaseException(MessageConstant.A000001, "dataMap中methodName參數錯誤!");
}
if(StringUtils.isBlank(serviceId)) {
throw new BaseException(MessageConstant.A000001, "dataMap中serviceId參數錯誤!");
}
return methodName;
}
/**
* @Description: 抽取列表數據解析方法
* @author: 1
* @date: 2020-9-5 10:13:30
* @param: @param <E>
* @param: @param methodName
* @param: @param resultStr
* @param: @param e
* @param: @return
* @return: List<? extends Object>
*/
private static <E> List<? extends Object> analysisData(String methodName, String resultStr, E e) {
List<? extends Object> parseArray = JsonUtils.parseArray(resultStr,"data", e.getClass());
return parseArray;
}
/**
* @Description: 解析分頁數據：新方法，使用更方便(直接傳入 class 對象)，備用
* @author: 1
* @date: 2020-9-21 21:41:03
* @param: @param <E>
* @param: @param dataMap
* @param: @param clazz
* @param: @return
* @return: Page<E>
*/
public static final<E> Page<E> getPageData(Map<String, Object> dataMap, final Class<E> clazz) {
E e = AnalysisGBaseDataUtils.getInstance(clazz);
String methodName = AnalysisGBaseDataUtils.paramValidate(dataMap, e);
Page<E> pages = null;
String resultStr = AnalysisGBaseDataUtils.sendRequest(dataMap, methodName);
try {
pages = new Page<E>();
String pageData = JsonUtils.getSubJson(resultStr, "data");
pages.setCount(true);
if(Objects.equal("[]", pageData)) {
//未獲取到數據
pages.setPageNum(1);
pages.setPageSize(10);
pages.setTotal(0);
pages.setPages(0);
}else {
pages.setPageNum(JsonUtils.parse(pageData, "pageNum"));
pages.setPageSize(JsonUtils.parse(pageData, "pageSize"));
Integer total = JsonUtils.parse(pageData, "total");
pages.setTotal(total);
pages.setPages(JsonUtils.parse(pageData, "pages"));
List<? extends Object> parseArray = AnalysisGBaseDataUtils.analysisData(methodName, pageData, e);
if(!Objects.equal(parseArray, null)) {
for (Object obj : parseArray) {
pages.add((E) obj);
}
}
}
}catch(Exception error) {
AnalysisGBaseDataUtils.log.error(methodName + "-方法-getPageData(clazz)-數據解析錯誤: " + error.getMessage(), error);
throw new BaseException(MessageConstant.A000001, methodName + "-方法-getPageData(clazz)-數據解析錯誤");
}
return pages;
}
/**
* @Description: 解析列表數據：新方法，使用更方便(直接傳入 class 對象)，備用
* @author: 1
* @date: 2020-9-22 14:18:22
* @param: @param <E>
* @param: @param dataMap
* @param: @param clazz
* @param: @return
* @return: List<E>
* @throws IllegalAccessException
* @throws InstantiationException
*/
public static final<E> List<E> getListData(Map<String, Object> dataMap, final Class<E> clazz) {
List<E> resultList = new ArrayList<E>();
E e = AnalysisGBaseDataUtils.getInstance(clazz);
String methodName = AnalysisGBaseDataUtils.paramValidate(dataMap, e);
String resultStr = AnalysisGBaseDataUtils.sendRequest(dataMap, methodName);
try {
List<? extends Object> parseArray = AnalysisGBaseDataUtils.analysisData(methodName, resultStr, e);
if(!Objects.equal(parseArray, null)) {
for (Object object : parseArray) {
resultList.add((E) object);
}
}
}catch(Exception error) {
AnalysisGBaseDataUtils.log.error(methodName + "-方法getListData(clazz)數據解析錯誤: " + error.getMessage(), error);
throw new BaseException(MessageConstant.A000001, methodName + "-方法getListData(clazz)數據解析錯誤");
}
return resultList;
}
/**
* @Description: 解析單條數據：新方法，使用更方便(直接傳入 class 對象)，備用
* @author: 1
* @date: 2020-9-5 10:12:04
* @param: @param <E>
* @param: @param dataMap
* @param: @param e
* @param: @return
* @return: E
*/
public static final <E> E getBeanData(Map<String, Object> dataMap, final Class<E> clazz) {
E e = AnalysisGBaseDataUtils.getInstance(clazz);
String methodName = AnalysisGBaseDataUtils.paramValidate(dataMap, e);
String resultStr = AnalysisGBaseDataUtils.sendRequest(dataMap, methodName);
try {
e = (E) JsonUtils.parse(resultStr, "data", clazz);
}catch(Exception error) {
AnalysisGBaseDataUtils.log.error(methodName + "-方法-getBeanData(clazz)-數據解析錯誤: " + error.getMessage(), error);
throw new BaseException(MessageConstant.A000001, methodName + "-方法-getBeanData(clazz)-數據解析錯誤");
}
return e;
}
/**
* @Description: 抽取發送請求的方法
* @author: 1
* @date: 2020-9-28 13:55:24
* @param: @param dataMap
* @param: @param methodName
* @param: @return
* @return: String
*/
private static String sendRequest(Map<String, Object> dataMap, String methodName) {
String resultStr = AnalysisGBaseDataUtils.restTemplate.postForObject(AnalysisGBaseDataUtils.gbaseApi, dataMap, String.class);
Integer code = JsonUtils.parse(resultStr, "code");
if(!Objects.equal(code, 20000)) {
String msg = JsonUtils.parse(resultStr, "msg", String.class);
AnalysisGBaseDataUtils.log.error(methodName + "-方法-sendRequest-操作錯誤: {}",msg );
throw new BaseException(MessageConstant.A000001, methodName + "-方法-sendRequest-操作錯誤: " + msg);
}
return resultStr;
}
/**
* @Description: 抽取獲取實例的方法
* @author: 1
* @date: 2020-9-28 14:04:42
* @param: @param <E>
* @param: @param clazz
* @param: @return
* @return: E
*/
private static final<E> E getInstance(final Class<E> clazz) {
E e = null;
try {
e = (E) clazz.newInstance();
} catch (InstantiationException | IllegalAccessException error) {
AnalysisGBaseDataUtils.log.error(clazz.toString() + "-方法-getInstance-獲取實例錯誤: " + error.getMessage(), error);
throw new BaseException(MessageConstant.A000001, clazz.toString() + "-方法-getInstance-獲取實例錯誤");
}
return e;
}
}
JSONUtils工具類為//
public class JsonUtils {
/**
* <pre>
* 對象轉化為json字符串
*
* @param obj 待轉化對象
* @return 代表該對象的Json字符串
*/
public static final String toJson(final Object obj) {
return JSON.toJSONString(obj);
// return gson.toJson(obj);
}
/**
* <pre>
* 對象轉化為json字符串
*
* @param obj 待轉化對象
* @return 代表該對象的Json字符串
*/
public static final String toJson(final Object obj, SerializerFeature... features) {
return JSON.toJSONString(obj, features);
// return gson.toJson(obj);
}
/**
* 對象轉化為json字符串並格式化
*
* @param obj
* @param format 是否要格式化
* @return
*/
public static final String toJson(final Object obj, final boolean format) {
return JSON.toJSONString(obj, format);
}
/**
* 對象對指定字段進行過濾處理，生成json字符串
*
* @param obj
* @param fields 過濾處理字段
* @param ignore true做忽略處理，false做包含處理
* @param features json特征，為null忽略
* @return
*/
public static final String toJson(final Object obj, final String[] fields, final boolean ignore,
SerializerFeature... features) {
if (fields == null || fields.length < 1) {
return toJson(obj);
}
if (features == null)
features = new SerializerFeature[] { SerializerFeature.QuoteFieldNames };
return JSON.toJSONString(obj, new PropertyFilter() {
@Override
public boolean apply(Object object, String name, Object value) {
for (int i = 0; i < fields.length; i++) {
if (name.equals(fields[i])) {
return !ignore;
}
}
return ignore;
}
}, features);
}
/**
* <pre>
* 解析json字符串中某路徑的值
*
* @param json
* @param path
* @return
*/
@SuppressWarnings("unchecked")
public static final <E> E parse(final String json, final String path) {
String[] keys = path.split(",");
JSONObject obj = JSON.parseObject(json);
for (int i = 0; i < keys.length - 1; i++) {
obj = obj.getJSONObject(keys[i]);
}
return (E) obj.get(keys[keys.length - 1]);
}
/**
* <pre>
* json字符串解析為對象
*
* @param json 代表一個對象的Json字符串
* @param clazz 指定目標對象的類型，即返回對象的類型
* @return 從json字符串解析出來的對象
*/
public static final <T> T parse(final String json, final Class<T> clazz) {
return JSON.parseObject(json, clazz);
}
/**
* <pre>
* json字符串解析為對象
*
* @param json json字符串
* @param path 逗號分隔的json層次結構
* @param clazz 目標類
*/
public static final <T> T parse(final String json, final String path, final Class<T> clazz) {
String[] keys = path.split(",");
JSONObject obj = JSON.parseObject(json);
for (int i = 0; i < keys.length - 1; i++) {
obj = obj.getJSONObject(keys[i]);
}
String inner = obj.getString(keys[keys.length - 1]);
return parse(inner, clazz);
}
/**
* 將制定的對象經過字段過濾處理后，解析成為json集合
*
* @param obj
* @param fields
* @param ignore
* @param clazz
* @param features
* @return
*/
public static final <T> List<T> parseArray(final Object obj, final String[] fields, boolean ignore,
final Class<T> clazz, final SerializerFeature... features) {
String json = toJson(obj, fields, ignore, features);
return parseArray(json, clazz);
}
/**
* <pre>
* 從json字符串中解析出一個對象的集合，被解析字符串要求是合法的集合類型
* （形如:["k1":"v1","k2":"v2",..."kn":"vn"]）
*
* @param json - [key-value-pair...]
* @param clazz
* @return
*/
public static final <T> List<T> parseArray(final String json, final Class<T> clazz) {
return JSON.parseArray(json, clazz);
}
/**
* <pre>
* 從json字符串中按照路徑尋找，並解析出一個對象的集合，例如：
* 類Person有一個屬性name，要從以下json中解析出其集合：
* {
* "page_info":{
* "items":{
* "item":[{"name":"KelvinZ"},{"name":"Jobs"},...{"name":"Gates"}]
* }
* }
* 使用方法：parseArray(json, "page_info,items,item", Person.class)，
* 將根據指定路徑，正確的解析出所需集合，排除外層干擾
*
* @param json json字符串
* @param path 逗號分隔的json層次結構
* @param clazz 目標類
* @return
*/
public static final <T> List<T> parseArray(final String json, final String path, final Class<T> clazz) {
String[] keys = path.split(",");
JSONObject obj = JSON.parseObject(json);
for (int i = 0; i < keys.length - 1; i++) {
obj = obj.getJSONObject(keys[i]);
}
String inner = obj.getString(keys[keys.length - 1]);
List<T> ret = parseArray(inner, clazz);
return ret;
}
/**
* <pre>
* 有些json的常見格式錯誤這里可以處理，以便給后續的方法處理
* 常見錯誤：使用了\" 或者 "{ 或者 }"，騰訊的頁面中常見這種格式
*
* @param invalidJson 包含非法格式的json字符串
* @return
*/
public static final String correctJson(final String invalidJson) {
String content = invalidJson.replace("\\\"", "\"").replace("\"{", "{").replace("}\"", "}");
return content;
}
/**
* 格式化Json
*
* @param json
* @return
*/
public static final String formatJson(String json) {
Map<?, ?> map = (Map<?, ?>) JSON.parse(json);
return JSON.toJSONString(map, true);
}
/**
* 獲取json串中的子json
*
* @param json
* @param path
* @return
*/
public static final String getSubJson(String json, String path) {
String[] keys = path.split(",");
JSONObject obj = JSON.parseObject(json);
for (int i = 0; i < keys.length - 1; i++) {
obj = obj.getJSONObject(keys[i]);
System.out.println(obj.toJSONString());
}
return obj != null ? obj.getString(keys[keys.length - 1]) : null;
}
}
通過這種方式很好的解決了當前項目中需要相互調用的問題，而且也非常適合當前項目的實際情況。
這中間遇到一個比較棘手的問題是，在數據返回時，分頁數據不能直接使用，需要轉換一次才能使用。
轉換方法也很簡單，如下，
由於該項目的訪問量不是太大，因此這種方式完全符合要求，解決了項目中存在的問題。
調用方式二
第二種調用方式和第一種有些區別，第二種調用方式的項目部署了多台服務器，如果仍然通過第一種方式來調用則不能滿足要求。
第一種調用方式只適合有一台服務器的情況，第二種就只能通過feign來調用了。這種調用方式的作用在於通過調用來實現數據的同步。
先看一下當前項目中的一種實現方式，先定義feign調用的接口，然后定義一個feign接口的實現類，然后在寫一個具體的調用接口和實現
類。在具體的實現類中，將feign接口當做成員變量，然后調用feign接口種的方法實現調用。最后實際調用時，是通過callFixDataService
實現調用的。
CallBigDataFeign
CallBigDataFeignFallBack
CallFixDataService
CallFixDataServiceImpl
最終調用方式，通過fastJson包下面的JSONObject和JSONOArray來進行調用。
配置方式為，地址可以配置多個，中間使用逗號分隔。
最終通過測試，這種方式完全符合業務要求，實現了一個項目調用另外一個部署在多台服務器上的項目。