一、Dubbo简介

Dubbo 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，服务自动注册和发现。

1、特性

（1）服务注册中心

相比Hessian类RPC框架，Dubbo有自己的服务中心， 写好的服务可以注册到服务中心， 客户端从服务中心寻找服务，然后再到相应的服务提供者机器获取服务。通过服务中心可以实现集群、负载均衡、高可用(容错) 等重要功能。服务中心一般使用zookeeper实现，也有redis和其他一些方式。以使用zookeeper作为服务中心为例，服务提供者启动后会在zookeeper的/dubbo节点下创建提供的服务节点，包含服务提供者ip、port等信息。服务提供者关闭时会从zookeeper中移除对应的服务。服务使用者会从注册中心zookeeper中寻找服务，同一个服务可能会有多个提供者，Dubbo会帮我们找到合适的服务提供者，也就是针对服务提供者的负载均衡。

（2）负载均衡

当同一个服务有多个提供者在提供服务时，客户端如何正确地选择提供者实现负载均衡呢？dubbo也给我们提供了几种方案：

• random随机选择提供者，并可以给提供者设置权重
• roundrobin轮询选择提供者
• leastactive 最少活跃调用数，相同活跃数的随机，活跃数：指调用前后计数差。使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。
• consistenthash 一致性hash，相同参数的请求发到同一台机器上。

（3）简化测试，允许直连提供者 在开发阶段为了方便测试，通常系统客户端能指定调用某个服务提供者，那么可以在引用服务时加一个url参数去指定服务提供者。

（4）服务版本，服务分组 在Dubbo配置文件中可以通过指定版本实现连接指定提供者，也就是通过服务版本可以控制服务的不兼容升级；当同一个服务有多种实现时，可以使用服务分组进行区分。

2、设计架构

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

3、配置原则

1. JVM 启动 -D 参数优先，这样可以使用户在部署和启动时进行参数重写，比如在启动时需改变协议的端口。
2. XML 次之，如果在 XML 中有配置，则 dubbo.properties 中的相应配置项无效。
3. Properties 最后，相当于缺省值，只有 XML 没有配置时，dubbo.properties 的相应配置项才会生效，通常用于共享公共配置，比如应用名。

4、高可用

通过设计，减少系统不能提供服务的时间 zookeeper宕机与dubbo直连 现象：zookeeper注册中心宕机，还可以消费dubbo暴露的服务。 原因：

• 监控中心宕掉不影响使用，只是丢失部分采样数据
• 数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务
• 注册中心对等集群，任意一台宕掉后，将自动切换到另一台
• 注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯
• 服务提供者无状态，任意一台宕掉后，不影响使用
• 服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复

5、服务降级

当服务器压力剧增的情况下，根据实际业务情况及流量，对一些服务和页面有策略的不处理或换种简单的方式处理，从而释放服务器资源以保证核心交易正常运作或高效运作。 可以通过服务降级功能临时屏蔽某个出错的非关键服务，并定义降级后的返回策略。

二、搭建环境

1、控制台管理

1.1 启动zookeeper：

/opt/module/zookeeper-3.4.10/bin/zkServer.sh start

1.2 管理控制台软件

作用：使用图形界面维护dubbo

• 进入dubbo-admin模块中，把application.properties中最后一行修改成zookeeper的地址
• mvn clean package
• java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

2、监控中心

用来显示接口暴露、注册信息，可观察接口的调用明细，调用时间

localhost:7001

三、springBoot整合

1、provider要实现的配置

• application.properties

#设置应用名
dubbo.application.name=bootprovider
#设置注册中心的位置及协议
dubbo.registry.address=zookeeper://192.168.184.130:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

• 在服务的实现类中添加注解@Service,是com.alibaba.dubbo包下注解
• 在主类中添加注解@EnableDubbo,用于开启基于注解的dubbo功能，从而把@service标识的注解类暴露出来

2、consumer配置

• application.properties

dubbo.application.name=bootconsumer
dubbo.registry.address=zookeeper://192.168.184.130:2181

• 把UserService service的注解从@Autowired改为@Reference

3、springboot-pom文件

pom文件

    org.springframework.boot
    spring-boot-starter-web


    hy
    api
    1.0-SNAPSHOT


    com.alibaba.boot
    dubbo-spring-boot-starter
    0.2.0

4、提供者provider配置

application.properties

dubbo.application.name=provider_boot
dubbo.registry.address=zookeeper://192.168.184.100:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881

启动类（EnableDubbo注解）

@EnableDubbo//dubbo注解
@SpringBootApplication
public class ProviderBootApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderBootApplication.class, args);
    }
}

service实现类（dubbo的Service注解）

@Service(weight = 100)//注意：这是dubbo的service注解，设置了权重
public class UserServiceImpl implements UserService {
    @Override
    public UserAddress getUserAddress(String userId) {
        UserAddress a1 = new UserAddress(1, "南京", "a1");
        UserAddress a2 = new UserAddress(2, "上海", "a2");
        List list = Arrays.asList(a1, a2);
        System.out.println("this is boot provider,version=1.0");
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        for (int i = 0; i < list.size(); i++) {
            if (list.get(i).getUserId().equals(userId)) {
                return list.get(i);
            }
        }
        return null;
    }
}

5、消费者consumer配置

application.properties

server.port=80
dubbo.application.name=consumer_boot
dubbo.registry.address=zookeeper://192.168.184.100:2181
dubbo.consumer.timeout=6000
dubbo.consumer.retries=3

service实现类（Reference注解）

public interface OrderService {
    UserAddress initOrder(String userId);
}
@Service
public class OrderServiceImpl implements OrderService{
    //@Reference//从zk中读取UserService服务的信息
    //@Reference(timeout=3000,retries=3)
    //@Reference(version = "1.0")
    //@Reference(version = "*")
    //@Reference(stub = "hy.service.impl.UserServiceStub")//下面的service时UserServiceStub类型
    //@Reference(url = "192.168.0.176:20880")//直连的服务的IP地址
    @Reference(loadbalance = "random")
    UserService service;
    @Override
    public UserAddress initOrder(String userId) {
        UserAddress addr = service.getUserAddress(userId);
        System.out.println(addr);
        return addr;
    }
}

controller类

@Controller
public class OrderCtrl {
    @Autowired
    OrderService service;
    @ResponseBody
    @RequestMapping("/initOrder")
    public UserAddress iniOrder(String userId){
        return service.initOrder(userId);
    }
}

6、测试

运行dubbo-provider之前的dubbo-admin界面（无服务）

运行dubbo-provider之后（服务出现）

测试成功！