19 重新来过从一个服务消费者的Demo说起

    为了Demo可以正常启动,需要我们先在本地启动一个Zookeeper如下图所示:

    接下来给大家贴一下示例源码,这个源码来源于Dubbo源码目录的 dubbo-demo/dubbo-demo-api 目录下面的dubbo-demo-api-consumer子项目,这里我做了删减,方便看核心代码:
    首先我们定义一个服务接口如下所示:

    2. package link.elastic.dubbo.consumer;
    4. import link.elastic.dubbo.entity.DemoService;
    5. import org.apache.dubbo.common.constants.CommonConstants;
    6. import org.apache.dubbo.config.ApplicationConfig;
    7. import org.apache.dubbo.config.MetadataReportConfig;
    8. import org.apache.dubbo.config.ProtocolConfig;
    9. import org.apache.dubbo.config.ReferenceConfig;
    10. import org.apache.dubbo.config.RegistryConfig;
    11. import org.apache.dubbo.config.bootstrap.DubboBootstrap;
    12. import org.apache.dubbo.rpc.service.GenericService;
    14. public class ConsumerApplication {
    15.             runWithBootstrap();
    16.     }
    17.     private static void runWithBootstrap() {
    18.         ReferenceConfig<DemoService> reference = new ReferenceConfig<>();
    19.         reference.setInterface(DemoService.class);
    20.         reference.setGeneric("true");
    21.         reference.setProtocol("");
    23.         DubboBootstrap bootstrap = DubboBootstrap.getInstance();
    24.         ApplicationConfig applicationConfig = new ApplicationConfig("dubbo-demo-api-consumer");
    25.         applicationConfig.setQosEnable(false);
    26.         applicationConfig.setQosPort(-1);
    27.         bootstrap.application(applicationConfig)
    29.             .protocol(new ProtocolConfig(CommonConstants.DUBBO, -1))
    30.             .reference(reference)
    31.             .start();
    33.         String message = demoService.sayHello("dubbo");
    34.         System.out.println(message);
    36.         // generic invoke
    37.         GenericService genericService = (GenericService) demoService;
    38.         Object genericInvokeResult = genericService.$invoke("sayHello", new String[]{String.class.getName()},
    39.             new Object[]{"dubbo generic invoke"});
    40.         System.out.println(genericInvokeResult);
    42. }

    启动服务,这个时候我们打开Zookeeper图形化客户端来看看这个服务在Zookeeper上面写入来哪些数据,如下图:
    在这里插入图片描述
    在这里插入图片描述

    写入Zookeper上的节点用于服务在分布式场景下的协调,这些节点是比较重要的。

    • 服务提供者配置信息URL形式
    • 服务消费者的配置信息URL形式
    • 服务路由信息
    • 配置信息

    上面这个图就是Dubbo3的注册信息了,后面我们也会围绕细节来说明下,这里可以看下新增了:

    • /dubbo/metadata 元数据信息
    • /dubbo/mapping 服务和应用的映射信息
    • /dubbo/config 注册中心配置
    • /services目录应用信息

    在这里可以大致了解下,在后面会有更详细的源码解析这个示例代码.通过透析代码来看透Dubbo3服务注册原理,服务提供原理。