dubbo版本2.5.6
因为实现了ApplicationListener 所以在IOC容器初始化调用onApplicationEvent方法
public void onApplicationEvent(ApplicationEvent event) {
if (ContextRefreshedEvent.class.getName().equals(event.getClass().getName())
&& this.isDelay() && !this.isExported() && !this.isUnexported()) {
if (logger.isInfoEnabled()) {
logger.info("The service ready on spring started. service: " + this.getInterface());
}
this.export(); 《-进入这个方法
}
}
public synchronized void export() {
if (this.provider != null) {
if (this.export == null) {
this.export = this.provider.getExport();获取xml的export配置
}
if (this.delay == null) {获取xml的delay配置
this.delay = this.provider.getDelay();
}
}
if (this.export == null || this.export) {是否允许暴露
if (this.delay != null && this.delay > 0) {是否需要延迟暴露
Thread thread = new Thread(new Runnable() {
public void run() {
try {
Thread.sleep((long)ServiceConfig.this.delay);
} catch (Throwable var2) {
}
ServiceConfig.this.doExport();
}
});
thread.setDaemon(true);
thread.setName("DelayExportServiceThread");
thread.start();
} else {
this.doExport();暴露
}
}
}
doExport大部分是检测配置的过程，最后调用doExportUrls
private void doExportUrls() {
List registryURLs = this.loadRegistries(true);获取服务注册中心list，从这个list可以看出来dubbo支持多个注册中心
//注册中心可以有很多种
Iterator var2 = this.protocols.iterator();
while(var2.hasNext()) {遍历多个协议，像注册中心注册
ProtocolConfig protocolConfig = (ProtocolConfig)var2.next();
this.doExportUrlsFor1Protocol(protocolConfig, registryURLs);
}
}
private void doExportUrlsFor1Protocol(ProtocolConfig protocolConfig, ListregistryURLs) { ……上边代码一直在构建URL scope = url.getParameter("scope"); if (!"none".toString().equalsIgnoreCase(scope)) { if (!"remote".toString().equalsIgnoreCase(scope)) { this.exportLocal(url);本地暴露 } if (!"local".toString().equalsIgnoreCase(scope)) { if (logger.isInfoEnabled()) { logger.info("Export dubbo service " + this.interfaceClass.getName() + " to url " + url); } 如果有注册中心就会进行远程暴露 if (registryURLs != null && registryURLs.size() > 0 && url.getParameter("register", true)) { Iterator var38 = registryURLs.iterator(); while(var38.hasNext()) { URL registryURL = (URL)var38.next(); url = url.addParameterIfAbsent("dynamic", registryURL.getParameter("dynamic")); URL monitorUrl = this.loadMonitor(registryURL); if (monitorUrl != null) { url = url.addParameterAndEncoded("monitor", monitorUrl.toFullString()); } if (logger.isInfoEnabled()) { logger.info("Register dubbo service " + this.interfaceClass.getName() + " url " + url + " to registry " + registryURL); } Invoker invoker = proxyFactory.getInvoker(this.ref, this.interfaceClass, registryURL.addParameterAndEncoded("export", url.toFullString())); Exporter exporter = protocol.export(invoker); this.exporters.add(exporter); } } else { Invoker invoker = proxyFactory.getInvoker(this.ref, this.interfaceClass, url); Exporter exporter = protocol.export(invoker);走到这个方法里面 this.exporters.add(exporter); } } } this.urls.add(url); }
RegistryProtocol#export publicExporter export(Invoker originInvoker) throws RpcException { 根据dubbo协议 的到exporter final RegistryProtocol.ExporterChangeableWrapper exporter = this.doLocalExport(originInvoker); 加载 注册中心 Registry 实现类 这里的为ZookeeperRegistry final Registry registry = this.getRegistry(originInvoker); 获取注册中心的url final URL registedProviderUrl = this.getRegistedProviderUrl(originInvoker); 向zookeeper注册 registry.register(registedProviderUrl); 获取订阅url final URL overrideSubscribeUrl = this.getSubscribedOverrideUrl(registedProviderUrl); final RegistryProtocol.OverrideListener overrideSubscribeListener = new RegistryProtocol.OverrideListener(overrideSubscribeUrl); this.overrideListeners.put(overrideSubscribeUrl, overrideSubscribeListener); 向注册中心订阅 registry.subscribe(overrideSubscribeUrl, overrideSubscribeListener); return new Exporter () { public Invoker getInvoker() { return exporter.getInvoker(); } public void unexport() { try { exporter.unexport(); } catch (Throwable var4) { RegistryProtocol.logger.warn(var4.getMessage(), var4); } try { registry.unregister(registedProviderUrl); } catch (Throwable var3) { RegistryProtocol.logger.warn(var3.getMessage(), var3); } try { RegistryProtocol.this.overrideListeners.remove(overrideSubscribeUrl); registry.unsubscribe(overrideSubscribeUrl, overrideSubscribeListener); } catch (Throwable var2) { RegistryProtocol.logger.warn(var2.getMessage(), var2); } } }; }
dolocalExport 暴露url 打开端口 privateRegistryProtocol.ExporterChangeableWrapper doLocalExport(Invoker originInvoker) { String key = this.getCacheKey(originInvoker); RegistryProtocol.ExporterChangeableWrapper exporter = (RegistryProtocol.ExporterChangeableWrapper)this.bounds.get(key); if (exporter == null) { synchronized(this.bounds) { exporter = (RegistryProtocol.ExporterChangeableWrapper)this.bounds.get(key); if (exporter == null) { Invoker invokerDelegete = new RegistryProtocol.InvokerDelegete(originInvoker, this.getProviderUrl(originInvoker)); exporter = new RegistryProtocol.ExporterChangeableWrapper(this.protocol.export(invokerDelegete), originInvoker); this.bounds.put(key, exporter); } } } return exporter; }
DubboProtocol#exporter publicExporter export(Invoker invoker) throws RpcException { URL url = invoker.getUrl(); 获取dubbo url dubbo：//192...：20880/ String key = serviceKey(url); DubboExporter exporter = new DubboExporter(invoker, key, this.exporterMap); this.exporterMap.put(key, exporter); Boolean isStubSupportEvent = url.getParameter("dubbo.stub.event", false); Boolean isCallbackservice = url.getParameter("is_callback_service", false); if (isStubSupportEvent && !isCallbackservice) { String stubServiceMethods = url.getParameter("dubbo.stub.event.methods"); if (stubServiceMethods != null && stubServiceMethods.length() != 0) { this.stubServiceMethodsMap.put(url.getServiceKey(), stubServiceMethods); } else if (this.logger.isWarnEnabled()) { this.logger.warn(new IllegalStateException("consumer [" + url.getParameter("interface") + "], has set stubproxy support event ,but no stub methods founded.")); } } this.openServer(url); **** return exporter; }
