dubbo学习笔记

dubbo学习笔记
分布的简单介绍

Dubbo是用于分布式系统的框架所以我们要先了解什么是分布式

分布式系统是若干独立计算机的集合，这些计算机对于用户来说就像单个相关系统。

老式系统(单一应用架构)就是把一个系统，统一放到一个服务器当中然后每一个服务器上放一个系统，如果说要更新代码的话，每一个服务器上的系统都要重新去部署十分的麻烦。

而分布式系统就是将一个完整的系统拆分成多个不同的服务，然后在将每一个服务单独的放到一个服务器当中。

应用架构的发展演变

下面图片来自dubbo的官网Apache Dubbo

发展演变

**ORM **单一应用架构：一个项目装到一个服务器当中，也可以运行多个服务器每一个服务器当中都装一个项目。

缺点：
1. 如果要添加某一个功能的话就要把一个项目重新打包，在分别部署到每一个服务器当中去。
2. 如果后期项目越来越大的话单台服务器跑一个项目压力会很大的。会不利于维护，开发和程序的性能。
**MVC **垂直应用架构：将应用切割成几个互不相干的小应用，在将每个小应用独立放到一个服务器上，如果哪一个应用的访问数量多就多加几台服务器。

分布式服务架构

RPC简介

分布式应用架构(远程过程调用)：当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。

什么叫RPC
1. RPC [ Remote Procedure Call]是指远程过程调用，是一种进程问通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。
2. RPC（Remote Procedure Call）— 远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。
RPC的工作原理

下面是对于上图的详细解释,也就是上面原理图的详细执行过程
1. Client像调用本地服务似的调用远程服务；
2. Client stub接收到调用后，将方法、参数序列化
3. 客户端通过sockets将消息发送到服务端
4. Server stub 收到消息后进行解码（将消息对象反序列化）
5. Server stub 根据解码结果调用本地的服务
6. 本地服务执行(对于服务端来说是本地执行)并将结果返回给Server stub
7. Server stub将返回结果打包成消息（将结果消息对象序列化）
8. 服务端通过sockets将消息发送到客户端
9. Client stub接收到结果消息，并进行解码（将结果消息反序列化）
10. 客户端得到最终结果。
RPC 调用分以下两种：

同步调用：客户方等待调用执行完成并返回结果

异步调用：客户方调用后不用等待执行结果返回，但依然可以通过回调通知等方式获取返回结果。若客户方不关心调用返回结果，则变成单向异步调用，单向调用不用返回结果。

RPC步骤解析

SOA
流动计算架构：在分布式应用架构的基础上增加了一个调度、治理中心基于访问压力实时管理集群容量、提高集群的利用率，用于提高机器利用率的资源调度和治理中心(SOA) 是关键 (不浪费计算机资源)

dubbo的核心概念

下图截至dubbo的官网,dubbo由阿里开源给Apache组织

Dubbo 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，服务自动注册和发现。分布式系统是将一个系统拆分为多个不同的服务

 dubbo设计架构

该图来自Dubbo官网，描述了服务注册中心、服务提供方、服务消费方、服务监控中心之间的调用关系。

蓝颜色的线为初始化的过程,对于为图中的0,1,2,0这个过程为服务启动的过程

而红色的虚线为异步调用的过程

服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。

服务消费者（Consumer）: 调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，对于图中的4.invoke过程。如果调用失败，再选另一台调用。

注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo的特性

（1）服务注册中心
- 相比Hessian类RPC框架，Dubbo有自己的服务中心，写好的服务可以注册到服务中心，客户端从服务中心寻找服务，然后再到相应的服务提供者机器获取服务。通过服务中心可以实现集群、负载均衡、高可用(容错) 等重要功能。
- 服务中心一般使用zookeeper实现，也有redis和其他一些方式。以使用zookeeper作为服务中心为例，服务提供者启动后会在zookeeper的/dubbo节点下创建提供的服务节点，包含服务提供者ip、port等信息。服务提供者关闭时会从zookeeper中移除对应的服务。
- 服务使用者会从注册中心zookeeper中寻找服务，同一个服务可能会有多个提供者，Dubbo会帮我们找到合适的服务提供者，也就是针对服务提供者的负载均衡。
（2）负载均衡
- 当同一个服务有多个提供者在提供服务时，客户端如何正确的选择提供者实现负载均衡呢？dubbo也给我们提供了几种方案
  - random 随机选提供者，并可以给提供者设置权重
  - roundrobin 轮询选择提供者
  - leastactive 最少活跃调用数，相同活跃数的随机，活跃数：指调用前后计数差。使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。
  - consistenthash 一致性hash，相同参数的请求发到同一台机器上。
