一、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文件

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency><groupId>hy</groupId><artifactId>api</artifactId><version>1.0-SNAPSHOT</version>
</dependency>
<dependency><groupId>com.alibaba.boot</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>0.2.0</version>
</dependency>

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 {@Overridepublic UserAddress getUserAddress(String userId) {UserAddress a1 = new UserAddress(1, "南京", "a1");UserAddress a2 = new UserAddress(2, "上海", "a2");List<UserAddress> 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;@Overridepublic UserAddress initOrder(String userId) {UserAddress addr = service.getUserAddress(userId);System.out.println(addr);return addr;}
}

controller类

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

6、测试

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

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

测试成功！