欢迎您关注和点赞支持！有问题可以下面评论！您的支持就是对我编写教学最大的鼓励！💗
阿里巴巴旗下的后来被收入ApacheBubbo官网
Apache Dubbo™ 是一款高性能Java RPC框架
什么是RPC？
随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。
image
单一应用架构
当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架(ORM)是关键。
垂直应用架构
当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，提升效率的方法之一是将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的Web框架(MVC)是关键。
分布式服务架构
当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。
流动计算架构
当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心(SOA)是关键。
声明
只有当单个节点的处理能力无法满足日益增长的计算、存储任务的时候，且硬件的提升（加内存、加磁盘、使用更好的CPU）高昂到得不偿失的时候，应用程序也不能进一步优化的时候，我们才需要考虑分布式系统。因为，分布式系统要解决的问题本身就是和单机系统一样的，而由于分布式系统多节点、通过网络通信的拓扑结构，会引入很多单机系统没有的问题，为了解决这些问题又会引入更多的机制、协议，带来更多的问题。
RPC基本原理
原理
RPC两个核心模块：通讯，序列化。
开始上手
Dubbo 版本发布及新特性速览 选择推荐生产使用的版本
img
除了生产者和消费者之间的引用关系是同步的。包括生产者，消费者注册到注册中心、监控中心的监管都是异步请求
同步是指：发送方发出数据后，等接收方发回响应以后才发下一个数据包的通讯方式。
异步是指：发送方发出数据后，不等接收方发回响应，接着发送下个数据包的通讯方式。 还可以干别的
调用关系说明
l 服务容器负责启动，加载，运行服务提供者。
l 服务提供者在启动时，向注册中心注册自己提供的服务。
l 服务消费者在启动时，向注册中心订阅自己所需的服务。
l 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
l 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
l 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
注册中心 Zookeeper
默认端口 clientPort=2181
为什么选择他？因为 Zookeeper 是 Apacahe Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo 服务的注册中心，工业强度较高，可用于生产环境，并推荐使用。
- 当提供者出现断电等异常停机时，注册中心能自动删除提供者信息
- 当注册中心重启时，能自动恢复注册数据，以及订阅请求
- 当会话过期时，能自动恢复注册数据，以及订阅请求...
使用
在 provider 和 consumer 中增加 zookeeper 客户端 jar 包依赖：
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.3.3</version>
</dependency>
或者window安装
下载并解压运行/bin/zkServer.cmd ，初次运行会报错，没有zoo.cfg配置文件。
如果发现闪退则在conf 下将 zoo_sample.cfg 复制一份 改为 zoo.cfg。（文件内可以设置端口 及 dataDir=./ 临时数据存储的目录（可写相对路径））
解决方案：编辑zkServer.cmd文件末尾endlocal 前添加pause 。这样运行出错就不会退出，会提示错误信息，方便找到原因。
使用zkCli.cmd验证信息
ls / 可以列出其下所有节点 就证明调试成功了
操作演示
dubbo-admin
官方提供了一个可视化的监控程序dubbo-admin，不过这个监控即使不装也不影响使用。这是个springboot 项目！
解压以后 在dubbo-admin-server\src\main\resources\application.properties中可以查看到一些信息
当然你也可以不用下载直接使用我提供的jar包 验证码：8gpf 可以直接看如何启动jar包
# 启动端口号 默认8080
server.port=7001
# 注册中心地址
admin.registry.address=zookeeper://127.0.0.1:2181
# 配置中心地址
admin.config-center=zookeeper://127.0.0.1:2181
# 元空间数据地址
admin.metadata-report.address=zookeeper://127.0.0.1:2181
# 登录账号密码
admin.root.user.name=root
admin.root.user.password=root
然后我们将其打成jar包
mvn clean package -Dmaven.test.skip=true
这样可以免除检查 如果发现你不能使用mvn命令应该配置下系统环境变量 在path中添加你maven下bin路径
出现build seccuss 以后 我们就可以启动jar包。jar包位置如下：如果不在那么打包的cmd窗口会提示在哪里
dubbo-admin-develop\dubbo-admin-distribution\target
zookeeper一定要打开！
java -jar dubbo-admin-0.1.jar
然后我们访问localhost:7001
点击服务查询就会弹出窗口。使用默认账号密码root root就可以登录。这时候就成功了！
登录窗口
代码入门
首先是Dubbo的pom
<!-- Dubbo Spring Boot Starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.3</version>
</dependency>
因为有两种客户端实现为 zkclient 和 curator 默认为curator 如果需要采用另一种请查看注册中心。
<!-- 引入zookeeper 及 客户端实现curator-->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.6.0</version>
<!--排除这个slf4j-log4j12 日志冲突-->
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
提供者 application.properties
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#元数据中心
dubbo.metadata-report.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=it.test.provider_server.serivce
# Dubbo 客户端实现 默认为 curator
dubbo.registry.client=curator
# dubbo 注册接口
dubbo.protocol.port=20880
server.port=8081
我们写了一个service 方法
尤其要注意service 是来源于dubbo他是提供者 所以使用 @service
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
@Service // 注意service 路径
@Component
public class TicketServiceImpl implements TicketService {
@Override
public String sall() {
return "成功销售一张票";
}
}
然后我们就可以启动项目了!
查询结果
然后我们创建 消费者
消费者的pom文件和 提供者相同
application.proprties
#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
server.port=8082
但是我们需要引入提供者坐标
<!-- 引入提供者坐标-->
<dependency>
<groupId>it.test</groupId>
<artifactId> provider_server</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
代码中的service 是注入到Spring容器中
import it.test.provider_server.serivce.TicketService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;
@Service
public class UserService {
@Reference
private TicketService service;
public void sallTicket(){
System.out.println("我"+service.sall());
}
}
然后我们再test里面就可以尝试 调用方法了 ！打印成功！
搭建提供者集群
很简单
我们只需要在创建一个一模一样的消费者出来
当前应用的名字和第一个提供者相同，并且dubbo.protocol.port=20881不同就可以了！
即便你关闭第一个提供者，你的程序依然可以执行。
如果需要搭建zookeeper集群。则查看官方dubbo 注册中心的文档就行！
致谢
部分内容来源于狂神说SpringBoot 一个很棒的教学up主 和官网的官方文档！
网友评论