摘要：遠程調(diào)用本地調(diào)用目標(biāo)介紹本地調(diào)用的設(shè)計和實現(xiàn)，介紹的源碼。前言是一個遠程調(diào)用的框架，但是它沒有理由不支持本地調(diào)用，本文就要講解關(guān)于本地調(diào)用的實現(xiàn)。服務(wù)暴露者集合取消暴露調(diào)用父類的取消暴露方法從集合中移除二該類繼承了類，是本地調(diào)用的實現(xiàn)。
遠程調(diào)用——injvm本地調(diào)用
目標(biāo)：介紹injvm本地調(diào)用的設(shè)計和實現(xiàn)，介紹dubbo-rpc-injvm的源碼。
前言
dubbo是一個遠程調(diào)用的框架，但是它沒有理由不支持本地調(diào)用，本文就要講解dubbo關(guān)于本地調(diào)用的實現(xiàn)。本地調(diào)用要比遠程調(diào)用簡單的多。
源碼分析
（一）InjvmExporter
該類繼承了AbstractExporter，是本地服務(wù)的暴露者封裝，其中實現(xiàn)比較簡單。只是實現(xiàn)了unexport方法，并且維護了一份保存暴露者的集合。
class InjvmExporter extends AbstractExporter {
/**
* 服務(wù)key
*/
private final String key;
/**
* 暴露者集合
*/
private final Map> exporterMap;
InjvmExporter(Invoker invoker, String key, Map> exporterMap) {
super(invoker);
this.key = key;
this.exporterMap = exporterMap;
exporterMap.put(key, this);
}
/**
* 取消暴露
*/
@Override
public void unexport() {
// 調(diào)用父類的取消暴露方法
super.unexport();
// 從集合中移除
exporterMap.remove(key);
}
}
（二）InjvmInvoker
該類繼承了AbstractInvoker類，是本地調(diào)用的invoker實現(xiàn)。
class InjvmInvoker extends AbstractInvoker {
/**
* 服務(wù)key
*/
private final String key;
/**
* 暴露者集合
*/
private final Map> exporterMap;
InjvmInvoker(Class type, URL url, String key, Map> exporterMap) {
super(type, url);
this.key = key;
this.exporterMap = exporterMap;
}
/**
* 服務(wù)是否活躍
* @return
*/
@Override
public boolean isAvailable() {
InjvmExporter exporter = (InjvmExporter) exporterMap.get(key);
if (exporter == null) {
return false;
} else {
return super.isAvailable();
}
}
/**
* invoke方法
* @param invocation
* @return
* @throws Throwable
*/
@Override
public Result doInvoke(Invocation invocation) throws Throwable {
// 獲得暴露者
Exporter exporter = InjvmProtocol.getExporter(exporterMap, getUrl());
// 如果為空，則拋出異常
if (exporter == null) {
throw new RpcException("Service [" + key + "] not found.");
}
// 設(shè)置遠程地址為127.0.0.1
RpcContext.getContext().setRemoteAddress(NetUtils.LOCALHOST, 0);
// 調(diào)用下一個調(diào)用鏈
return exporter.getInvoker().invoke(invocation);
}
}
其中重寫了isAvailable和doInvoke方法。
（三）InjvmProtocol
該類是本地調(diào)用的協(xié)議實現(xiàn)，其中實現(xiàn)了服務(wù)調(diào)用和服務(wù)暴露方法，并且封裝了一個判斷是否是本地調(diào)用的方法。
1.屬性
/**
* 本地調(diào)用 Protocol的實現(xiàn)類key
*/
public static final String NAME = Constants.LOCAL_PROTOCOL;
/**
* 默認(rèn)端口
*/
public static final int DEFAULT_PORT = 0;
/**
* 單例
*/
private static InjvmProtocol INSTANCE;
2.getExporter
static Exporter getExporter(Map> map, URL key) {
Exporter result = null;
// 如果服務(wù)key不是*
if (!key.getServiceKey().contains("*")) {
// 直接從集合中取出
result = map.get(key.getServiceKey());
} else {
// 如果 map不為空，則遍歷暴露者，來找到對應(yīng)的exporter
if (map != null && !map.isEmpty()) {
for (Exporter exporter : map.values()) {
// 如果是服務(wù)key
if (UrlUtils.isServiceKeyMatch(key, exporter.getInvoker().getUrl())) {
// 賦值
result = exporter;
break;
}
}
}
}
// 如果沒有找到exporter
if (result == null) {
// 則返回null
return null;
} else if (ProtocolUtils.isGeneric(
result.getInvoker().getUrl().getParameter(Constants.GENERIC_KEY))) {
// 如果是泛化調(diào)用，則返回null
return null;
} else {
return result;
}
}
該方法是獲得相關(guān)的暴露者。
3.export
@Override
public Exporter export(Invoker invoker) throws RpcException {
// 創(chuàng)建InjvmExporter 并且返回
return new InjvmExporter(invoker, invoker.getUrl().getServiceKey(), exporterMap);
}
4.refer
@Override
public Invoker refer(Class serviceType, URL url) throws RpcException {
// 創(chuàng)建InjvmInvoker 并且返回
return new InjvmInvoker(serviceType, url, url.getServiceKey(), exporterMap);
}
5.isInjvmRefer
public boolean isInjvmRefer(URL url) {
final boolean isJvmRefer;
// 獲得scope配置
String scope = url.getParameter(Constants.SCOPE_KEY);
// Since injvm protocol is configured explicitly, we don"t need to set any extra flag, use normal refer process.
if (Constants.LOCAL_PROTOCOL.toString().equals(url.getProtocol())) {
// 如果是injvm，則不是本地調(diào)用
isJvmRefer = false;
} else if (Constants.SCOPE_LOCAL.equals(scope) || (url.getParameter("injvm", false))) {
// if it"s declared as local reference
// "scope=local" is equivalent to "injvm=true", injvm will be deprecated in the future release
// 如果它被聲明為本地引用 scope = local"相當(dāng)于"injvm = true"，將在以后的版本中棄用injvm
isJvmRefer = true;
} else if (Constants.SCOPE_REMOTE.equals(scope)) {
// it"s declared as remote reference
// 如果被聲明為遠程調(diào)用
isJvmRefer = false;
} else if (url.getParameter(Constants.GENERIC_KEY, false)) {
// generic invocation is not local reference
// 泛化的調(diào)用不是本地調(diào)用
isJvmRefer = false;
} else if (getExporter(exporterMap, url) != null) {
// by default, go through local reference if there"s the service exposed locally
// 默認(rèn)情況下，如果本地暴露服務(wù)，請通過本地引用
isJvmRefer = true;
} else {
isJvmRefer = false;
}
return isJvmRefer;
}
該方法是判斷是否為本地調(diào)用。
后記
該部分相關(guān)的源碼解析地址：https://github.com/CrazyHZM/i...
該文章講解了遠程調(diào)用中關(guān)于injvm本地調(diào)用的部分，三種抽象的角色還是比較鮮明的，服務(wù)暴露相關(guān)的exporter、服務(wù)引用相關(guān)的invoker、以及協(xié)議相關(guān)的protocol，關(guān)鍵還是弄清楚再設(shè)計上的意圖，以及他們分別代表的是什么。那么看這些不同的協(xié)議實現(xiàn)會很容易看懂。接下來我將開始對rpc模塊關(guān)于memcached協(xié)議部分進行講解。
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/73232.html
