Dubbo简介

Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分业务的架构，使用这种方式可以使各个业务之间解耦合（或者最大限度地松耦合）。

简单来说Dubbo:

一款分布式服务框架
高性能和透明化的RPC远程服务调用方案
SOA服务治理方案

Dubbo架构

这里写图片描述

Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务消费方。
Registry: 服务注册与发现的注册中心。
Monitor: 统计服务的调用次数和调用时间的监控中心。

调用流程

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

SpringBoot整合Dubbo

项目整体架构

这里写图片描述

这里还用到了Zookeeper注册中心,所以需要到Zookeeper官网下载压缩包，下载后进行解压，然后启动Zookeeper，点击解压包下的bin/zkServer.cmd:

这里还用到了zookeeper的可视化工具ZK UI。

服务监控中心搭建：dubbo-admin的下载，地址：https://github.com/Linliuxing/dubbo-admin
直接下载zip包，解压后将dubbo-admin下的内容全部拷贝到本地tomcat的webapps下
在运行tomcat之前，先将zookeeper启动，如果不配置监控中心（WEB-INF/dubbo.properties，内容如下），

       dubbo.registry.address=zookeeper://127.0.0.1:2181
       dubbo.admin.root.password=root
　　　　dubbo.admin.guest.password=guest

默认启动tomcat即可,http://localhost:8080/dubbo-admin, 登录时输入root/root

这里写图片描述

SpringBoot添加Dubbo和Zookeeper依赖：

        <!--spring-boot-starter-dubbo-->
        <dependency>
            <groupId>com.gitee.reger</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.1.1</version>
        </dependency>
        <!-- 引入zookeeper，去除其中的log4j，否则会因为日志原因导致堆栈溢出 -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.10</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

springboot-dubbo-api：

定义服务接口ProviderService ：

public interface ProviderService {
    String sayHello(String name);
}

springboot-dubbo-provider：

application.yml配置信息：

server:
    port: 8081
spring:
  dubbo:
    application:
      name: service-provider
    base-package: com.lin.service # dubbo服务发布者所在的包
    registry:
      address: 192.168.0.116 # zookeeper注册中心的地址
      port: 2181       # zookeeper注册中心的端口
      protocol: zookeeper
      register: true
    protocol:
      name: dubbo
      port: 20880
      accesslog: true
    provider:
      retries: 1
      delay: -1

服务实现类：

@Service(version = "1.0.0")
@Component
public class ProviderServiceImpl implements ProviderService {
    @Override
    public String sayHello(String name) {
        return "Hello "+name;
    }
}

springboot-dubbo-consumer：

application.yml配置信息：

server:
    port: 8082
spring:
  dubbo:
    application:
      name: service-consumer
    base-package: com.lin.service  # dubbo服务调用者所在的包
    registry:
      address: 192.168.0.116  # zookeeper注册中心的地址
      port: 2181              # zookeeper注册中心的端口
      protocol: zookeeper
      subscribe: true
    protocol:
      name: dubbo
      host: 192.168.0.116
    consumer:
      timeout: 1000
      check: false  # 服务启动时检查被调用服务是否可用
      retries: 2    # 服务调用重试次数

调用服务提供者的服务：

@RestController
public class Consumer   {

    // 使用兼容注入，可以使用dubbo原生注解@Reference注入
    @Reference(version = "1.0.0")
    public ProviderService service;

    @GetMapping(value = "/hello/{name}")
    public String hello(@PathVariable String name){
        return service.sayHello(name);
    }
}

测试：