（3）简化测试，允许直连提供者

在开发阶段为了方便测试，通常系统客户端能指定调用某个服务提供者，那么可以在引用服务时加一个url参数去指定服务提供者。配置如下：
```
 <dubbo:reference id="xxxService"interface="com.alibaba.xxx.XxxService"url="dubbo://localhost:20890"/>
1
```
（4）服务版本，服务分组

在Dubbo配置文件中可以通过制定版本实现连接制定提供者，也就是通过服务版本可以控制服务的不兼容升级；当同一个服务有多种实现时，可以使用服务分组进行区分。

dubbo环境搭建 ZooKeeper注册中心

搭建zookeeper注册中心环境

官网参考地址,由于官网会不断的更新和改变,官网是最好的参考资料Zookeeper | Apache Dubbo

安装,得到对应版本的软件之后,直接解压就可以用了吗,不过需要修改一些配置。

在zookeeper官网下载zookeeper
http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/

下载的为3.4.14版本的

进入到conf目录下

复制文件
- 修改配置文件
可以看到上面的配置文件中的数据存储的方式是以linux系统的方式进行存储的,可以修改为window下的,并创建对应的目录
- 创建data目录
- 通过cmd命令进入到黑窗口之后,执行命令
- 可以看到服务在2181端口启动了
- 验证,进入一个新的黑窗口,注意是在bin目录下执行命令,bin下的为可执行文件
进入到该界面,表示没有问题
- 测试
再次查看的可以看到有两个节点了

如果想要详细的了解Dubbo可以参考官方的资料,使用

Zookeeper 注册中心的基本使用和工作原理。

如果想要了解更多由于Zookeeper的原理有关的知识,可以参考下面的文档Zookeeper | Apache Dubbo

zookeeper监控中心的配置和安装

1、下载dubbo-admin

可以在github中进行下载,如果github没有当前的版本,可以直接使用后面的资料中提供的下好的安装包。下载的可以说是一个完整的项目,现在需要做的就是将这个项目部署在服务器中。(一般使用别人的项目在自己的环境中进行运行的话,都需要修改一些配置文件)

下载之后解压的文件
- 打开配置文件之后发现和我们所期待的配置相同,因此不需要改动
- 通过cmd命令进入到dubbo-admin目录下,通过mvn对项目进行打包
  
  注意:打包可能需要花费几分钟的时间,需要耐心等待,同时注意zkServer.cmd是否开启状态(没有开启将会失败)
建议在打包前最好查看一下当前maven的版本,版本过高可能会打包失败。

我当前使用的版本为3.6.1
```
mvn -v    //查看版本
maven clean package         //清理并打包,如果是第一次打包该项目,可以不需要clean命令
1
2
```
- 打包成功
可以看到该目录下会多出一个目录

进入之后就可以看到一个打包好的文件,该打包好的现在已经可以单独执行了
- 可以把打包好的文件单独拿出来,这样看起来更舒服
- 在该jar所在的目录进入cmd中,运行该jar包,和平时的springboot项目启动一样
```
java -jar dubbo-admin-0.0.1-SNAPSHOT.jar
1
```
- 测试,在浏览器中输入
```
127.0.0.1:7001
1
```
  会提示输入账号和密码都为root
- 运行界面
Dubbo环境搭建，创建提供者、消费者项目

基于以下图实现服务提供者、消费者

消费者接口的搭建

创建Maven项目=> user-service-provider 服务提供者

通过idea创建一个maven项目

为了避免不必要的麻烦,在本项目中就没有连接数据库,而是通过假数据的方式

