基于Spring的Dubbo服务导出。方法入口为ServiceBean.export(),此方法会调用ServiceConfig.export()方法,进行真正的服务导出。
服务导出原理
服务导出的入口为ServiceBean的export()方法,当Spring启动完之后,通过接收SpringContextRefreshedEvent事件来触发export()方法的执行。
一个ServiceBean对象就表示一个Dubbo服务,ServiceBean对象中的参数就表示服务的参数,比如timeout,该对象的参数值来自@Service注解的参数。
服务导出流程顺序如下:
- 确定服务参数:确定服务参数,根据各个数据源补全当前服务最终的(优先级最高的)参数值;
- 启动网络服务器:根据服务的参数信息,启动对应的网络服务器(Netty、tomcat、jetty等),用来接收网络请求;
- 服务注册:将服务的信息注册到服务中心;
- 监听:监听Dubbo中的动态配置信息变更。
在做这两件事情之前,需要把服务的参数确定,一个Dubbo服务的参数,除了可以在@Service注解中去配置,还会继承Dubbo服务所属应用(Application)上的配置,还可以在配置中心或者JVM环境变量中去配置某个服务的参数,所以首先要确定好当前服务最终的(优先级最高)的参数值。
确定好服务器参数之后,根据所配置的协议启动对应的网络服务器。在启动服务器时,并且在网络服务器接收请求的过程中,都可以从服务参数中获取信息,比如最大连接数,线程数,socket超时时间等。
启动完网络服务器后,就像服务信息注册到注册中心。同事还有向注册中心注册监听器,监听Dubbo中的动态配置信息变更。
确定服务参数
确定服务参数,根据各个数据源补全当前服务最终的(优先级最高的)参数值。
优先级如下:
如果开启了configCenterFirst(默认开始,不开启的不记)。
- JVM环境变量(SystemConfiguration)
- 操作系统环境变量
- 配置中心APP配置(AppExternalConfiguration)
- 配置中心Global配置(ExternalConfiguration)
- @Service注解配置(AbstractConfig)
- dubbo.properites(PropertiesConfiguration)
如果没开启则@Service注解到配置中心前面。另外,优先级最高的是动态配置,动态配置包含了能动态修改的参数,不包含所有参数。
在确定服务参数时,需要先从上级获取参数,获取之后,如果 服务本身配置了相同的参数,直接覆盖。
确定注册服务支持的协议
按照确定服务参数步骤中的优先级,确定协议,可以是多个协议。
protocol可以在如下节点配置:
- SpringBoot的application.properties
- dubbo.properties
- 配置中心
- JVM环境变量
启动网络服务器
确定了协议后,就要启动服务。HTTP协议启动tomcat或者jetty,Dubbo协议启动Netty。
在dubbo中,还需要绑定一个RequestHandler用来处理请求。Http服务对应InternalHandler,Dubbo服务对应ExchangeHandler。
详细分析Dubbo协议启动的Server(略)
服务注册
构造服务最终URL
确定了协议、服务名、服务参数后,就可以开始组装成服务URL。
在Dubbo中支持服务动态配置,动态配置可以在服务导出后修改服务的配置。动态配置能够继续给服务增加一些参数,所以把服务的URL注册到注册中心之前,得先按照动态配置中添加的配置重写URL。
简化参数
构造好URL后,还需要简化参数,部分参数已经在URL中体现,例如绑定的端口等。‘
注册到注册中心
如果是用zk做注册中心,接下去会调用zkclient的createNode命令。
导出重试
如果导出失败了,会再次重试导出。
监听
- 通过监听配置中心,获取最新的配置,对最原始的URL重写,如果与当前的URL不相同,就重新导出
重新导出
- 在动态配置中修改网络服务器的参数 server.reset
- 超时时间
- 获取原始的URL,根据配置重写URL
- 重写URL判断与现在的URL是否相同
- 如果与现在的URL不相同,则重新进行服务注册
其他
监听服务导出是否结束
Spring整合Dubbo的框架中,如果服务导出完毕,可以通过监听事件ServiceBeanExportedEvent来实现,发布事件代码位置:org.apache.dubbo.config.spring.ServiceBean#publishExportEvent