如何基于 dubbo 进行服务治理、服务降级、失败重试以及超时重试?php
服务治理,这个问题若是问你,其实就是看看你有没有服务治理的思想,由于这个是作过复杂微服务的人确定会遇到的一个问题。java
服务降级,这个是涉及到复杂分布式系统中必备的一个话题,由于分布式系统互相来回调用,任何一个系统故障了,你不降级,直接就全盘崩溃?那就太坑爹了吧。面试
失败重试,分布式系统中网络请求如此频繁,要是由于网络问题不当心失败了一次,是否是要重试?spring
超时重试,同上,若是不当心网络慢一点,超时了,如何重试?网络
一个大型的分布式系统,或者说是用如今流行的微服务架构来讲吧,分布式系统由大量的服务组成。那么这些服务之间互相是如何调用的?调用链路是啥?说实话,几乎到后面没人搞的清楚了,由于服务实在太多了,可能几百个甚至几千个服务。架构
那就须要基于 dubbo 作的分布式系统中,对各个服务之间的调用自动记录下来,而后自动将各个服务之间的依赖关系和调用链路生成出来,作成一张图,显示出来,你们才能够看到对吧。app
须要自动统计各个接口和服务之间的调用次数以及访问延时,并且要分红两个级别。async
这些东西都搞定了以后,后面才能够来看当前系统的压力主要在哪里,如何来扩容和优化啊。分布式
好比说服务 A 调用服务 B,结果服务 B 挂掉了,服务 A 重试几回调用服务 B,仍是不行,那么直接降级,走一个备用的逻辑,给用户返回响应。ide
举个栗子,咱们有接口 HelloService
。HelloServiceImpl
有该接口的具体实现。
public interface HelloService {
void sayHello();
}
public class HelloServiceImpl implements HelloService {
public void sayHello() {
System.out.println("hello world......");
}
}
复制代码
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="dubbo-provider" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:service interface="com.zhss.service.HelloService" ref="helloServiceImpl" timeout="10000" />
<bean id="helloServiceImpl" class="com.zhss.service.HelloServiceImpl" />
</beans>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="dubbo-consumer" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:reference id="fooService" interface="com.test.service.FooService" timeout="10000" check="false" mock="return null">
</dubbo:reference>
</beans>
复制代码
咱们调用接口失败的时候,能够经过 mock
统一返回 null。
mock 的值也能够修改成 true,而后再跟接口同一个路径下实现一个 Mock 类,命名规则是 “接口名称+Mock
” 后缀。而后在 Mock 类里实现本身的降级逻辑。
public class HelloServiceMock implements HelloService {
public void sayHello() {
// 降级逻辑
}
}
复制代码
所谓失败重试,就是 consumer 调用 provider 要是失败了,好比抛异常了,此时应该是能够重试的,或者调用超时了也能够重试。配置以下:
<dubbo:reference id="xxxx" interface="xx" check="true" async="false" retries="3" timeout="2000"/>
复制代码
举个栗子。
某个服务的接口,要耗费 5s,你这边不能干等着,你这边配置了 timeout 以后,我等待 2s,还没返回,我直接就撤了,不能干等你。
能够结合大家公司具体的场景来讲说你是怎么设置这些参数的:
timeout
:通常设置为 200ms
,咱们认为不能超过 200ms
还没返回。retries
:设置 retries,通常是在读请求的时候,好比你要查询个数据,你能够设置个 retries,若是第一次没读到,报错,重试指定的次数,尝试再次读取。