本文参考：【优极限】最透彻的Dubbo教程（dubbo经典之作完整版），阿里分布式框架dubbo零基础实战教学_手把手地啊你读懂底层源码【完整版】_哔哩哔哩_bilibili

1、互联网架构演变

（1）单一应用架构

把系统中所有的功能、模块耦合在一个应用中的架构方式。程序在一个服务器上。

优点：项目易于管理、部署简单

缺点：测试成本高、可伸缩性差、可靠性差、迭代困难、跨语言程度差、团队协作

（2）RPC架构

远程过程调用。通过网络从远程计算机程序上请求服务，比如Thrift，程序可能分布在两个以上服务器上。

优点：应用直接调用服务，服务之间是隔离的

缺点：服务过多时，管理成本高昂。服务治理，服务注册、发现，服务容错，服务跟踪，服务网关，IP暴露等都是此架构无法避免的问题。

（3）SOA架构

面向服务架构。就是在RPC基础上增加了ESB服务中介，主要提供了一个服务与服务之间的交互。

如上图所示，应用如果调用用户、购物车等服务，则直接跟ESB打交道，ESB再跟用户、购物车、订单等服务打交道。

ESB包含的功能：负载均衡，流量控制，加密处理，服务的监控，监控告急等。

（4）微服务架构

一个大型的复杂软件应用，由一个或多个微服务组成。系统中各个微服务可被独立部署，各个微服务之间是松耦合的。每个微服务仅关注于完成一件任务并很好的完成该任务。对比SOA架构，使用注册中心代替ESB服务总线。注册中心相比服务总线来说，更加轻量级。

如上图所示，用户、购物车、订单等服务均注册到注册中心，假如应用访问订单服务，则从注册中心发现服务，然后再调用订单服务。如果订单需要购物车的服务，则从注册中心发现服务，然后再调用购物车服务。

2、Dubbo服务

dubbo和spring cloud都是微服务的具体实现，dubbo是RPC的框架。

角色：Provider、Consumer、Registry、Monitor

启动时，Provider会把提供的所有服务都放到Registry（注册到注册中心）

消费时，Consumer从Registry中找服务，因为Provider不止一个，Consumer不可能一个个的去找。找到后，订阅想要的服务。消费时，调用Provider的远程服务。所以，找服务从注册中心找，消费时找对应的Provider。

监控中心，监控Dubbo运行过程中的参数。

打个比方，注册中心相当于手机中的通讯录，存的是名字。然后拨打号码时，就是拨打11位的号码，这个就是provider的具体服务。

3、Multicast注册中心

它是dubbo自带的注册中心，只使用demo测试，实际开发需要使用Zookeeper注册中心。

步骤如下：

（1）提供方启动时广播自己的地址

（2）消费方启动时广播订阅请求

（3）提供方收到订阅请求时，单播自己的地址给订阅者，如果设置了unicast=false，则广播给订阅者（提供方和消费方在同一台服务器需要该设置）

（4）消费方收到提供方地址时，连接该地址进行RPC调用。

4、Zookeeper注册中心

（1）zookeeper说明

Zookeeper是一个分布式的应用程序协调服务，它是一个为分布式应用提供一致性服务的软件，包括：配置维护、域名服务、分布式同步、组服务等。它的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。

本次我们将Zookeeper作为Dubbo服务的注册中心。

（2）windows版本下载使用

下载地址：官网下Apache Downloads

修改conf/zoo_sample.cfg为zoo.cfg

其中：

dataDir=D:\\programs\\apache-zookeeper-3.8.2\\data

logDir=D:\\programs\\apache-zookeeper-3.8.2\\logs

启动命令：

直接zkServer.cmd，不需要带start参数

Zookeeper使用，参考：

zookeeper：简介及常用命令_zookeeper常用命令_LazyKing-qi的博客-CSDN博客

5、Dubbo使用示例

（1）maven工程说明

