dubbo（2.7.3） 33 收集 dubbo 广播响应

有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步, 认准 https://blog.zysicyj.top

全网最细面试题手册，支持艾宾浩斯记忆法。这是一份最全面、最详细、最高质量的 java 面试题，不建议你死记硬背，只要每天复习一遍，有个大概印象就行了。https://store.amazingmemo.com/chapterDetail/1685324709017001`

Dubbo broadcast2 广播模式收集所有服务提供者的接口响应

背景

适用场景：对于一个 dubbo 消费者，广播调用多个 dubbo 提供者，该消费者可以收集所有服务提供者的响应结果。

示例

  • consumer demo

@Reference 引入服务提供者，其中，令 cluster=”broadcast2”，代表进行一个收集响应结果的广播调用。

广播调用所有服务提供者，逐个调用，并且可以完整的返回所有服务提供者的执行结果 (正确或异常)，并将所有服务提供者的响应结果存于 RpcContext。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@RestController
public class TestServiceConsumer {

    @Reference(interfaceClass = DubboHealthService.class,cluster = "broadcast2")
    private DubboHealthService dubboHealthService;
    
     @GetMapping("/health")
         public String broadCast(){
             try{
                 dubboHealthService.health();
             }catch (Exception e){
                 Map<String, String> m = RpcContext.getServerContext().getAttachments();
                 return m.toString()+"|"+"fail";
             }
             Map<String, String> m = RpcContext.getServerContext().getAttachments();
             return m.toString()+"|"+"success";
         }
}

  • provider demo
1
2
3
4
5
6
7
8
9
10
@Service
public class DubboHealthServiceImpl implements DubboHealthService {

    @Override
    public String health() {
//        int i = 1/0;
        return "i am provider2";
    }
}

  • 执行结果

所有 provider 全部成功：

1
2
3
>curl http://localhost:8081/health
>{broadcast.results=[{"ip":"10.220.47.253","port":20880,"data":"i am provider1"},{"ip":"10.220.47.253","port":20881,"data":"i am provider2"}]}|success%

令其中一个 provider 执行除以零：

1
2
3
>curl http://localhost:8081/health
>{broadcast.results=[{"ip":"10.220.47.253","port":20880,"data":"i am provider1"},{"ip":"10.220.47.253","port":20881,"exceptionMsg":"/ by zero"}]}|success%