在大规模服务化之前，应用可能只是通过 RMI 或 Hessian 等工具，简单的暴露和引用远程服务，通过配置服务的URL地址进行调用，通过 F5 等硬件进行负载均衡。
当服务越来越多时，服务 URL 配置管理变得非常困难，F5 硬件负载均衡器的单点压力也越来越大。 此时需要一个服务注册中心，动态地注册和发现服务，使服务的位置透明。并通过在消费方获取服务提供方地址列表，实现软负载均衡和 Failover，降低对 F5 硬件负载均衡器的依赖，也能减少部分成本。
当进一步发展，服务间依赖关系变得错踪复杂，甚至分不清哪个应用要在哪个应用之前启动，架构师都不能完整的描述应用的架构关系。 这时，需要自动画出应用间的依赖关系图，以帮助架构师理清关系。
接着，服务的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？ 为了解决这些问题，第一步，要将服务现在每天的调用量，响应时间，都统计出来，作为容量规划的参考指标。其次，要可以动态调整权重，在线上，将某台机器的权重一直加大，并在加大的过程中记录响应时间的变化，直到响应时间到达阈值，记录此时的访问量，再以此访问量乘以机器数反推总容量。
以上是 Dubbo 最基本的几个需求。
dubbo的架构：
节点角色说明
| 节点 | 角色说明 |
|---|---|
Provider |
暴露服务的服务提供方 |
Consumer |
调用远程服务的服务消费方 |
Registry |
服务注册与发现的注册中心 |
Monitor |
统计服务的调用次数和调用时间的监控中心 |
Container |
服务运行容器 |
调用关系说明
- 服务容器负责启动，加载，运行服务提供者。
- 服务提供者在启动时，向注册中心注册自己提供的服务。
- 服务消费者在启动时，向注册中心订阅自己所需的服务。
- 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
- 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
- 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。
连通性
- 注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小
- 监控中心负责统计各服务调用次数，调用时间等，统计先在内存汇总后每分钟一次发送到监控中心服务器，并以报表展示
- 服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销
- 服务消费者向注册中心获取服务提供者地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销
- 注册中心，服务提供者，服务消费者三者之间均为长连接，监控中心除外
- 注册中心通过长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者
- 注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在本地缓存了提供者列表
- 注册中心和监控中心都是可选的，服务消费者可以直连服务提供者
健壮性
- 监控中心宕掉不影响使用，只是丢失部分采样数据
- 数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务
- 注册中心对等集群，任意一台宕掉后，将自动切换到另一台
- 注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯
- 服务提供者无状态，任意一台宕掉后，不影响使用
- 服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复
伸缩性
- 注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心
- 服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者
升级性
当服务集群规模进一步扩大，带动IT治理结构进一步升级，需要实现动态部署，进行流动计算，现有分布式服务架构不会带来阻力。下图是未来可能的一种架构：
节点角色说明
| 节点 | 角色说明 |
|---|---|
Deployer |
自动部署服务的本地代理 |
Repository |
仓库用于存储服务应用发布包 |
Scheduler |
调度中心基于访问压力自动增减服务提供者 |
Admin |
统一管理控制台 |
Registry |
服务注册与发现的注册中心 |
Monitor |
统计服务的调用次数和调用时间的监控中心 |
以上内容都来自官网的说明，我只是摘抄过来，方便自己了解。
下面我们来做一个demo操作：在整合demo过程中遇到有比较多的坑，现做个记录，主要步骤以下：
1、安装zookeeper
这个过程，我主要放在：https://www.cnblogs.com/lxhaaron/articles/14117523.html这个地址做了说明，这里就不做过多描述
2、创建provider服务
主要步骤以下：
一、创建一个空项目，命名为：springboot-dubbo-zookeeper-pro
二、在这个项目中创建一个Model，项目我们从阿里云：https://start.aliyun.com创建，这样比从spring官网创建速度快很多：
三、输入项目名称和包名
四、选择Springboot的web项目
五、完成项目创建
六、加入引用：
<!-- 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> <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>5.1.0</version> <exclusions> <exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> </exclusions> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>5.1.0</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.6.2</version> </dependency>
七、创建一个接口服务：ITicketService，并定义一个方法sellTicket
package com.fengfang.services; /** * TODO * * @author liuxh * @date 2020/12/11 16:30 **/ public interface ITicketService { public String sellTicket(); }
八、定义这个接口服务的实现类：旧版本是使用：org.apache.dubbo.config.annotation.Service的@Service注解，这很容易与spring的注解混淆，
因为我现在用的dubbo是最新版本：2.7.8，写代码时提示这个服务过期了，就更新为@DubboService注解，没有用以前的这个服务注解
package com.fengfang.services.impl; import com.fengfang.services.ITicketService; import org.apache.dubbo.config.annotation.DubboService; import org.springframework.stereotype.Component; /** * TODO * * @author liuxh * @date 2020/12/11 16:30 **/
@DubboService
//@Service
@Component public class TicketService implements ITicketService { @Override public String sellTicket() { System.out.println("正在执行提供者服务!"); return "我是提供者的服务--卖票服务！"; } }
九、配置dubbo的配置文件：application.yml
server:
port: 8081
#定义dubbo属性
dubbo:
application:
name: TicketServiceProvider
registry:
address: zookeeper://192.168.31.47:2181
timeout: 100000
protocol:
port: 20880
name: dubbo
scan:
base-packages: com.fengfang.services
这样服务器就完成了，可以启动服务看下，也可以到zookeeper里面去看下，这里就介绍一个用于连接zookeeper的客户端下载地址，https://www.cnblogs.com/xubao/p/10693932.html，自己下载下来可以用来测试zookeeper远程是否正常。
遇到的坑有以下几个：
-
dubbo启动报错：org.apache.dubbo.config.ProtocolConfig#0“ contains illegal character, only digit，原因是没有设置：
dubbo.protocol.name=dubbo,设置了这个属性后就正常了，这个错误是自己跟踪源码发现的。 - 出现以下这样的错误：原因是没有设置：
dubbo.registry.timeout=50000,最后增加了这个设置就没有问题了，这个问题是根据网上说的，还有的说要设置：dubbo.config-center.timeout,这个设置我是没有增加的。
- 出现这样的错误：SpringBoot启动dubbo出现com.alibaba.dubbo.common.bytecode.Wrapper12: inconsistent stack height -1异常，原因是：
出现以下错误：原因是: 定义服务接口方法的时候 不能已get开头， 例如：getXXX()
换成别的方法名 例如selectXXX() 之后 错误消失。参考问题地址：https://blog.csdn.net/fly_miqiqi/article/details/107080377，这个问题自己在后面重新测试验证时，好像又没有这个问题了，即使用带get的也正常了。
3、创建consumer服务，用于测试服务
一、再创建一个模块：springboot-dubbo-zookeeper-consumer
这个图片的包名没有更改，我是创建后重命名和服务提供者一样的
二、加入引用，和上面服务提供者一样：
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>5.1.0</version> <exclusions> <exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> </exclusions> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>5.1.0</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.6.2</version> </dependency>
三、增加配置档，application.yml
server:
port: 8082
dubbo:
registry:
address: zookeeper://192.168.31.47:2181
protocol: zookeeper
timeout: 50000
protocol:
name: dubbo
port: 20881
application:
name: TicketServiceConsumer
四、创建一个与服务提供者一样的服务接口：
package com.fengfang.services; /** * TODO * * @author liuxh * @date 2020/12/11 19:16 **/ public interface ITicketService { public String sellTicket(); }
五、创建一个消费者程序 ：UserTicketService，这里旧版本dubbo是使用:org.apache.dubbo.config.annotation.Reference的@Reference注解的，新版本已更改为：@DubboReference
注解的，但新版本更改为：
package com.fengfang.services; import org.apache.dubbo.config.annotation.DubboReference; import org.springframework.stereotype.Service; /** * TODO * * @author liuxh * @date 2020/12/11 19:16 **/ @Service public class UserTicketService { @DubboReference ITicketService ticketService; public void userBuyTicket(){ System.out.println("开始执行消费者程序"); String ticket = ticketService.sellTicket(); System.out.println(ticket); System.out.println("完成执行消费者程序"); } }
六、定义一个单元测试方法，用于测试以上服务方法：以下红色字体内容
package com.fengfang; import com.fengfang.services.UserTicketService; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; @SpringBootTest class SpringbootDubboZookeeperConsumerApplicationTests { @Autowired UserTicketService userTicketService; @Test void contextLoads() { } @Test public void testUserBuyTicket(){ userTicketService.userBuyTicket(); } }
以上操作完成后，一个dubbo服务提供者和一个dubbo消费者就完成了，另外zookeeper没有在这里进行过多的说明，可以自己再网上查询下资料
另外项目现在虽然能完成功能，但还是有一个日志冲突的问题未解决，我在网上找了好多帖子也没有处理好，这个是个遗留问题待后续跟进处理。
会报以下这样的错误：
