Dubbo2.7源码分析-如何发布服务

Dubbo的服务发布逻辑是比较复杂的，我们还是以Dubbo自带的示例进行讲解，抽丝剥茧，拨云见日。

Provider配置如下：

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://dubbo.apache.org/schema/dubbo "> <!-- 提供方应用信息，用于计算依赖关系 --> <dubbo:application /> <!-- 使用multicast广播注册中心暴露服务地址 --> <dubbo:registry address="multicast://224.5.6.7:1234" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol port="20880" /> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" /> <!-- 和本地bean一样实现服务 --> <bean /> </beans> ApplicationContext

ClassPathXmlApplicationContext父类AbstractApplicationContext的方法refresh()在实例化bean之后的最后一步finishRefresh()中，此方法作用是发布相应的事件。

protected void finishRefresh() { //省略LifeCycleProcessor刷新代码 // Publish the final event. publishEvent(new ContextRefreshedEvent(this)); // 省略注册到 LiveBeansView MBean代码 }

可以看到发布了一个ContextRefreshedEvent事件。

protected void publishEvent(Object event, ResolvableType eventType) { //省略部分代码 getApplicationEventMulticaster().multicastEvent(applicationEvent, eventType); //省略分部代码

首先获取ApplicationEvent事件广播对象，然后广播事件。

ApplicationEvent事件广播对象默认是SimpleApplicationEventMulticaster，这个对象是在AbstractApplicationContext的方法initApplicationEventMulticaster()初始化的，如果需要自定义，可以实现接口ApplicationEventMulticaster,并将bean的名字命名为applicationEventMulticaster。

接下来看看SimpleApplicationEventMulticaster类的multicastEvent方法。

@Override public void multicastEvent(final ApplicationEvent event, ResolvableType eventType) { //事件类型 ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event)); //applicationListener for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) { //异常执行 Executor executor = getTaskExecutor(); if (executor != null) { executor.execute(new Runnable() { @Override public void run() { invokeListener(listener, event); } }); } else { invokeListener(listener, event); } } }

可以看到此方法会调用applicationListener的方法,对于Dubbo而言，就是ServiceBean.

怎么样获取到ServiceBean的呢？

ServiceBean实现了好几个接口，其中有两个接口ApplicationContextAware和ApplicationListener，其中ApplicationContextAware使ServiceBean具有获取ApplicationContext的能力(了解bean的生命周期)，而ApplicationListener使ServiceBean具有响应事件响应的能力。dubbo实现ApplicationContextAware的目的是通过反射把自己添加到ApplicationContext的ApplicationListener列表中，即使不实现ApplicationContextAware接口，spring也会将实现了ApplicationListener接口的bean添加到其listener列表中的，dubbo这样做估计是向后兼容。

接着看invokeListener(listener, event);方法

protected void invokeListener(ApplicationListener<?> listener, ApplicationEvent event) { ErrorHandler errorHandler = getErrorHandler(); if (errorHandler != null) { try { doInvokeListener(listener, event); } catch (Throwable err) { errorHandler.handleError(err); } } else { doInvokeListener(listener, event); } } private void doInvokeListener(ApplicationListener listener, ApplicationEvent event) { try { listener.onApplicationEvent(event); } catch (ClassCastException ex) { //省略异常处理 } else { throw ex; } } }

invokeListener方法内部调用了doInvokeListener方法，而doInvokeListener方法调用了listener(ServiceBean)的onApplicationEvent方法.

ServiceBean public void onApplicationEvent(ContextRefreshedEvent event) { if (isDelay() && !isExported() && !isUnexported()) { if (logger.isInfoEnabled()) { logger.info("The service ready on spring started. service: " + getInterface()); } export(); } }

onApplicationEvent方法调用了export方法，export方法首先判断是否已经发布了服务，发布了则直接返回，没有发布则会判断是否需要延迟发布，如果需要延迟，则将发布服务做为一个任务添加到ScheduledThreadPoolExecutor线程池中，如果不延迟，则调用doExport方法立即发布服务。
doExport方法中会获取application/registries/monitor/module/protocols,并做一些检查和属性填充，然后调用doExportUrls();发布服务。doExportUrls()首先调用loadRegistries方法得到要注册的url，然后发布相关Protocol的服务。