UserAddress.java
```
public class UserAddress implements Serializable {
    private Integer id;
    private String userAddress; //用户地址
    private String userId; //用户id
    private String consignee; //收货人
    private String phoneNum; //电话号码
    private String isDefault; //是否为默认地址    Y-是     N-否
    
    //下面是get,set,无参构造,有参构造,可以通过 @Data注解的方式生成,也可以通过快捷键的方式生成
}
1
2
3
4
5
6
7
8
9
10
```
UserService
```
public  interface UserService {
    /**
     * 按照用户的id返回所有的收获地址
     * @param userId
     * @return
     */
    public List<UserAddress> getUserAddressList(String userId);
}
1
2
3
4
5
6
7
8
```
接口的实现类UserServiceImp.java
```
public class UserServiceImpl implements UserService {
    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);
    }
}
1
2
3
4
5
6
7
8
```
目前的目录结构

消费者的接口搭建

创建Maven项目=> order-service-consumer 服务消费者(订单服务)

OrderService.java
```
public interface OrderService {

    /**
     * 初始化订单
     * @param userId
     */
    public void initOrder(String userId);
}
1
2
3
4
5
6
7
8
```
实现类
```
public class OrderServiceImpl implements OrderService {

    UserService userService;

    public void initOrder(String userId) {
        //查询用户的收获地址
        List<UserAddress> addressList = userService.getUserAddressList(userId);
        System.out.println(addressList);

    }
}
1
2
3
4
5
6
7
8
9
10
11
```
由于最终两个模块可能需要部署在不同的服务器中,所以需要将消息提供者的Bean和用户接口复制过来

创建公共的服务接口

这样的话更加的好

创建完成之后最终的目录结构如下所示
- 将bean和接口都提取到一个模块中,而将之前的删除掉
然后再user-service-provider中的pom.xml文件中添加依赖,否者将会报错
```
<dependencies>
		<dependency>
			<groupId>com.wjiangquan.gmail</groupId>
			<artifactId>gmall-interface</artifactId>
			<version>1.0-SNAPSHOT</version>
		</dependency>
</dependencies>
1
2
3
4
5
6
7
```
同时在order-service-consumer模块的pom.xml文件中也需要导入上面的依赖

服务提供者配置及测试
实现步骤
1. 将服务的提供者注册到注册中心(暴露服务)
  
  (1) 导入dubbo和zookeeper依赖
  
  导入dubbo依赖(2.6.2)
  
  <dependency> <groupId>com.alibabagroupId> <artifactId>dubboartifactId> <version>2.6.2version> dependency>
  1
  2
  3
  4
  5
  6
  7
  
  导入zookeeper
  
   <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency>
  1
  2
  3
  4
  5
  6
  7
(2) 配置服务提供者

在resource文件中创建provider.xml
```
 ```xml
 
 
 	
 	
 	
 	
 	
 	
 	
 	
 	
     
 	
 	
 	    
 
 ```
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
```
编写一个ProviderApplication启动类程序，运行测试配置
```
public class MailApplication {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext applicationContext= new ClassPathXmlApplicationContext("provider.xml");
        applicationContext.start();
        System.in.read();
    }
}
1
2
3
4
5
6
7
```
运行成功之后的效果

运行结果如下,运行之后刷新之后就可以看到数据了

可以查看服务的提供者

可以查看应用,都是正常的

包括服务也可以查看

等等,可以查看一系列的信息,至此,服务提供者的配置和测试完成

服务消费者配置及测试

