Dubbo原始碼解析（三十九）叢集——merger
阿新 • • 發佈：2020-06-24
叢集——merger
目標：介紹dubbo中叢集的分組聚合，介紹dubbo-cluster下merger包的原始碼。
前言
按組合並返回結果 ，比如選單服務，介面一樣，但有多種實現，用group區分，現在消費方需從每種group中呼叫一次返回結果，合併結果返回，這樣就可以實現聚合選單項。這個時候就要用到分組聚合。
原始碼分析
（一）MergeableCluster
public class MergeableCluster implements Cluster {
public static final String NAME = "mergeable";
@Override 該類實現了Cluster介面，是分組集合的叢集實現。
（二）MergeableClusterInvoker
該類是分組聚合的實現類，其中最關機的就是invoke方法。
@Override 前面部分在講獲得呼叫的結果，後面部分是對結果的合併，合併有兩種方式，根據配置不同可用分為基於方法的合併和基於merger的合併。
（三）MergerFactory
Merger 工廠類，獲得指定型別的Merger 物件。
public class MergerFactory {
/**
* Merger 物件快取
*/
private static final ConcurrentMap<Class<?>,Merger<?>> mergerCache =
new ConcurrentHashMap<Class<?>,Merger<?>>();
/**
* 獲得指定型別的Merger物件
* @param returnType
* @param <T>
* @return
*/
public static <T> Merger<T> getMerger(Class<T> returnType) {
Merger result;
// 如果型別是集合
if (returnType.isArray()) {
// 獲得型別
Class type = returnType.getComponentType();
// 從快取中獲得該型別的Merger物件
result = mergerCache.get(type);
// 如果為空，則
if (result == null) {
// 初始化所有的 Merger 擴充套件物件，到 mergerCache 快取中。
loadMergers();
// 從集合中取出對應的Merger物件
result = mergerCache.get(type);
}
// 如果結果為空，則直接返回ArrayMerger的單例
if (result == null && !type.isPrimitive()) {
result = ArrayMerger.INSTANCE;
}
} else {
// 否則直接從mergerCache中取出
result = mergerCache.get(returnType);
// 如果為空
if (result == null) {
// 初始化所有的 Merger 擴充套件物件，到 mergerCache 快取中。
loadMergers();
// 從集合中取出
result = mergerCache.get(returnType);
}
}
return result;
}
/**
* 初始化所有的 Merger 擴充套件物件，到 mergerCache 快取中。
*/
static void loadMergers() {
// 獲得Merger所有的擴充套件物件名
Set<String> names = ExtensionLoader.getExtensionLoader(Merger.class)
.getSupportedExtensions();
// 遍歷
for (String name : names) {
// 載入每一個擴充套件實現，然後放入快取。
Merger m = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(name);
mergerCache.putIfAbsent(ReflectUtils.getGenericClass(m.getClass()),m);
}
}
}
複製程式碼邏輯比較簡單。
（四）ArrayMerger
因為不同的型別有不同的Merger實現，我們可以來看看這個圖片：
可以看到有好多好多，我就講解其中的一種，偷懶一下，其他的麻煩有興趣的去看看原始碼了。
public class ArrayMerger implements Merger<Object[]> {
/**
* 單例
*/
public static final ArrayMerger INSTANCE = new ArrayMerger();
@Override
public Object[] merge(Object[]... others) {
// 如果長度為0 則直接返回
if (others.length == 0) {
return null;
}
// 總長
int totalLen = 0;
// 遍歷所有需要合併的物件
for (int i = 0; i < others.length; i++) {
Object item = others[i];
// 如果為陣列
if (item != null && item.getClass().isArray()) {
// 累加陣列長度
totalLen += Array.getLength(item);
} else {
throw new IllegalArgumentException((i + 1) + "th argument is not an array");
}
}
if (totalLen == 0) {
return null;
}
// 獲得陣列型別
Class<?> type = others[0].getClass().getComponentType();
// 建立長度
Object result = Array.newInstance(type,totalLen);
int index = 0;
// 遍歷需要合併的物件
for (Object array : others) {
// 遍歷每個陣列中的資料
for (int i = 0; i < Array.getLength(array); i++) {
// 加入到最終結果中
Array.set(result,index++,Array.get(array,i));
}
}
return (Object[]) result;
}
}
複製程式碼是不是很簡單，就是迴圈合併就可以了。
後記
該部分相關的原始碼解析地址：github.com/CrazyHZM/in…
該文章講解了叢集中關於分組聚合實現的部分。接下來我將開始對叢集模組關於路由部分進行講解。