dubbo-demo是最外层的主工程。

dubbo-api是接口定义层，定义了服务提供者的服务接口

dubbo-provider是服务提供层，负责将服务注册到注册中心（zk），然后对外提供RPC服务。

dubbo-consumer是服务消费层，负责从注册中心拿到服务列表，然后调用相应的RPC服务。

（2）dubbo-demo工程

最外层工程。

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><packaging>pom</packaging><modules><module>dubbo-api</module><module>dubbo-provider</module><module>dubbo-consumer</module></modules><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.4.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>dubbo-demo</artifactId><version>0.0.1-SNAPSHOT</version><name>dubbo-demo</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><dubbo.version>2.7.3</dubbo.version></properties><dependencyManagement><dependencies><!-- dubbo依赖 --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>${dubbo.version}</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><!-- zookeeper注册中心引入curator客户端  --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>${dubbo.version}</version><type>pom</type></dependency></dependencies></dependencyManagement></project>

（3）dubbo-api工程

接口定义层。

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>dubbo-demo</artifactId><groupId>com.example</groupId><version>0.0.1-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>0.0.1-SNAPSHOT</version><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><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.12</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><type>pom</type></dependency></dependencies></project>

User.java

package com.example.api;import java.io.Serializable;
import lombok.Data;
import lombok.ToString;@Data
@ToString
public class User implements Serializable {private Integer id;private String name;
}

UserServiceI.java

package com.example.api;public interface UserServiceI {User selectUserById(Integer id);
}

（4）dubbo-provider工程

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>dubbo-demo</artifactId><groupId>com.example</groupId><version>0.0.1-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>com.example</groupId><artifactId>dubbo-provider</artifactId><version>0.0.1-SNAPSHOT</version><dependencies><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies></project>

application.yml

# 防止端口冲突
server:port: 8081dubbo:application:# 应用名称name: providerregistry:# 注册中心地址address: zookeeper://172.25.36.203:2181# 超时时间，单位毫秒timeout: 6000# 元中心地址metadata-report:address: zookeeper://172.25.36.203:2181protocol:# 协议名称name: dubbo# 协议端口port: 20880scan:# 扫描包的位置base-packages: com.example.provider.service

将172.25.36.203替换成本机地址。
UserServiceImpl.java

package com.example.provider.service;import com.example.api.User;
import com.example.api.UserServiceI;
import org.apache.dubbo.config.annotation.Service;@Service
public class UserServiceImpl implements UserServiceI {@Overridepublic User selectUserById(Integer id) {User user = new User();user.setId(id);user.setName("张三");return user;}
}

使用dubbo的Service注解。

ProviderApplication.java

package com.example.provider;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class ProviderApplication {public static void main(String[] args) {SpringApplication.run(ProviderApplication.class, args);}
}

（5）dubbo-consumer工程

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>dubbo-demo</artifactId><groupId>com.example</groupId><version>0.0.1-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>com.example</groupId><artifactId>dubbo-consumer</artifactId><version>0.0.1-SNAPSHOT</version><dependencies><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies></project>

application.yml

# 防止端口冲突
server:port: 8082dubbo:application:# 应用名称name: consumerregistry:# 注册中心地址address: zookeeper://172.25.36.203:2181

将172.25.36.203替换成本机地址。

UserInit.java

借用@PostConstruct注解，使得consumer工程启动时调用RPC服务。

package com.example.consumer;import com.example.api.UserServiceI;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;@Component
public class UserInit  {// 会拉去注册中心的服务缓存在本地，即使注册中心宕机，之前的服务也能用，但是新的服务无法发现@Reference(parameters = {"unicast", "false"})  // 同一台机器使用广播private UserServiceI userService;@PostConstructpublic void init(){System.out.println(userService.selectUserById(2));}
}

ConsumerApplication.java

package com.example.consumer;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;@SpringBootApplication
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class, args);}
}