一、分布式简要说明
Dubbo是用于分布式系统的框架所以我们要先了解什么是分布式
分布式系统是若干独立 计算机的集合，这些计算机对于用户来说就像单个相关系统。
老式系统(单一应用架构)就是把一个系统，统一放到一个服务器当中然后每一个服务器上放一个系统，如果说要更新代码的话，每一个服务器上的系统都要重新去部署十分的麻烦。
而分布式系统就是将一个完整的系统拆分成多个不同的服务，然后在将每一个服务单独的放到一个服务器当中。(三个臭皮匠赛过诸葛亮)
1.1、应用架构及发展演变
1.2、Dubbo和SpringCloud对比
1.3、发展演变
1.3.1、ORM
单一应用架构：一个项目装到一个服务器当中，也可以运行多个服务器每一个服务器当中都装一个项目。
缺点：1.如果要添加某一个功能的话就要把一个项目重新打包，在分别部署到每一个服务器当中去。2.如果后期项目越来越大的话单台服务器跑一个项目压力会很大的。会不利于维护，开发和程序的性能。
1.3.2、mvc
垂直应用架构：将应用切割成几个互不相干的小应用，在将每个小应用独立放到一个服务器上，如果哪一个应用的访问数量多就多加几台服务器。
1.3.3、分布式服务架构
1.3.4、RPC简介
分布式应用架构(远程过程调用)：当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。
- 什么是RPC
- RPC [ Remote Procedure Call]是指远程过程调用，是一种进程问通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。
- RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。
- RPC工作原理
- 过程
- a.Client像调用本地服务似的调用远程服务；
- b.Client stub接收到调用后，将方法、参数序列化
- c.客户端通过sockets将消息发送到服务端
- d.Server stub 收到消息后进行解码（将消息对象反序列化）
- e.Server stub 根据解码结果调用本地的服务
- f.本地服务执行(对于服务端来说是本地执行)并将结果返回给Server stub
- g.Server stub将返回结果打包成消息（将结果消息对象序列化）
- h.服务端通过sockets将消息发送到客户端
- i.Client stub接收到结果消息，并进行解码（将结果消息发序列化）
- j.客户端得到最终结果
- RPC 调用分以下两种：
- 同步调用：客户方等待调用执行完成并返回结果。
- 异步调用：客户方调用后不用等待执行结果返回，但依然可以通过回调通知等方式获取返回结果。若客户方不关心调用返回结果，则变成单向异步调用，单向调用不用返回结果。
- RPC步骤解析
- SOA
- 流动计算架构：在分布式应用架构的基础上增加了一个调度、治理中心基于访问压力实时管理集群容量、提高集群的利用率，用于提高机器利用率的 资源调度和治理中心(SOA) 是关键 (不浪费计算机资源)
二、Dubbo基础
2.1、Dubbo核心概念
- Dubbo官网: http://dubbo.apache.org/en-us/index.html
- Dubbo 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，服务自动注册和发现。分布式系统是将一个系统拆分为多个不同的服务
2.2、Dubbo特性一览
2.3、dubbo设计架构
- 服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。
- 服务消费者（Consumer）: 调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
- 注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
- 监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
2.4、Dubbo的特性
2.4.1、服务注册中心
- 相比Hessian类RPC框架，Dubbo有自己的服务中心， 写好的服务可以注册到服务中心， 客户端从服务中心寻找服务，然后再到相应的服务提供者机器获取服务。通过服务中心可以实现集群、负载均衡、高可用(容错) 等重要功能。
- 服务中心一般使用zookeeper实现，也有redis和其他一些方式。以使用zookeeper作为服务中心为例，服务提供者启动后会在zookeeper的/dubbo节点下创建提供的服务节点，包含服务提供者ip、port等信息。服务提供者关闭时会从zookeeper中移除对应的服务。
- 服务使用者会从注册中心zookeeper中寻找服务，同一个服务可能会有多个提供者，Dubbo会帮我们找到合适的服务提供者，也就是针对服务提供者的负载均衡。
2.4.2、负载均衡
- 当同一个服务有多个提供者在提供服务时，客户端如何正确的选择提供者实 现负载均衡呢？dubbo也给我们提供了几种方案：
- random 随机选提供者，并可以给提供者设置权重
- roundrobin 轮询选择提供者
- leastactive 最少活跃调用数，相同活跃数的随机，活跃数：指调用前后计数差。使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。
- consistenthash 一致性hash，相同参数的请求发到同一台机器上。
2.4.3、简化测试，允许直连提供者
- 在开发阶段为了方便测试，通常系统客户端能指定调用某个服务提供者，那么可以在引用服务时加一个url参数去指定服务提供者。 配置如下：
<dubbo:reference id="xxxService"interface="com.alibaba.xxx.XxxService"url="dubbo://localhost:20890"/>
2.4.4、服务版本，服务分组
- 在Dubbo配置文件中可以通过制定版本实现连接制定提供者，也就是通过服务版本可以控制服务的不兼容升级；当同一个服务有多种实现时，可以使用服务分组进行区分。
三、Dubbo环境搭建
3.1、搭建zookeeper注册中心环境
Dubbo官方文档: http://dubbo.apache.org/en-us/docs/user/quick-start.html
在zookeeper官网下载zookeeperhttp://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/
- zookeeper 可访问如下文档：
点击链接查看：https://www.yuque.com/yang.guo.top1/java-start/yu9k75
此时，我们zookeeper的注册中心及环境以及搭建完毕。
3.2、搭建zookeeper监控中心的配置、启动dubbo-admin监控页面
- 下载dubbo-admin
- dubbo-admin下载地址 ：https://github.com/apache/dubbo-admin/tree/master
- 解压后进入目录修改指定zookeeper地址
- 进入如下地址：dubbo-admin-master\dubbo-admin\src\main\resources\application.properties"
将zookeeper的监控中心的地址配置为本地端口
#注册中心的地址 dubbo.registry.address=zookeeper://127.0.0.1:2181
- 配置完毕后，我们在dubo-zookeeper\dubbo-admin-master\dubbo-admin文件夹下cmd打包测试下。
- mvn clean package
- java -jar dubbo-admin-0.0.1-SNAPSHOT.jar运行打包好的jar包
- 启动成功后，可以看到一个8080的端口
- 此时我们的zookeeper的服务都为启动状态，在浏览器中访问 localhost:8080，访问到注册中心，输入账号密码root。
- 此时，我们zookeeper监控中心的配置完成。注意，要访问到监控中心，一定要启动zookeeper注册中心的启动类
四、Dubbo-hello world
4.1、Dubbo环境搭建，创建提供者、消费者项目
4.1.1、服务提供者搭建（user-service-provider）
- pojo.UserAddress
/** * @Description: * @Author: Guo.Yang * @Date: 2022/09/22/15:45 */ @Data @AllArgsConstructor @NoArgsConstructor public class UserAddress { private Integer id; private String userAddress; //用户地址 private String userId; //用户id private String consignee; //收货人 private String phoneNum; //电话号码 private String isDefault; //是否为默认地址 Y-是 N-否 }
- service.UserService
/** * @Description: * @Author: Guo.Yang * @Date: 2022/09/22/15:47 */ @Service public interface UserService { /** * 按照用户id返回所有的收货地址 * @param userId * @return */ public List<UserAddress> getUserAddressList(String userId); }
- service.impl.UserServiceImpl
/** * @Description: * @Author: Guo.Yang * @Date: 2022/09/22/15:48 */ @Service("UserServiceImpl") public class UserServiceImpl implements UserService { @Override public List<UserAddress> getUserAddressList(String userId) { UserAddress address1 = new UserAddress(1, "河南省郑州巩义市宋陵大厦2F", "1", "安然", "150360313x", "Y"); UserAddress address2 = new UserAddress(2, "北京市昌平区沙河镇沙阳路", "1", "情话", "1766666395x", "N"); return Arrays.asList(address1,address2); } }
4.1.2、服务消费者搭建（order-service-consumer）订单服务
- service.OrderService
/** * @Description: * @Author: Guo.Yang * @Date: 2022/09/22/15:56 */ @Service public interface OrderService { /** * 初始化订单 * @param userID */ public void initOrder(String userID); }
- service.impl.OrderServiceImpl
/** * @Description: * @Author: Guo.Yang * @Date: 2022/09/22/15:56 */ @Service("OrderServiceImpl") public class OrderServiceImpl implements OrderService { //查询用户的收货地址 UserService userService; @Override public void initOrder(String userID) { //查询用户的收货地址 List<UserAddress> userAddressList = userService.getUserAddressList(userID); System.out.println(userAddressList); } }
- 注意
- 因服务消费者要拿到提供者的方法
- 将 服务提供者 中的 实体类 及 UserService 复制到当前消费者同级文件中。
- 此时我们调用userservice肯定是要报错的。这种面向接口的方式，我们这里只是调到了接口，而接口实际是在另外一个项目中，如果我们两个项目工程都创建共同的实体类，太过于麻烦了，我们可以将服务接口，服务模型等单独放在一个项目中，更为方便调用。（将公共业务部分提到一个业务模块下，需要的模块服务，引入公共业务依赖jar包即可）
4.1.3、搭建共同的服务接口（gmail-interface）
- pojo.UserAddress
@Data @AllArgsConstructor @NoArgsConstructor public class UserAddress { private Integer id; private String userAddress; //用户地址 private String userId; //用户id private String consignee; //收货人 private String phoneNum; //电话号码 private String isDefault; //是否为默认地址 Y-是 N-否 }
- service.OrderService
public interface OrderService { /** * 初始化订单 * @param userID */ public void initOrder(String userID); }
- servce.UserService
public interface UserService { /** * 按照用户id返回所有的收货地址 * @param userId * @return */ public List<UserAddress> getUserAddressList(String userId); }
- 将 提供者 和 消费者 项目中的所有实体类复制到当前相关的文件包下，删除原有的实体类包及service包，也就是将实体类及service放在了当前公共的项目中。
- 把服务提供者和消费者项目中引入以下依赖，引入后项目不在报错.
<!-- 使用自定义的共通服务模块--> <dependency> <groupId>com.yang</groupId> <artifactId>gmail-interface1</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency>
4.2、服务提供者配置&测试
4.2.1、将服务提供者注册到注册中心中
- 在user-service-provider 导入dubbo依赖、操作zk的客户端
<!--dubbo--> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.2</version> </dependency> <!--注册中心是 zookeeper，引入zookeeper客户端--> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency>
- 在resource文件中创建provider.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!--1、指定当前服务/应用的名字(同样的服务名字相同，不要和别的服务同名)--> <dubbo:application name="user-service-provider"></dubbo:application> <!--2、指定注册中心的位置--> <!--<dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>--> <dubbo:registry protocol="zookeeper" address="39.105.228.254:2181"></dubbo:registry> <!--3、指定通信规则（通信协议? 服务端口）--> <dubbo:protocol name="dubbo" port="10011"></dubbo:protocol> <!--4、暴露服务 让别人调用 ref指向服务的真正实现对象--> <dubbo:service interface="com.yang.gmail_interface.service.UserService" ref="userServiceImpl"></dubbo:service> <!--服务的实现--> <bean id="userServiceImpl" class="com.yang.user_service_provider.service.impl.UserServiceImpl"></bean> </beans>
- 编写一个ProviderApplication启动类程序，运行测试配置
public class MailApplication { public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext applicationContext= new ClassPathXmlApplicationContext("provider.xml"); applicationContext.start(); System.in.read(); } }
- 启动主启动类
- 启动dubbo-admin服务
- 访问http://localhost:8080/
- 在里边会看到我们刚刚注册进去的服务提供者
- 服务提供者配置测试成功
