1. 程式人生 > >33、基於dubbo如何做服務治理、服務降級以及重試?

33、基於dubbo如何做服務治理、服務降級以及重試?

1、面試題

如何基於dubbo進行服務治理、服務降級、失敗重試以及超時重試?

2、面試官心裡分析

服務治理,這個問題如果問你,其實就是看看你有沒有服務治理的思想,因為這個是做過複雜微服務的人肯定會遇到的一個問題。

服務降級,這個是涉及到複雜分散式系統中必備的一個話題,因為分散式系統互相來回呼叫,任何一個系統故障了,你不降級,直接就全盤崩潰?那就太坑爹了吧!

失敗重試,分散式系統中網路請求如此頻繁,要是因為網路問題不小心失敗了一次,是不是要重試?

超時重試,同上,如果不小心網路慢一點,超時了,如何重試?

(1)dubbo工作原理:服務註冊,註冊中心,消費者,代理通訊,負載均衡;
(2)網路通訊、序列化:dubbo協議,長連線,NIO,hessian序列化協議;
(3)負載均衡策略,叢集容錯策略,動態代理策略:dubbo跑起來的時候一些功能是如何運轉的,怎麼做負載均衡?怎麼做叢集容錯?怎麼生成動態代理?
(4)dubbo SPI機制:你瞭解不瞭解dubbo的SPI機制?如何基於SPI機制對dubbo進行擴充套件?
(5)dubbo的服務治理、降級、重試。

3、面試題剖析

(1)服務治理

1)呼叫鏈路自動生成

一個大型的分散式系統,或者說是用現在流行的微服務架構來說吧,分散式系統由大量的服務組成。那麼這些服務之間互相是如何呼叫的?呼叫鏈路是啥?說實話,幾乎到後面沒人搞的清楚了,因為服務實在太多了,可能幾百個甚至幾千個服務。

那就需要基於dubbo做的分散式系統中,對各個服務之間的呼叫自動記錄下來,然後自動將各個服務之間的依賴關係和呼叫鏈路生成出來,做成一張圖,顯示出來,大家才可以看到對吧。

服務A -> 服務B -> 服務C
-> 服務E
-> 服務D
-> 服務F
-> 服務W

2)服務訪問壓力以及時長統計

需要自動統計各個介面和服務之間的呼叫次數以及訪問延時,而且要分成兩個級別。一個級別是介面粒度,就是每個服務的每個介面每天被呼叫多少次,TP50,TP90,TP99,三個檔次的請求延時分別是多少;第二個級別是從源頭入口開始,一個完整的請求鏈路經過幾十個服務之後,完成一次請求,每天全鏈路走多少次,全鏈路請求延時的TP50,TP90,TP99,分別是多少。

這些東西都搞定了之後,後面才可以來看當前系統的壓力主要在哪裡,如何來擴容和優化啊!

3)其他的

服務分層(避免迴圈依賴),呼叫鏈路失敗監控和報警,服務鑑權,每個服務的可用性的監控(介面呼叫成功率?幾個9?)99.99%,99.9%,99%

(2)服務降級

比如說服務A呼叫服務B,結果服務B掛掉了,服務A重試幾次呼叫服務B,還是不行,直接降級,走一個備用的邏輯,給使用者返回響應

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() {
// 降級邏輯
}

}

(3)失敗重試和超時重試

所謂失敗重試,就是consumer呼叫provider要是失敗了,比如拋異常了,此時應該是可以重試的,或者呼叫超時了也可以重試。

<dubbo:reference id="xxxx" interface="xx" check="true" async="false" retries="3" timeout="2000"/>

某個服務的介面,要耗費5s,你這邊不能幹等著,你這邊配置了timeout之後,我等待2s,還沒返回,我直接就撤了,不能幹等你

如果是超時了,timeout就會設定超時時間;如果是呼叫失敗了自動就會重試指定的次數

你就結合你們公司的具體的場景來說說你是怎麼設定這些引數的,timeout,一般設定為200ms,我們認為不能超過200ms還沒返回

retries,3次,設定retries,還一般是在讀請求的時候,比如你要查詢個數據,你可以設定個retries,如果第一次沒讀到,報錯,重試指定的次數,嘗試再次讀取2次。

文集:https://www.jianshu.com/nb/32293473