如何更好地学习阿里RPC框架dubbo的源代码,Dubbo是一种分布式服务框架，致力于提供高性能和透明的RPC远程服务呼叫方案，以及SOA服务治理程序，网络通信框架的主要核心组件实现了同步ovyync和请求 - 响应消息机制。 .rpc：远程流程调用，支持负载均衡，灾难恢复和群集功能注册表：服务目录框架服务注册和服务事件发布和订阅。 Dubbo使用全簧配置，透明度访问应用程序，没有API入侵，只需使用Spring加载Dubbo配置，加载Dubbo Spress的Schema扩展。
如何更好地学习dubbo源代码,1. DUBBO和Spring集成DUBBO可以非常简单，无论是提供者还是消费者都可以通过春季轮廓配置。配置后，您可以使用Spring Bean公开和调用。不要看到DUBBO API的存在。这是因为Dubbo使用Spring的可扩展架构自定义配置支持。在Spring配置文件中，您可以配置此功能。 Dubbo的XML解析在Meta-Inf下的Spring.Handlers文件中指定：dubbonamespaceHandler。与以前设计的ServiceConfig一样，它被解析为ReferEnceConfig等。 2，JDK SPI扩展以来，达博是一个开源框架，必须有很多可伸缩点。 DUBBO通过扩展JDK SPI机制来扩展。具体而言，在Meta-inf目录中，放置文件名是全名，文件是密钥，值键值对，值是特定实现类的所有类名，键是标志值。由于Dubbo使用URL总线的设计，因此许多参数通过URL对象传递。在实践中，该值由URL中的参数值指定。 DUBBO的SPI延伸由extensloader实现。您可以看到扩展程序源代码。您可以看到Dubbo有三个方面的JDK SPI：（1）JDK SPI仅通过接口类名获取所有实现，扩展程序通过接口类名称和键值获得实现; （2）自适应实现，正在生成代理类，以便根据实际呼叫的一些参数调用的类。 （3）自动ATIC包装实现，这种类型的实现通常会自动激活，通常用于包装类，例如协议的两种实现：ProtocolFilterWrapper，ProtocollisteNerWrapper。 3，URL总线设计Dubbo使用URL总线设计，以使每层脱钩。我们通常的设计将在层和层之间的相互作用之间进行模型，使得层和层之间的通信成本相对较大，并且更麻烦。因此，Dubbo使用层之间的通信来使用URL形式。例如，当注册中心开始时，参数URL是：注册表：//0.0.0.0：9090？ Codec = Registry＆Transporter = Netty这意味着当前是注册中心，绑定到所有IP，端口为9090，THe解析器类型是注册表所使用的底层网络通信框架是netty。其次，Dubbo Start Process Dubbo分为三部分：注册表，服务提供商（提供商），服务消费者（消费者）。 1.注册中心启动进程注册中心的启动过程，主要是要查看两个类：注册表同步，注册库，两个类的初始化方法开始。 RegistrySynchronizer的start方法：（1）将所有配置信息加载到内存; （2）将当前的注册中心信息保存到数据库; （3）启动5个定时器。 5计时器的功能是：（1）自动重定向计时器。默认为1小时。如果当前注册中心的连接数是1.2倍高于平均值，将重定向到其他注册中心，以实现与注册中心群集的平衡数量。 （2）DirtycheckTask，脏数据检查计时器。角色是：检查缓存提供程序，数据库提供程序，缓存消费者，数据库消费者，清除脏数据的数据;清洁无限的提供者和消费者数据;对于现有的智慧或消费者数据库，重新注册和订阅。 （3）换算扫描，更改更改表计时器清理任务。该角色是读取更改酷刑，删除过期的数据。 （4）AlivedCheckTask，注册中心存活状态时序检查，更新注册表表的到期字段，以确定注册表的生存状态。如果有一个新注册表，发送同步消息，将所有注册表的所有地址通知给所有客户端。 （5）换档，更改检查计时器。检查更改表的更改，检查类型包括：参数叠加更改，路由更改，服务消费者更改，重量变化，负载平衡更改。
dubbo,DUBBO的服务流程，还需要一个对象，这是一个相同的对象来维护与服务相关联的所有对象，其中参考是提供者。由于ServiceBean实现了初始化的interface，因此呼叫界面在所有后续后呼叫界面春天实例化bean：[java]视图普通拷贝公共voideriesset（）抛出异常{//如果没有提供者（getProvider（）== null）{//所有IOC容器提供商地图ProviderConfigMap = applicationContext == null null：beanfactoryutils.beansoftypeincludinganceStors（applicationscontext，providerconfig.class，false，false）; if（ProviderConfigMap = null && providerConfigmap.size（）> 0！）？ {Map CompretaceConfigmap = applicationscontext == null？ null：beanfactoryutils.beansoftypeincludinganceStors（ApplicationContext，Protocolconfig.class，false，false）; if（（（protocolcon）fimmap == null || protocolconfigmap.size（）== 0）&& providerConfigmap.size（）> 1）{//与旧版本兼容laveerConfigs = new arraylist（）; for（ProviderConfig配置：ProviderConfigMap.Values（））{if（！config.isdefault（）= null && config.isdefault（）booleanvalue（）。）{providerconfigs.add（config）;}} //关联所有提供者if（ProviderConfigs.size（）> 0）{setProviders（ProviderConfigs）;}} else {ProviderConfig ProviderChfig = null; for（ProviderConfig Config：provalergerconfigmap.values（））{if（config.isdefault（）== null || config.isdefault（）booleanvalue（）。）{if（providerconfig = null！）{oppl nefilealstateexception（offreeLeflealstateException（“重复提供程序配置：“+ ProviceerConfig +”和“+ Config）} ProviderConfig= config;}}}}} {setProvider（ProviderConfig）;}}}}}}} //如果未配置应用程序，则IF（getApplication（）== null＆（getProvider（）= = null || getProvider（ ）。getApplication（）== null））{//获取所有applicationsmap applicationconfigmap = applicationcontext == null null :? beanfactoryutils.beansoftypeincludingancestors（applicationcontext，applicationconfig.class，false，false）; if（！applicationconfigmap = null && applicationconfigmap.size（）> 0）{applicationconfig applicationconfig = null; for（applicationconfig config：。applicationconfigmap.values（））{if（config.isdefault（）== null || config.isdefault（）booleanvalue（））{if（applicationconfig = null）{over neforlalstateexception（！重复应用程序配置：“+ applicationconfig +”和“+ con图）;} applicationconfig = config;}} //相关的应用程序if（applicationconfig！= null）{setapplication（applicationconfig）;}} //如果未配置模块，则（getModule（）== null &&（getProvider（）== null || if（moduleconfigmap = null && moduleconfigmap.size（）！> 0）{moduleconfig moduleconfig = null; for（moduleconfig config：moduleconfigmap.values（））{if（config.indefault（）== null || config.indefault（）。booleanvalue（））{！ if（moduleconfig = null）{抛出新的IllegalStateException（“重复模块配置：”+ ModuleConfig +“和”+ Config）;} ModuleCon图= config;}！}！} //关联模块如果（moduleconfig = null）{setmodule（moduleconfig）;}} //如果未配置注册表，则没有智慧（getRegistries（）== null || getRegistries（） 。size（）== 0）&&（getProvider（）== null || getRegistries（）。getRegistries（）== null || getRegistries（）。getRegistries（）。size（）== 0）&&（getApplication（） == null || getApplication（）。getRegistries（）.. == null || getApplication（）getAregistries（）size（）== 0））{map RegistryConfigmap = applicationContext == null null：beanfactoryutils.beansoftypeincludingancistors（applicationcontext，registryconfig .class，false，false）; if（RegistryConfigMap？！= null && regrestryconfigmap.size（）> 0）{list registryconfigs = new arraylist（）; for（RegistryConfig Config：RegistryConfigMap.Values（））{if（config.isdefault（）== null || config.isdefault（）.booleanvalue（））{RegistryConfigs.add（config）;}} //关联注册表IF（RegistryConfigs！= null && RegistryConfigs.size（）> 0）{super.setRegistries（RegistryConfigs）;}}}}} //如果不配置监视器，则没有派分（GetMonitor（）== null &&（getProvider（）== null || getProvider（）。GetMonitor（）== null）&&（getApplication）== null | | getApplication（）getMonitor（）== null））{Map MonitorConfigMap = ApplicationContext == null null：。？！ beanfactoryutils.beansoftypeincludinganceStors（ApplicationContext，MonitorConfig.Class，False，False）; if（monitorconfigmap = null && monitorconfigmap.size（）> 0）{monitorconfig monitorconfig = null; for（monitorconfig config：monitorconfigmap.values（））{if（config.isdefault（）== null || config.isdefault（）booleanvalue（））{。如果（Moni）！ torconfig = null）{投掷新的IllegalstateException（“重复监视器配置：”+ MonitorConfig +“和”+ Config）;}！ monitorconfig = config;}} //关联的监视器if（monitorconfig = null）{setMonitor（MonitorConfig）; }}} //如果未配置协议，没有provike（（getProtocols（）== NULL || getProtocols（）。大小（）== 0）&&（getProvider（）== NULL || getProvider（）。GetProtocols（ ）== null || getProvider（）。GetProtocols（）。size（）== 0））{map protectconfigmap = applicationcontext == null？ null：beanfactoryutils.beansoftypeincludinganceStors（appli）catentcontext，protocolconfig.class，false，false）; if（！protocolconfigmap = null && protocolconfigmap.size（）> 0）{list protectconfigs = new arraylist（）; for（Protocolcon.fig config：protocolconfigmap.values（））{if（config .indefault（）== null || config.indefault（）。booleanvalue（））{protocolconfigs.add（config）;}} //相关协议（ protocolconfigs！= null && protecencolconfigs.size（）> 0）{super .setprotocols（protocolconfig）;}}} //如果没有配置（getPath（）== null || getPath（）。长度（）== 0 ）{if（beanname！= null && beanname.length（）> 0 && getInterface（）！= null && getInterface（）。length（）> 0 && beanname.startswith（getInterface（）））{setpath（beanname）;}}} //曝光提供程序如果（！isdelay（））{export（）;

责任编辑（崔妮）

以上就是关于**dubbo 源码，dubbo调用耗时**的全部内容，了解更多请关注蚂蚁资源网。