Springboot整合Dubbo启动解析Bean定义

根据springboot启动原理，会先把启动类下的所有类先进行解析bean定义，所以要先EnableDubbo这个注解，再根据这个注解里面的注解，可以知道import的两个类DubboComponentScanRegistrar和DubboConfigConfigurationSelector

DubboConfigConfigurationSelector看上去主要用来加载dubbo配置的一些信息

DubboAutoConfiguration这个类是在自动装配是加载的

本地的类定义和spring.factories需要的类定义加载完会调用this.reader.loadBeanDefinitions(configClasses);开始对ImportBeanDefinitionRegistrar注解的类进行bean定义注册，DubboComponentScanRegistrar做了两件事，注册了ServiceAnnotationBeanPostProcessor和ReferenceAnnotationBeanPostProcessor的bean定义

然后在ServiceAnnotationBeanPostProcessor扫描出有dubbo的@Service注解的类进行注册，这里会新增一个bean定义类ServiceBean:userServiceIml:xx.xx.comsumer.service.UserService，这个类的class是ServiceBean，以此类推会把所有的@com.alibaba.dubbo.config.annotation.Service注解的都解析了

ReferenceAnnotationBeanPostProcessor主要是对@Reference注解的类做动态代理

Service暴露

等springboot创建完所有bean，由于ServiceBean实现了ApplicationListener接口，所以在ServiceBean的类一些bean创建完之后，会调用onApplicationEvent这个方法，这个方法就是对服务的暴露

给provider，module，registries，monitor，protocols填充属性

JavassistProxyFactory做动态代理

InjvmProtocol导出

然后就是远程导出

导出服务

到这里就是创建完netty了，就是获取注册中心注册数据

整个过程差不多就是这样

Reference服务发现

由于ReferenceBean实现了FactoryBean，所以在创建bean的时候会调用getObject方法

消费者调用提供者服务

Dubbo总结

dubbo协议

支持多协议，默认dubbo协议还有rmi，hessian，http，webservice，hrift，memcached，redis，rest等协议

注册中心

支持多注册中心，默认使用 Zookeeper 作为注册中心，还有 Redis、Multicast、Simple 注册中心，但不推荐。dubbo会把数据存到本地，所以注册中心挂了，消费者也可以调用提供者

负载均衡

随机，轮训，活跃度，一致性hash

Dubbo容错策略

failover cluster模式

provider 宕机重试以后，请求会分到其他的provider上，默认两次，可以手动设置重试次数，建议把写操作重试次数设置成0。

failback模式

失败自动恢复会在调用失败后，返回一个空结果给服务消费者。并通过定时任务对失败的调用进行重试，适合执行消息通知等操作。

failfast cluster模式

快速失败只会进行一次调用，失败后立即抛出异常。适用于幂等操作，写操作，类似于failover cluster模式中重试次数设置为0的情况。

failsafe cluster模式

失败安全是指，当调用过程中出现异常时，仅会打印异常，而不会抛出异常。适用于写入审计日志等操作。

forking cluster模式

并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过 forks=“2” 来设置最大并行数。

broadcacst cluster模式

广播调用所有提供者，逐个调用，任意一台报错则报错。通常用于通知所有提供者更新缓存或日志等本地资源信息。

序列化

dubbo序列化：阿里尚未开发成熟的高效java序列化实现，阿里不建议在生产环境使用它

hessian2序列化(默认推荐)：hessian是一种跨语言的高效二进制序列化方式。但这里实际不是原生的hessian2序列化，而是阿里修改过的hessian lite，它是dubbo RPC默认启用的序列化方式

json序列化：目前有两种实现，一种是采用的阿里的fastjson库，另一种是采用dubbo中自己实现的简单json库，但其实现都不是特别成熟，而且json这种文本序列化性能一般不如上面两种二进制序列化。

java序列化：主要是采用JDK自带的Java序列化实现，性能很不理想。

整体设计

图例说明：

• 图中左边淡蓝背景的为服务消费方使用的接口，右边淡绿色背景的为服务提供方使用的接口，位于中轴线上的为双方都用到的接口。
• 图中从下至上分为十层，各层均为单向依赖，右边的黑色箭头代表层之间的依赖关系，每一层都可以剥离上层被复用，其中，Service 和 Config 层为 API，其它各层均为 SPI。
• 图中绿色小块的为扩展接口，蓝色小块为实现类，图中只显示用于关联各层的实现类。
• 图中蓝色虚线为初始化过程，即启动时组装链，红色实线为方法调用过程，即运行时调用链，紫色三角箭头为继承，可以把子类看作父类的同一个节点，线上的文字为调用的方法。

各层说明

• Config 配置层：对外配置接口，以 ServiceConfig, ReferenceConfig 为中心，可以直接初始化配置类，也可以通过 spring 解析配置生成配置类
• Proxy 服务代理层：服务接口透明代理，生成服务的客户端 Stub 和服务器端 Skeleton, 以 ServiceProxy 为中心，扩展接口为 ProxyFactory
• Registry 注册中心层：封装服务地址的注册与发现，以服务 URL 为中心，扩展接口为 RegistryFactory, Registry, RegistryService
• Cluster 路由层：封装多个提供者的路由及负载均衡，并桥接注册中心，以 Invoker 为中心，扩展接口为 Cluster, Directory, Router, LoadBalance
• Monitor 监控层：RPC 调用次数和调用时间监控，以 Statistics 为中心，扩展接口为 MonitorFactory, Monitor, MonitorService
• Protocol 远程调用层：封装 RPC 调用，以 Invocation, Result 为中心，扩展接口为 Protocol, Invoker, Exporter
• Exchange 信息交换层：封装请求响应模式，同步转异步，以 Request, Response 为中心，扩展接口为 Exchanger, ExchangeChannel, ExchangeClient, ExchangeServer
• Transport 网络传输层：抽象 mina 和 netty 为统一接口，以 Message 为中心，扩展接口为 Channel, Transporter, Client, Server, Codec
• Serialize 数据序列化层：可复用的一些工具，扩展接口为 Serialization, ObjectInput, ObjectOutput, ThreadPool

Zookeeper和Dubbo的关系

在 Provider 上可以配置的 Consumer 端的属性有哪些

1）timeout：方法调用超时
2）retries：失败重试次数，默认重试 2 次
3）loadbalance：负载均衡算法，默认随机
4）actives 消费者端，最大并发调用限制

Dubbo启动时如果依赖的服务不可用会怎样

Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，默认 check="true"，可以通过 check="false" 关闭检查。

当一个服务接口有多种实现时怎么做

当一个接口有多种实现时，可以用 group 属性来分组，服务提供方和消费方都指定同一个 group 即可。

服务上线怎么兼容旧版本

可以用版本号（version）过渡，多个不同版本的服务注册到注册中心，版本号不同的服务相互间不引用。这个和服务分组的概念有一点类似。

Dubbo可以对结果进行缓存吗

可以，Dubbo 提供了声明式缓存，用于加速热门数据的访问速度，以减少用户加缓存的工作量。

Dubbo服务之间的调用是阻塞的吗

默认是同步等待结果阻塞的，支持异步调用。

Dubbo 是基于 NIO 的非阻塞实现并行调用，客户端不需要启动多线程即可完成并行调用多个远程服务，相对多线程开销较小，异步调用会返回一个 Future 对象。

异步调用流程图如下。