Dubbo探索（二）之合並結果擴展

目的：分組聚合中，自定義合並策略，合並不同分組返回的結果

實現：

首先，假設提供方provider提供了UserService接口的多個實現，分別為UserServiceImpl和AnotherUserServiceImpl,分別隸屬於db和mock組， 消費方將調用這兩個服務，並按照自定義策略合並他們的返回結果，作為最終結果。整體結構如下：

代碼結構如下：

provider方：

    service

         -- UserServiceImpl.java   # 實現從數據庫讀取用戶數據

         -- AnotherUserServiceImpl.java   # mock用戶數據作為返回結果

    resources

         -- dubbo-provider.xml  

dubbo-provider.xml中配置service如下              

<dubbo:service ref="userService" group="db" interface="com.patty.dubbo.api.service.UserService"/>

<dubbo:service ref="anotherUserService" group="mock" interface="com.patty.dubbo.api.service.UserService"/>

consumer方：

    service

        -- MyMerger.java   # 擴展Merger接口，實現自定義的合並策略

    resources

        -- dubbo-consumer.xml

        -- META-INF.dubbo

             -- com.alibaba.dubbo.rpc.cluster.Merger   # 純文本文件， 映射自定義的merger名稱到相應的實現類

本例中，映射內容為：

    myMerger=com.patty.dubbo.consumer.service.MyMerger

dubbo-consumer.xml中配置merger合並器：

 <dubbo:reference id="userService" group="*" interface="com.patty.dubbo.api.service.UserService"
                     timeout="10000" retries="3" mock="true">
        <dubbo:method name="findAllUsers" merger="myMerger">
        </dubbo:method>
 </dubbo:reference>

MyMerger實現如下：

public class MyMerger implements Merger<List<UserVo>> {

    @Override
    public List<UserVo> merge(List<UserVo>... userVoLists) {
        ArrayList<UserVo> result = new ArrayList<>();
        for (List<UserVo> userVoList : userVoLists) {
            for (UserVo userVo : userVoList) {
                if (userVo.getwId().equals("10")) {
                    userVoList.remove(userVo);
                }
            }
            result.addAll(userVoList);
        }
        return result;
    }
}

該類實現 com.alibaba.dubbo.rpc.cluster.Merger接口。

具體實現參考：https://github.com/pattywgm/dubbo-demo/tree/577c289d0ef3b0e45361e1ac6141ccb2b1cdb8c3