Dubbo是阿里的内部RPC框架，于2011年对外提供，2019年捐献给Apache，至此由Apache维护更新，Dubbo依赖Spring，除了RPC访问外，还提供了服务治理功能，如：负载均衡、数据统计等

结合上图，Dubbo主要分为5个角色：

图中虚线部分均为异步，实线为同步，流程为：

0. start：启动Spring容器时，初始化Provider
1. register：Provider信息注册到Registry
2. subscribe：Consumer通过Registry订阅
3. notify：Registry将Provider信息通知给Consumer
4. invoke：Consumer通过Provider信息调用Provider方法
5. count：将访问信息上传到Monitor

Dubbo支持的协议

Dubbo支持的注册中心

一、使用Dubbo

创建一个maven工程，依赖springboot

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.0</version>
    </parent>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <version>2.7.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.7.0</version>
            </dependency>
            <!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter -->
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>2.7.8</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
                <version>4.2.0</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

1. api模块

新建Maven子模块，作为对外接口：

定义接口：

public interface DemoService {
    public String demo(String demo);
}

2. provider模块

新建Maven子模块，作为提供者

2.1 导入依赖

provider不需要作为web项目

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!--dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <!--zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
        </dependency>
        <!--api模块-->
        <dependency>
            <groupId>com.aruba.demo1</groupId>
            <artifactId>api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>

2.2 springboot配置文件

resources目录下新建application.yml，配置dubbo，内容如下：

dubbo:
  application:
    name: dubbo-provider
  registry:
    address: zookeeper://192.168.42.4:2181

2.3 实现对外接口

使用@DubboService注解，表示该对象为Dubbo使用的Provider对象

@DubboService
public class DemoServiceImpl implements DemoService {

    @Override
    public String demo(String demo) {
        return demo + ",hello";
    }

}

2.4 启动springboot

使用注解开启dubbo

@SpringBootApplication
@EnableDubbo
public class ProviderApplication {

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

}

3. consumer模块

创建一个Maven子模块，作为调用方

3.1 导入依赖

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <!--zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
        </dependency>
        <!--api模块-->
        <dependency>
            <groupId>com.aruba.demo1</groupId>
            <artifactId>api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>

3.2 springboot配置文件

在resources目录下新建application.xml，内容为：

dubbo:
  application:
    name: dubbo-consumer
  registry:
    address: zookeeper://192.168.42.4:2181

3.3 service层

定义接口：

public interface DemoConsumerService {
    public String demoConsumer();
}

实现接口，远程对象使用@DubboReference注解注入：

@Service
public class DemoConsumerServiceImpl implements DemoConsumerService {

    @DubboReference
    private DemoService service;

    @Override
    public String demoConsumer() {
        return service.demo("dubbo");
    }
}

3.4 controller层

@RestController
public class DemoController {

    @Autowired
    private DemoConsumerService service;

    @RequestMapping("/demo")
    public String demo() {
        return service.demoConsumer();
    }

}

3.5 SpringBoot启动类

同样需要使用@EnableDubbo注解开启dubbo

@SpringBootApplication
@EnableDubbo
public class ConsumerApplication {

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

}

浏览器访问结果：

二、负载均衡

Dubbo内置了以下负载均衡策略：

使用方式

Provider和Consumer都可以使用以上策略，指定策略名使用全小写，第一种方式为注解时指定：

第二种方式为springboot配置文件中指定全局策略：

dubbo:
  application:
    name: dubbo-provider
  registry:
    address: zookeeper://192.168.42.4:2181
  #指定provider的负载均衡策略
  provider:
    loadbalance: random
  #指定consumer的负载均衡策略
  consumer:
    loadbalance: random

下面以Provider注解为例子

1. 为Provider实现类指定策略

方法中加个控制台输出，以便于后续观察负载均衡策略的效果

@DubboService(weight = 1, loadbalance = "roundrobin")
public class DemoServiceImpl implements DemoService {

    @Override
    public String demo(String demo) {
        System.out.println(demo);
        return demo + ",hello";
    }

}

2. 模拟集群环境

复制springboot启动类：

springboot配置文件中，指定协议端口，来启动多次

dubbo:
  application:
    name: dubbo-provider
  registry:
    address: zookeeper://192.168.42.4:2181
  protocol:
    name: dubbo
    port: 20881

修改port，我这边是从20881改到20884，每次修改完启动下对应的springboot启动类，4个启动完的效果：

3. Consumer调用

轮询的效果是依次访问节点，启动Consumer后，进行浏览器访问：

项目地址：

https://gitee.com/aruba/dubbo.git