關於dubbo的服務降級

1、dubbo降級服務    

    dubbo開發中，可能因爲服務沒有啓動或者網絡不通，調用中會出現RpcException，也就是遠程調用失敗。若是是服務啓動順序的問題，可能加工check="false"的配置能夠獲得很好的解決。可是，若是是服務宕掉或者併發數過高致使的RpcException該如何處理?

    通過過12306搶票的人應該常常會遇到這個問題：在搶票高峯的時候，明明票還有，可是查詢出來的列表倒是爲空的（若是沒票列表也應該會呈現）；等高峯事後再查詢，列表又恢復正常。我的猜想應該是查詢過程當中出現了問題，要麼超時，要麼網絡問題致使查詢失敗採用的服務降級處理。因此，最終呈現給用戶的並非內部系統出錯之類的提示，而是一個空的列表。好了，言歸正傳，在dubbo中想實現服務降級，須要怎麼樣作能夠實現？

    查看dubbo的官方文檔，能夠發現有個mock的配置，mock只在出現非業務異常(好比超時，網絡異常等)時執行。mock的配置支持兩種，一種爲boolean值，默認的爲false。若是配置爲true，則缺省使用mock類名，即類名+Mock後綴；另一種則是配置"return null"，能夠很簡單的忽略掉異常。

2、結合dubbo的例子

說明下面將經過一個例子進行說明：

/**接口定義*/
public interface IUser {
 
    public void addUser(User u);
     
    public User getUserById(int id);
     
}
 
/**實現類*/
public class UserImpl implements IUser {
     
    private static List<User> USER_LIST = new ArrayList<User>();
     
    static{
        for(int i=0;i<10;i++){
            User u = new User();
            u.setAddress("address"+i);
            u.setId(i);
            u.setName("name"+i);
             
            USER_LIST.add(u);
        }
    }
     
    public void addUser(User u) {
        USER_LIST.add(u);
        System.out.println("total:"+USER_LIST.size());
    }
 
    public User getUserById(int id) {
        for(int i=0;i<USER_LIST.size();i++){
            if(USER_LIST.get(i).getId() == id){
                return USER_LIST.get(i);
            }
        }
        return null;
    }
}

 

dubbo-provider.xml配置:

<?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="hello-world-app" />

	<!-- 使用multicast廣播註冊中心暴露服務地址 -->
	<dubbo:registry address="zookeeper://127.0.0.1:2181" />

	<!-- 用dubbo協議在20880端口暴露服務 -->
	<dubbo:protocol name="dubbo" port="20880" />

	<!-- 聲明須要暴露的服務接口 -->
	<dubbo:service interface="com.zzq.test.iface.IUser" ref="userImpl" timeout="10000" />

	<!-- 和本地bean同樣實現服務 -->
	<bean id="userImpl" class="com.zzq.test.ifaceimpl.UserImpl" />

</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" />
 
    <!-- 生成遠程服務代理，能夠和本地bean同樣使用demoService -->
    <dubbo:reference id="iUser" interface="com.zzq.test.iface.IUser"  timeout="10000" check="false" mock="return null">
    </dubbo:reference>
 
</beans>

調用的測試代碼：

public static void main(String[] args) throws Exception{
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"classpath:dubbo-consumer.xml"});
	    context.start();
	    
	    IUser iUser = (IUser)context.getBean("iUser");
	    User u = new User();
	    u.setAddress("aaa");
	    u.setId(311);
	    u.setName("n3");
	    iUser.addUser(u);
	    System.out.println(iUser.getUserById(1));
	}

經過測試，若是服務啓動，則程序按照預期的運行正常；若是服務沒啓動，則此時運行程序，程序並未報錯，打印出null。

3、思考

    經過以上的例子能夠知道，經過mock的配置，能夠很好的實現dubbo服務降級。可是，仔細查看上面的例子會發現，IUser自己定義了兩個接口，一個是新增用戶，一個是根據id查詢用戶信息。對於根據id查詢用戶信息，在調用失敗的時候返回null很好理解，多是因爲驗證失敗或者記錄刪除了，可是對於新增用戶，可能就須要拋出具體的業務信息，不然程序沒法處理後續的業務，包括頁面彈出」添加成功「或者列表刷新的時候沒法查看到最新的記錄，這樣體驗將會很是很差。因此，若是要有較好的區分，能夠經過如下的方式，能夠更好的實現降級：

（1）將接口進行歸類，查詢類和變動操做類：對於查詢的分爲一個接口類，變動的歸類爲其餘的接口類，這樣對於查詢的可使用mock="return null"進行降級操做；對於變動類的，能夠仍舊使用try……catch進行異常捕獲處理；

（2）配置mock="true"，同時mock實現接口，接口名要注意命名規範：接口名+Mock後綴。此時若是調用失敗會調用Mock實現。mock實現須要保證有無參的構造方法。

配置mock="true"的狀況，對於上面的例子即在IUser的同個路徑下，添加類IUserMock，實現以下：

public class IUserMock implements IUser {

	@Override
	public void addUser(User u) {
		throw new RuntimeException("add user fail!");
	}

	@Override
	public User getUserById(int id) {
		return null;
	}

}