最近在学习dubbo框架，dubbo是一个远程RPC调用框架，提供了很多角色，如下所示：

节点角色说明

调用关系说明

1. 服务容器负责启动，加载，运行服务提供者。
2. 服务提供者在启动时，向注册中心注册自己提供的服务。
3. 服务消费者在启动时，向注册中心订阅自己所需的服务。
4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

本文采用zookeeper作为注册中心（版本3.6.1)

服务提供方实现如下：

1. maven依赖如下：

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>${dubbo.version}</version>
            <type>pom</type>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.6.1</version>
        </dependency>

    </dependencies>

2. 提供dubbo远程调用的API

package com.huang.dubbo.api;

/**
 * @Author: huangyichun
 * @Date: 2021/3/30
 */
public interface GreetingsService {
    String sayHi(String name);
}

package com.huang.dubbo.api;

import org.apache.dubbo.config.annotation.DubboService;

/**
 * @Author: huangyichun
 * @Date: 2021/3/30
 */
@DubboService
public class GreetingsServiceImpl implements GreetingsService {
    @Override
    public String sayHi(String name) {
        return "hi, " + name;
    }
}

3. dubbo配置

# dubbo-provider.properties
dubbo.application.name=annotation-provider
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

4. 加载配置文件

package com.huang.dubbo;

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.PropertySource;

@SpringBootApplication
@EnableDubbo(scanBasePackages = "com.huang.dubbo.api")
@PropertySource("classpath:/dubbo-provider.properties")
public class DubboApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboApplication.class, args);
    }

}

消费端实现：

1. dubbo配置

<?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://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <dubbo:application name="consumer-of-helloworld-app"  />

    <!-- 使用multicast广播注册中心暴露发现服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="greetingsService" interface="com.huang.dubbo.api.GreetingsService" check="true"/>

</beans>

2. 测试类

package com.huang.dubbo;

import com.huang.dubbo.api.GreetingsService;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * @Author: huangyichun
 * @Date: 2021/3/30
 */
public class Consumer {


    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"consumer.xml"});
        context.start();
        GreetingsService demoService = (GreetingsService)context.getBean("greetingsService"); // 获取远程服务代理
        String hello = demoService.sayHi("world ------------------------"); // 执行远程方法
        System.out.println( hello );
    }
}

输出结果如下：

hi, world ------------------------

查看zookeeper节点信息如下：

ls /dubbo/com.huang.dubbo.api.GreetingsService/providers 
[dubbo%3A%2F%2F10.12.214.93%3A20880%2Fcom.huang.dubbo.api.GreetingsService%3Fanyhost%3Dtrue%26application%3Dannotation-provider%26deprecated%3Dfalse%26dubbo%3D2.0.2%26dynamic%3Dtrue%26generic%3Dfalse%26interface%3Dcom.huang.dubbo.api.GreetingsService%26metadata-type%3Dremote%26methods%3DsayHi%26pid%3D10258%26release%3D2.7.9%26side%3Dprovider%26timestamp%3D1617332790089]