汉口网站制作设计,电商网站建设毕业设计,东城手机网站建设,做网站公司融资多少钱Dubbo 3.2版本分析Provider启动时操作 前言例子分析onStarting 模块doStart 模块 小结 前言
上一篇文章#xff0c;我们分析了 Dubbo 3.2 版本在 Provider 启动前的操作流程#xff0c;这次我们具体分析具体它的启动过程#xff0c;揭开它的神秘面纱。
例子
这里我们还是… Dubbo 3.2版本分析Provider启动时操作 前言例子分析onStarting 模块doStart 模块 小结 前言
上一篇文章我们分析了 Dubbo 3.2 版本在 Provider 启动前的操作流程这次我们具体分析具体它的启动过程揭开它的神秘面纱。
例子
这里我们还是以provider启动的Demo为入口进行分析。如下为Dubbo服务暴漏出来的接口
public interface DemoService {String sayHello(String name);
}DemoServiceImpl为Dubbo provider
public class DemoServiceImpl implements DemoService {private static final Logger logger LoggerFactory.getLogger(DemoServiceImpl.class);Overridepublic String sayHello(String name) {logger.info(Hello name , request from consumer: RpcContext.getServiceContext().getRemoteAddress());return Hello name , response from provider: RpcContext.getServiceContext().getLocalAddress();}}Application为服务的启动类
public class Application {private static final String REGISTRY_URL zookeeper://sr-1-zk-cluster-1.gz.cvte.cn:2181;public static void main(String[] args) {startWithBootstrap();}private static void startWithBootstrap() {ServiceConfigDemoServiceImpl service new ServiceConfig();service.setInterface(DemoService.class);service.setRef(new DemoServiceImpl());DubboBootstrap bootstrap DubboBootstrap.getInstance();bootstrap.application(new ApplicationConfig(dubbo-api-provider)).registry(new RegistryConfig(REGISTRY_URL)).protocol(new ProtocolConfig(CommonConstants.DUBBO, -1)).service(service).start().await();}
}分析
上文分析过设置 application - 设置 registry - 设置 protocol - 设置 serviceConfig 的流程了这次我们进入 start 方法。
进入 start 方法后最终来到 applicationDeployer.start() 这里。关于 applicationDeployer它申明是ApplicationDeployer 类型默认情况下具体实现为 DefaultApplicationDeployer关于它们的类结构如图1所示。Dubbo 3.0 把服务的发布流程进行了抽象引入了 **Deployer **的概念负责应用的的初始化和启动。除了 start 方法其他方法如图2所示。
public DubboBootstrap start() {this.start(true);return this;}/*** Start dubbo application** param wait If true, wait for startup to complete, or else no waiting.* return*/public DubboBootstrap start(boolean wait) {Future future applicationDeployer.start();if (wait) {try {future.get();} catch (Exception e) {throw new IllegalStateException(await dubbo application start finish failure, e);}}return this;}接着我们具体看看 DefaultApplicationDeployer对 start 方法的具体实现。这里先进行服务发布状态的判断通过 AbstractDeployer类里定义的一个共享的成员变量进行判断默认值是 PENDING。 private volatile DeployState state PENDING; Dubbo 3.0 引入了领域模型的概念那么在这里会先判断是否由新加入的模型而重新调用启动过程。判断方式见 hasPendingModule 方法。其中 applicationModel.getModuleModels() 会返回一个线程安全的读写队列。 private final List moduleModels new CopyOnWriteArrayList(); 这里我们是刚启动的状态所以会 ModuleModel 默认状态即 **PENDINGhasPendingModule **的结果为ture。进入 isStarting 方法同样判断是判断 state此时还是为 PENDING所以结果为false。关于 startModules 方法的分析我们放在后边讲。再完后我们可以看到三个被封装好的流程 onStarting()、 initialize()、doStart()分别进行服务启动状态的设置、服务启动的初始化启动各个领域模型。针对这个三个模快我们在后文继续分析。
public Future start() {synchronized (startLock) {if (isStopping() || isStopped() || isFailed()) {throw new IllegalStateException(getIdentifier() is stopping or stopped, can not start again);}try {// maybe call start again after add new module, check if any new moduleboolean hasPendingModule hasPendingModule();if (isStarting()) {// currently, is starting, maybe both start by module and application// if it has new modules, start themif (hasPendingModule) {startModules();}// if it is starting, reuse previous startFuturereturn startFuture;}// if is started and no new module, just returnif (isStarted() !hasPendingModule) {return CompletableFuture.completedFuture(false);}// pending - starting : first start app// started - starting : re-start apponStarting();initialize();doStart();} catch (Throwable e) {onFailed(getIdentifier() start failure, e);throw e;}return startFuture;}}private boolean hasPendingModule() {boolean found false;for (ModuleModel moduleModel : applicationModel.getModuleModels()) {if (moduleModel.getDeployer().isPending()) {found true;break;}}return found;
}onStarting 模块
这里进来还是先进行状态的判断如果既不是处于准备中状态或者启动过的状态则return。接着通过 setStarting 方法修改我们的state 为 STARTING 状态。这里还会去启动监听者listeners 为 AbstractDeployer类中的成员变量 protected ListDeployListener listeners new CopyOnWriteArrayList(); 关于它的赋值有两个时机这里可以回顾我们的例子中获取 DubboBootstrap 对象时的代码这里在创建的过程中会去加载两个监听器。 DubboBootstrap bootstrap DubboBootstrap.getInstance(); 如下面代码所示一个是通过我们 SPI 机制引入的 ExporterDeployListener另一个是用于监听服务启动过程的 DeployListenerAdapter不过可能是考虑便于后边拓展这里 onStarting 方法目前暂未做实现。最后构造一个异步线程池赋值给 startFuture 变量该线程池可用于服务启动、配置加载等事件状态的执行。 private volatile CompletableFuture startFuture; private void onStarting() {// pending - starting// started - startingif (!(isPending() || isStarted())) {return;}setStarting();startFuture new CompletableFuture();if (logger.isInfoEnabled()) {logger.info(getIdentifier() is starting.);}}protected void setStarting() {this.state STARTING;for (DeployListenerE listener : listeners) {try {listener.onStarting(scopeModel);} catch (Throwable e) {logger.error(COMMON_MONITOR_EXCEPTION,,,getIdentifier() an exception occurred when handle starting event,e);}}}// DeployListenerAdapter
applicationDeployer.addDeployListener(new DeployListenerAdapterApplicationModel() {Overridepublic void onStarted(ApplicationModel scopeModel) {notifyStarted(applicationModel);}Overridepublic void onStopped(ApplicationModel scopeModel) {notifyStopped(applicationModel);}Overridepublic void onFailure(ApplicationModel scopeModel, Throwable cause) {notifyStopped(applicationModel);}}); // ExporterDeployListener
public class ExporterDeployListener implements ApplicationDeployListener, Prioritized {protected volatile ConfigurableMetadataServiceExporter metadataServiceExporter;Overridepublic void onInitialize(ApplicationModel scopeModel) {}Overridepublic void onStarting(ApplicationModel scopeModel) {}// ....}doStart 模块
在执行 initialize 模块初始化后最终是 doStart 模块这里先启动 内部的模块模型 即 DefaultModuleDeployer 实例这里同样会把 **DefaultModuleDeployer **的状态先设置为 STARTING。注意前面设置的是DefaultApplicationDeployer 的状态跟这里的模块的状态还不一样。然后会遍历所有的模块列表可能有些业务场景自己拓展了模块吧这里会判断它们是否出于准备状态然后一起启动。
private void doStart() {startModules();
}private void startModules() {// ensure init and start internal module firstprepareInternalModule();// filter and start pending modules, ignore new module during starting, throw exception of module startfor (ModuleModel moduleModel : applicationModel.getModuleModels()) {if (moduleModel.getDeployer().isPending()) {moduleModel.getDeployer().start();}}}小结
本文分析了 Dubbo 3.2 版本分析Provider启动时的流程会先启动 ApplicationDeployer 类型实例在执行 state( onStarting 方法) 更新流程后进行初始化**( initialize 方法)最后然后是执行启动流程( do start 方法)**。在 do start 方法里才又先启动我们的内部模块再遍历所有的模块列表把所有处于准备状态的模块进行启动。最后关于 initialize 方法由于涉及流程很长为了保证文章可读性这里笔者暂时先不展开也算留个悬念下一篇我们继续分析它。
