线偶
线偶

03 启动流程

线偶 发布于  收录于 源码分析 Dubbo 系列

dubbo 基于 3.2.6 版本

入口程序 

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

// registry、protocol、reference、service 都会调用 configManager#addConfig，很重要。
DubboBootstrap bootstrap = DubboBootstrap.getInstance();
    // 设置应用配置
    bootstrap.application(new ApplicationConfig("dubbo-demo-api-consumer"))
        // 注册中心
        .registry(registryConfig)
        // 协议配置
        .protocol(new ProtocolConfig(CommonConstants.DUBBO, -1))
        // 服务引用
        .reference(reference)
        // 服务暴露
        .service(service)
        // 启动 dubbo
        .start();

源码位置: org.apache.dubbo.config.context.AbstractConfigManager#addConfig

阅读全文
DubboSource Code源码分析 Dubbo 系列

01 搭建 Dubbo 源码调试环境

线偶 发布于  收录于 源码分析 Dubbo 系列

dubbo 基于 3.2.6 版本

源码分析，主要介绍服务级别的注册和发现，所以我们需要设置下参数来启用。 选取 dubbo-demo-api 模块作为示例。

provider 示例程序 

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

public class Application {

    private static final String REGISTRY_URL = "zookeeper://127.0.0.1:2181";

    public static void main(String[] args) {
        startWithBootstrap();
    }

    private static void startWithBootstrap() {
        ServiceConfig<DemoServiceImpl> service = new ServiceConfig<>();
        service.setInterface(DemoService.class);
        service.setRef(new DemoServiceImpl());

        RegistryConfig registryConfig = new RegistryConfig(REGISTRY_URL);
        // 注册类型为 service
        registryConfig.setParameters(Collections.singletonMap(RegistryConstants.REGISTRY_TYPE_KEY, RegistryConstants.SERVICE_REGISTRY_TYPE));

        DubboBootstrap bootstrap = DubboBootstrap.getInstance();
        bootstrap.application(new ApplicationConfig("dubbo-demo-api-provider"))
            .registry(registryConfig)
            .protocol(new ProtocolConfig(CommonConstants.DUBBO, -1))
            .service(service)
            .start()
            .await();
    }
}

consumer 示例程序 

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

public class Application {

    private static final String REGISTRY_URL = "zookeeper://127.0.0.1:2181";

    public static void main(String[] args) {
            runWithBootstrap();
    }

    private static void runWithBootstrap() {
        ReferenceConfig<DemoService> reference = new ReferenceConfig<>();
        reference.setInterface(DemoService.class);
        reference.setGeneric("true");

        RegistryConfig registryConfig = new RegistryConfig(REGISTRY_URL);
        // 注册类型为 service
        registryConfig.setParameters(Collections.singletonMap(RegistryConstants.REGISTRY_TYPE_KEY, RegistryConstants.SERVICE_REGISTRY_TYPE));

        DubboBootstrap bootstrap = DubboBootstrap.getInstance();
        bootstrap.application(new ApplicationConfig("dubbo-demo-api-consumer"))
            .registry(registryConfig)
            .protocol(new ProtocolConfig(CommonConstants.DUBBO, -1))
            .reference(reference)
            .start();

        DemoService demoService = bootstrap.getCache().get(reference);
        String message = demoService.sayHello("dubbo");
        System.out.println(message);

        // generic invoke
        GenericService genericService = (GenericService) demoService;
        Object genericInvokeResult = genericService.$invoke("sayHello", new String[]{String.class.getName()},
            new Object[]{"dubbo generic invoke"});
        System.out.println(genericInvokeResult.toString());
    }
}
阅读全文
DubboSource Code源码分析 Dubbo 系列