在 order-service-consumer 服务消费者项目中引入依赖
```
	
		<dependency>
			<groupId>com.alibabagroupId>
			<artifactId>dubboartifactId>
			<version>2.6.2version>
		dependency>
		
		<dependency>
			<groupId>org.apache.curatorgroupId>
			<artifactId>curator-frameworkartifactId>
			<version>2.12.0version>
		dependency>
1
2
3
4
5
6
7
8
9
10
11
12
```
创建consumer.xml
```
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.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">
	
	<context:component-scan base-package="com.wjiangquan.gmall.service.imp"/>

	
	<dubbo:application name="order-service-consumer">dubbo:application>
	
	<dubbo:registry address="zookeeper://127.0.0.1:2181">dubbo:registry>

	
	<dubbo:reference interface="com.wjiangquan.gmall.service.UserService" id="userService">dubbo:reference>
	
beans>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
```
把当前OrderServiceImpl实现类中加上注解
```
package com.wjiangquan.gmall.service.imp;

import com.wjiangquan.gmall.bean.UserAddress;
import com.wjiangquan.gmall.service.OrderService;
import com.wjiangquan.gmall.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.util.List;

/**
 * @author weijiangquan
 * @date 2022/9/13 -17:35
 * @Description
 */

@Service
public class OrderServiceImpl implements OrderService {


    @Autowired
    UserService userService;


    public void initOrder(String userId) throws IOException {
        //查询用户的收获地址
        System.out.println("用户id"+userId);
        List<UserAddress> addressList = userService.getUserAddressList(userId);

        for (UserAddress userAddress:addressList){
            System.out.println(userAddress.getUserAddress());
        }
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
```
启动类
```
import com.wjiangquan.gmall.service.OrderService;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

/**
 * @author weijiangquan
 * @date 2022/9/13 -21:40
 * @Description
 */
public class MainApplication {

    @SuppressWarnings("resource")
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("consumer.xml");
        OrderService orderService = classPathXmlApplicationContext.getBean(OrderService.class);
        orderService.initOrder("1");
        System.out.println("调用完成......");
        System.in.read();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
```
运行结果

 dubbo-monitor-simple简易监控中心

执行命令,耐心等待,打包可能需要花费几分钟的时间
```
mvn package
1
```
打包成功

将打包之后生成的压缩包解压到当前目录

解压上面的文件并放到dubbo目录下(个人习惯)

进入配置文件

通过查看文件之后发现注册中心的地址配置是正确的

进入到bin目录中双击启动项目

如下提示启动成功

访问8080端口,发现正常

在服务提供者和消费者的xml中配置以下内容，再次启动服务提供和消费者启动类。
```
    
    <dubbo:monitor protocol="registry"></dubbo:monitor>
    
1
2
3
```
参考资料

资料链接: https://pan.baidu.com/s/1EaOm8iQ9KnC2URypjfk-kw?pwd=8gdt

提取码: 8gdt 复制这段内容后打开百度网盘手机App，操作更方便哦

视频资料 参考视频

[外链图片转存中…(img-86EGEJgJ-1663083616233)]

进入到bin目录中双击启动项目

[外链图片转存中…(img-h8ImxZnJ-1663083616235)]

如下提示启动成功

[外链图片转存中…(img-gPiIeJFK-1663083616237)]

访问8080端口,发现正常

[外链图片转存中…(img-MiM8Sm9F-1663083616243)]

在服务提供者和消费者的xml中配置以下内容，再次启动服务提供和消费者启动类。
```
    
    <dubbo:monitor protocol="registry"></dubbo:monitor>
    
1
2
3
```
参考资料

资料链接: https://pan.baidu.com/s/1EaOm8iQ9KnC2URypjfk-kw?pwd=8gdt

提取码: 8gdt 复制这段内容后打开百度网盘手机App，操作更方便哦

视频资料 参考视频
相关阅读:
数据可视化：Echarts和Tableau简介
 skywalking
基于深度学习的农作物叶片病害检测系统（UI界面+YOLOv5+训练数据集）
LeetCode SQL专项练习排序 & 修改（2）
AUTOCAD——Excel表格导入CAD、CAD合并两兄弟
 Python 并发：全局解释器锁（GIL）及其对多线程的影响
 Vue3 封装 Element Plus Menu 无限级菜单组件
 【gcc】RtpTransportControllerSend学习笔记 2
每天新内容
 HarmonyOS开发Java与ArkTS如何抉择
原文地址：https://blog.csdn.net/weixin_47994845/article/details/126843932

分布的简单介绍

应用架构的发展演变

发展演变

RPC的工作原理

RPC 调用分以下两种：

dubbo的核心概念

dubbo设计架构

Dubbo的特性

dubbo环境搭建 ZooKeeper注册中心

搭建zookeeper注册中心环境

Zookeeper 注册中心的基本使用和工作原理。

zookeeper监控中心的配置和安装

Dubbo环境搭建，创建提供者、消费者项目

消费者接口的搭建

消费者的接口搭建

创建公共的服务接口

服务提供者配置及测试

服务消费者配置及测试

dubbo-monitor-simple简易监控中心

参考资料

参考资料