Dubbo是Alibaba开源的分布式服务框架,咱们能够很是容易地经过Dubbo来构建分布式服务,并根据本身实际业务应用场景来选择合适的集群容错模式,这个对于不少应用都是迫切但愿的,只须要经过简单的配置就可以实现分布式服务调用,也就是说服务提供方(Provider)发布的服务能够自然就是集群服务,好比,在实时性要求很高的应用场景下,可能但愿来自消费方(Consumer)的调用响应时间最短,只须要选择Dubbo的Forking Cluster模式配置,就能够对一个调用请求并行发送到多台对等的提供方(Provider)服务所在的节点上,只选择最快一个返回响应的,而后将调用结果返回给服务消费方(Consumer),显然这种方式是以冗余服务为基础的,须要消耗更多的资源,可是可以知足高实时应用的需求。算法
1、Dubbo服务集群容错
假设咱们使用的是单机模式的Dubbo服务,若是在服务提供方(Provider)发布服务之后,服务消费方(Consumer)发出一次调用请求,刚好此次因为网络问题调用失败,那么咱们能够配置服务消费方重试策略,可能消费方第二次重试调用是成功的(重试策略只须要配置便可,重试过程是透明的);可是,若是服务提供方发布服务所在的节点发生故障,那么消费方再怎么重试调用都是失败的,因此咱们须要采用集群容错模式,这样若是单个服务节点因故障没法提供服务,还能够根据配置的集群容错模式,调用其余可用的服务节点,这就提升了服务的可用性。api
简单地说目前Dubbo支持的集群容错模式,每种模式适应特定的应用场景,能够根据实际须要进行选择。Dubbo内置支持以下6种集群模式:缓存
一、Failover Cluster模式安全
配置值为failover。这种模式是Dubbo集群容错默认的模式选择,调用失败时,会自动切换,从新尝试调用其余节点上可用的服务。服务器
对于一些幂等性操做可使用该模式,如读操做,由于每次调用的反作用是相同的,因此能够选择自动切换并重试调用,对调用者彻底透明。网络
能够看到,若是重试调用必然会带来响应端的延迟,若是出现大量的重试调用,可能说明咱们的服务提供方发布的服务有问题,如网络延迟严重、硬件设备须要升级、程序算法很是耗时,等等,这就须要仔细检测排查了。负载均衡
例如,能够这样显式指定Failover模式,或者不配置则默认开启Failover模式,配置示例以下:框架
<dubbo:service interface="org.shirdrn.dubbo.api.ChatRoomOnlineUserCounterService" version="1.0.0" cluster="failover" retries="2" timeout="100" ref="chatRoomOnlineUserCounterService" protocol="dubbo" > <dubbo:method name="queryRoomUserCount" timeout="80" retries="2" /> </dubbo:service>
上述配置使用Failover Cluster模式,若是调用失败一次,能够再次重试2次调用,服务级别调用超时时间为100ms,调用方法queryRoomUserCount的超时时间为80ms,容许重试2次,最坏状况调用花费时间160ms。若是该服务接口org.shirdrn.dubbo.api.ChatRoomOnlineUserCounterService还有其余的方法可供调用,则其余方法没有显式配置则会继承使用dubbo:service配置的属性值。dom
二、Failfast Cluster模式分布式
配置值为failfast。这种模式称为快速失败模式,调用只执行一次,失败则当即报错。
这种模式适用于非幂等性操做,每次调用的反作用是不一样的,如写操做,
好比交易系统咱们要下订单,若是一次失败就应该让它失败,一般由服务消费方控制是否从新发起下订单操做请求(另外一个新的订单)。
三、Failsafe Cluster模式
配置值为failsafe。失败安全模式,若是调用失败, 则直接忽略失败的调用,
而是要记录下失败的调用到日志文件,以便后续审计。
四、Failback Cluster模式
配置值为failback。失败自动恢复,后台记录失败请求,定时重发。
一般用于消息通知操做。
五、Forking Cluster模式
配置值为forking。并行调用多个服务器,只要一个成功即返回。
一般用于实时性要求较高的读操做,但须要浪费更多服务资源。
六、Broadcast Cluster模式
配置值为broadcast。
广播调用全部提供者,逐个调用,任意一台报错则报错(2.1.0开始支持)。
一般用于通知全部提供者更新缓存或日志等本地资源信息。
上面的6种模式均可以应用于生产环境,咱们能够根据实际应用场景选择合适的集群容错模式。
若是咱们以为Dubbo内置提供的几种集群容错模式都不能知足应用须要,
也能够定制实现本身的集群容错模式,由于Dubbo框架给我提供的扩展的接口,只须要实现接口com.alibaba.dubbo.rpc.cluster.Cluster便可。
2、Dubbo服务负载均衡
Dubbo框架内置提供负载均衡的功能以及扩展接口,咱们能够透明地扩展一个服务或服务集群,根据须要很是容易地增长/移除节点,提升服务的可伸缩性。
Dubbo框架内置提供了4种负载均衡策略,以下所示:
一、Random LoadBalance:随机策略,配置值为random。能够设置权重,有利于充分利用服务器的资源,高配的能够设置权重大一些,低配的能够稍微小一些
二、RoundRobin LoadBalance:轮询策略,配置值为roundrobin。
三、LeastActive LoadBalance:配置值为leastactive。根据请求调用的次数计数,处理请求更慢的节点会受到更少的请求
四、ConsistentHash LoadBalance:一致性Hash策略,具体配置方法能够参考Dubbo文档。相同调用参数的请求会发送到同一个服务提供方节点上,若是某个节点发生故障没法提供服务,则会基于一致性Hash算法映射到虚拟节点上(其余服务提供方)
在实际使用中,只须要选择合适的负载均衡策略值,配置便可,下面是上述四种负载均衡策略配置的示例:
<dubbo:service interface="org.shirdrn.dubbo.api.ChatRoomOnlineUserCounterService" version="1.0.0"
cluster="failover" retries="2" timeout="100" loadbalance="random"
ref="chatRoomOnlineUserCounterService" protocol="dubbo" >
<dubbo:method name="queryRoomUserCount" timeout="80" retries="2" loadbalance="leastactive" />
</dubbo:service>
上述配置,也体现了Dubbo配置的继承性特色,也就是dubbo:service元素配置了loadbalance=”random”,则该元素的子元素dubbo:method若是没有指定负载均衡策略,则默认为loadbalance=”random”,不然若是dubbo:method指定了loadbalance=”leastactive”,则使用子元素配置的负载均衡策略覆盖了父元素指定的策略(这里调用queryRoomUserCount方法使用leastactive负载均衡策略)。