dubbo源码版本 是2.5.4
一、故事开始的地方
我们发布一个服务一般配置文件是这样的
<dubbo:service interface="com.youzan.dubbo.api.DemoService"
class="com.youzan.dubbo.provider.DemoServiceImpl"/>
前面的文章解释过，dubbo对spring进行了拓展，dubbo标签的解析类是DubboNamespaceHandler。
//com.alibaba.dubbo.config.spring.schema.DubboNamespaceHandler
public void init() {
//省略代码
registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
registerBeanDefinitionParser("reference", new DubboBeanDefinitionParser(ReferenceBean.class, false));
//省略代码
}
可以看出dubbo:service标签的解析和ServiceBean有关系。
ServiceBean对spring容器的声明周期进行监听，进入onApplicationEvent方法。我们的故事也就是从这里开始。
ServiceBean监听spring容器事件，作为启动入口。
ServiceConfig 是我们的配置载体，也是核心逻辑的组装。
ServiceBean
二、几个概念
Protocol
RPC网络通信协议抽象类。
Invoker
它是 Dubbo 的核心模型，它代表一个可执行体，可向它发起 invoke 调用，它有可能是一个本地的实现，也可能是一个远程的实现，也可能一个集群实现。
Invoker体系
我们服务调用先经过集群策略AbstractClusterInvoker，接着调用服务AbstractInvoker，最终逻辑执行AbstractProxyInvoker。
Export
Invoker的管理类，维护着export本地缓存。
三、调用链路
ServiceBean.onApplicationEvent
|--ServiceConfig.export
|----ServiceConfig.doExport
|------ServiceConfig.doExportUrls
|--------ServiceConfig.doExportUrlsFor1Protocol
本地服务发布
|----------ServiceConfig.exportLocal
|------------JavassistProxyFactory.getInvoker
|------------InjvmProtocol.export
远程服务发布
|----------JavassistProxyFactory.getInvoker
|----------RegistryProtocol.export
|-------------RegistryProtocol.doLocalExport
|---------------DubboProtocol.export
调用链路图示
//AbstractProtocol
Map<String, Exporter<?>> exporterMap = new ConcurrentHashMap<String, Exporter<?>>();
exporter的缓存，key=com.youzan.dubbo.api.DemoService:20880，也就是服务拼上端口。AbstractProtocol的子类都会去维护这个缓存。
四、关键代码
ServiceConfig.doExportUrls 加载注册中心所有服务，作为后面暴露服务的参数。
private void doExportUrls() {
List<URL> registryURLs = loadRegistries(true);
for (ProtocolConfig protocolConfig : protocols) {
doExportUrlsFor1Protocol(protocolConfig, registryURLs);
}
}
服务发布核心方法入口ServiceConfig.doExportUrlsFor1Protocol。服务发布分为本地发布和远程发布。本地发布主要为本地服务调用进行服务，避免不必要的网络请求。
本地服务发布
ServiceConfig.exportLocal
private void exportLocal(URL url) {
if (!Constants.LOCAL_PROTOCOL.equalsIgnoreCase(url.getProtocol())) {
URL local = URL.valueOf(url.toFullString())
.setProtocol(Constants.LOCAL_PROTOCOL)
.setHost(NetUtils.LOCALHOST)
.setPort(0);
Exporter<?> exporter = protocol.export(
proxyFactory.getInvoker(ref, (Class) interfaceClass, local));
exporters.add(exporter);
logger.info("Export dubbo service " + interfaceClass.getName() + " to local registry");
}
}
这里的protocol会根据当前协议采用InjvmProtocol（SPI相关知识，见前面SPI章节）。proxyFactory 具体执行类 JavassistProxyFactory。
InjvmProtocol.export
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
return new InjvmExporter<T>(invoker, invoker.getUrl().getServiceKey(), exporterMap);
}
JavassistProxyFactory.getInvoker，doInvoke通过java反射调用目标类的具体方法。
public <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) {
final Wrapper wrapper = Wrapper.getWrapper(proxy.getClass().getName().indexOf('$') < 0 ? proxy.getClass() : type);
return new AbstractProxyInvoker<T>(proxy, type, url) {
@Override
protected Object doInvoke(T proxy, String methodName,
Class<?>[] parameterTypes,
Object[] arguments) throws Throwable {
return wrapper.invokeMethod(proxy, methodName, parameterTypes, arguments);
}
};
}
远程服务发布
ServiceConfig.doExportUrlsFor1Protocol
for (URL registryURL : registryURLs) {
//省略代码
Invoker<?> invoker = proxyFactory.getInvoker(ref, (Class) interfaceClass, registryURL.addParameterAndEncoded(Constants.EXPORT_KEY, url.toFullString()));
Exporter<?> exporter = protocol.export(invoker);
exporters.add(exporter);
}
遍历注册中心服务列表，进行服务发布。
proxyFactory依旧是JavassistProxyFactory，同本地发布一样。
protocol，registryURL是 registry:开头的，使用的是RegistryProtocol
RegistryProtocol.export
public <T> Exporter<T> export(final Invoker<T> originInvoker) throws RpcException {
//export invoker
final ExporterChangeableWrapper<T> exporter = doLocalExport(originInvoker);
//registry provider
final Registry registry = getRegistry(originInvoker);
final URL registedProviderUrl = getRegistedProviderUrl(originInvoker);
registry.register(registedProviderUrl);
// 订阅override数据
// FIXME 提供者订阅时，会影响同一JVM即暴露服务，又引用同一服务的的场景，因为subscribed以服务名为缓存的key，导致订阅信息覆盖。
final URL overrideSubscribeUrl = getSubscribedOverrideUrl(registedProviderUrl);
final OverrideListener overrideSubscribeListener = new OverrideListener(overrideSubscribeUrl);
overrideListeners.put(overrideSubscribeUrl, overrideSubscribeListener);
registry.subscribe(overrideSubscribeUrl, overrideSubscribeListener);
//保证每次export都返回一个新的exporter实例
//其它代码省略
RegistryProtocol主要增加了注册中心相关的拓展，比如注册中心订阅，注册中心服务更新等。服务的暴露逻辑在 doLocalExport中实现。
private <T> ExporterChangeableWrapper<T> doLocalExport(final Invoker<T> originInvoker) {
String key = getCacheKey(originInvoker);
ExporterChangeableWrapper<T> exporter = (ExporterChangeableWrapper<T>) bounds.get(key);
if (exporter == null) {
synchronized (bounds) {
exporter = (ExporterChangeableWrapper<T>) bounds.get(key);
if (exporter == null) {
final Invoker<?> invokerDelegete = new InvokerDelegete<T>(originInvoker, getProviderUrl(originInvoker));
exporter = new ExporterChangeableWrapper<T>((Exporter<T>) protocol.export(invokerDelegete), originInvoker);
bounds.put(key, exporter);
}
}
}
return (ExporterChangeableWrapper<T>) exporter;
}
bounds 注册中心缓存，key=服务提供的url，value=ExporterChangeableWrapper，ExporterChangeableWrapper是一个Invoker和Exporter对应关系载体。
PS. key样例： dubbo://172.17.1.54:20880/com.alibab.demo.XXXService.开头的
private class ExporterChangeableWrapper<T> implements Exporter<T> {
private final Invoker<T> originInvoker;
private Exporter<T> exporter;
当缓存里没有接下来具体的服务暴露由 DubboProtocol.export进行执行，注册中心相关，后续章节解说。
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
URL url = invoker.getUrl();
// export service.
String key = serviceKey(url);
DubboExporter<T> exporter = new DubboExporter<T>(invoker, key, exporterMap);
exporterMap.put(key, exporter);
//export an stub service for dispaching event
//代码省略
//服务端口暴露
openServer(url);
return exporter;
}
同样先判断缓存是否已经有export，没有就创建。然后调用openServer暴露对应的服务端口，网络服务部分后续章节解说。
相关文章
https://www.jianshu.com/p/c52fbaca7385
http://dubbo.apache.org/zh-cn/docs/dev/design.html
网友评论