13518219792
如何从源码分析Dubbo与SpringBoot整合以及进行Dubbo启动，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
创新互联建站-专业网站定制、快速模板网站建设、高性价比扬中网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式扬中网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖扬中地区。费用合理售后完善，10余年实体公司更值得信赖。
在分析Reference是提到过Dubbo会自动引配置类，这里需要注意DubboBootstrapApplicationListener：
registerCommonBeans(BeanDefinitionRegistry registry) {
registerInfrastructureBean(registry, ReferenceAnnotationBeanPostProcessor.BEAN_NAME,
ReferenceAnnotationBeanPostProcessor.class);
registerInfrastructureBean(registry, DubboConfigAliasPostProcessor.BEAN_NAME,
DubboConfigAliasPostProcessor.class);
registerInfrastructureBean(registry, DubboLifecycleComponentApplicationListener.BEAN_NAME,
DubboLifecycleComponentApplicationListener.class);
registerInfrastructureBean(registry, DubboBootstrapApplicationListener.BEAN_NAME,
DubboBootstrapApplicationListener.class);
registerInfrastructureBean(registry, DubboConfigDefaultPropertyValueBeanPostProcessor.BEAN_NAME,
DubboConfigDefaultPropertyValueBeanPostProcessor.class);
}
public class DubboBootstrapApplicationListener extends OneTimeExecutionApplicationContextEventListener
implements Ordered {
private final DubboBootstrap dubboBootstrap;
public DubboBootstrapApplicationListener() {
//这里是一个单例
this.dubboBootstrap = DubboBootstrap.getInstance();
}
//监听事件
@Override
public void onApplicationContextEvent(ApplicationContextEvent event) {
if (event instanceof ContextRefreshedEvent) {
onContextRefreshedEvent((ContextRefreshedEvent) event);//上下文刷新完成事件
} else if (event instanceof ContextClosedEvent) {
onContextClosedEvent((ContextClosedEvent) event);//关闭事件
}
}
private void onContextRefreshedEvent(ContextRefreshedEvent event) {
dubboBootstrap.start();
}
private void onContextClosedEvent(ContextClosedEvent event) {
dubboBootstrap.stop();
}
}DubboBootstrapApplicationListener 实现了Spring的事件监听，当上下文刷新完成的时候，会执行dubboBootstrap.start()：
public DubboBootstrap start() {
//CAS
if (started.compareAndSet(false, true)) {
ready.set(false);
//初始化
initialize();
//Dubbo服务导出
exportServices();
if (!isOnlyRegisterProvider() || hasExportedServices()) {
exportMetadataService();
registerServiceInstance();
}
//服务引用
referServices();
}
return this;
}先看exportServices()服务导出：
private void exportServices() {
configManager.getServices().forEach(sc -> {
ServiceConfig serviceConfig = (ServiceConfig) sc;
serviceConfig.setBootstrap(this);
if (exportAsync) {
ExecutorService executor = executorRepository.getServiceExporterExecutor();
Future future = executor.submit(() -> {
sc.export();
exportedServices.add(sc);
});
asyncExportingFutures.add(future);
} else {
sc.export();
exportedServices.add(sc);
}
});
}循环configManager.getServices()中的数据依次执行导出，那这些Service是从哪来的？：
public Collection
return getConfigs(getTagName(ServiceConfigBase.class));
}
最终实际调用：
protected
return (Map
}
getTagName(ServiceConfigBase.class) 获取类的标签，这里也就是service。我们之前分析过Dubbo的DubboService注解在注册原始类的同时还会注册ServiceBean。下面看ServiceBean的类结构图， 它是ServiceConfigBase的一个子类，那么他是如何放到configsCache中去的？
再来看ServiceConfigBase的父类AbstractConfig，它里面有一个PostConstruct注解的方法，查看官方解释：PostConstruct注解用于需要依赖注入完成以执行任何初始化之后要执行的方法上。必须在类投入使用之前调用此方法。所有支持依赖注入的类都必须支持该注释。即使该类不要求注入任何资源，也必须调用用PostConstruct注释的方法。也就是说所有的ServiceBean在被Spring初始化之后都会调用addIntoConfigManager方法。
@PostConstruct
public void addIntoConfigManager() {
ApplicationModel.getConfigManager().addConfig(this);
}addIntoConfigManager方法的实际作用就是向configsCache中缓存：
protected void addConfig(AbstractConfig config, boolean unique) {
if (config == null) {
return;
}
write(() -> {
Map configsMap = configsCache.computeIfAbsent(getTagName(config.getClass()), type -> newMap());
addIfAbsent(config, configsMap, unique);
});
} 所以，Dubbo中凡是实现AbstractConfig接口的类，在被Spring初始化之后，最终都会被缓存到configManager中。
总结：
1、Dubbo中实现AbstractConfig接口的Bean，在被Spring初始化之后，都会被放入configManager。
2、Dubbo通过实现Spring的监听事件，在上下文刷新完成的时候开始进行Dubbo服务的初始化和启动。
3、启动引导类dubboBootstrap 是一个单例。
至此，Dubbo容器的启动分析完成。
关于如何从源码分析Dubbo与SpringBoot整合以及进行Dubbo启动问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注创新互联行业资讯频道了解更多相关知识。
