dubbo学习笔记
Posted 莪假裝堅強
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了dubbo学习笔记相关的知识，希望对你有一定的参考价值。
分布的简单介绍
Dubbo是用于分布式系统的框架所以我们要先了解什么是分布式
分布式系统是若干独立 计算机的集合，这些计算机对于用户来说就像单个相关系统。
老式系统(单一应用架构)就是把一个系统，统一放到一个服务器当中然后每一个服务器上放一个系统，如果说要更新代码的话，每一个服务器上的系统都要重新去部署十分的麻烦。
而分布式系统就是将一个完整的系统拆分成多个不同的服务，然后在将每一个服务单独的放到一个服务器当中。
应用架构的发展演变
下面图片来自dubbo的官网Apache Dubbo
发展演变
**ORM **单一应用架构：一个项目装到一个服务器当中，也可以运行多个服务器每一个服务器当中都装一个项目。
缺点：
-
如果要添加某一个功能的话就要把一个项目重新打包，在分别部署到每一个服务器当中去。
-
如果后期项目越来越大的话单台服务器跑一个项目压力会很大的。会不利于维护，开发和程序的性能。
**MVC **垂直应用架构：将应用切割成几个互不相干的小应用，在将每个小应用独立放到一个服务器上，如果哪一个应用的访问数量多就多加几台服务器。
分布式服务架构
RPC简介
分布式应用架构(远程过程调用)：当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。
什么叫RPC
- RPC [ Remote Procedure Call]是指远程过程调用，是一种进程问通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。
- RPC（Remote Procedure Call）— 远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。
RPC的工作原理
下面是对于上图的详细解释,也就是上面原理图的详细执行过程
- Client像调用本地服务似的调用远程服务；
- Client stub接收到调用后，将方法、参数序列化
- 客户端通过sockets将消息发送到服务端
- Server stub 收到消息后进行解码（将消息对象反序列化）
- Server stub 根据解码结果调用本地的服务
- 本地服务执行(对于服务端来说是本地执行)并将结果返回给Server stub
- Server stub将返回结果打包成消息（将结果消息对象序列化）
- 服务端通过sockets将消息发送到客户端
- Client stub接收到结果消息，并进行解码（将结果消息反序列化）
- 客户端得到最终结果。
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，相同参数的请求发到同一台机器上。
- random
（3）简化测试，允许直连提供者
在开发阶段为了方便测试，通常系统客户端能指定调用某个服务提供者，那么可以在引用服务时加一个url参数去指定服务提供者。 配置如下：
<dubbo:reference id="xxxService"interface="com.alibaba.xxx.XxxService"url="dubbo://localhost:20890"/>
（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命令
- 打包成功
可以看到该目录下会多出一个目录
进入之后就可以看到一个打包好的文件,该打包好的现在已经可以单独执行了
- 可以把打包好的文件单独拿出来,这样看起来更舒服
- 在该
jar所在的目录进入cmd中,运行该jar包,和平时的springboot项目启动一样
java -jar dubbo-admin-0.0.1-SNAPSHOT.jar
-
测试,在浏览器中输入
127.0.0.1:7001会提示输入账号和密码都为
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注解的方式生成,也可以通过快捷键的方式生成
UserService
public interface UserService
/**
* 按照用户的id返回所有的收获地址
* @param userId
* @return
*/
public List<UserAddress> getUserAddressList(String userId);
接口的实现类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);
目前的目录结构
消费者的接口搭建
创建Maven项目=> order-service-consumer 服务消费者(订单服务)
OrderService.java
public interface OrderService
/**
* 初始化订单
* @param userId
*/
public void initOrder(String userId);
实现类
public class OrderServiceImpl implements OrderService
UserService userService;
public void initOrder(String userId)
//查询用户的收获地址
List<UserAddress> addressList = userService.getUserAddressList(userId);
System.out.println(addressList);
由于最终两个模块可能需要部署在不同的服务器中,所以需要将消息提供者的
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>
同时在order-service-consumer模块的pom.xml文件中也需要导入上面的依赖
服务提供者配置及测试
实现步骤
将服务的提供者注册到注册中心(暴露服务)
(1) 导入dubbo和zookeeper依赖
- 导入dubbo依赖(2.6.2)
<!--引入dubbo--> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.2</version> </dependency>
- 导入zookeeper
<!--注册中心使用的是zookeeper,引入操作zookeeper的客户端--> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency>
(2) 配置服务提供者
在
resource文件中创建provider.xml```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="127.0.0.1:2181"></dubbo:registry> <!--3、指定通信规则（通信协议? 服务端口） 非常重要的一步 ,真正的协议有许多,可以参考官网,在这里就是用dubbo--> <dubbo:protocol name="dubbo" port="20880"></dubbo:protocol> <!--4、暴露服务 让别人调用 ref指向服务的真正实现对象--> <dubbo:service interface="com.wjiangquan.gmall.service.UserService" ref="userServiceImpl"></dubbo:service> <!--服务的实现--> <bean id="userServiceImpl" class="com.wjiangquan.gmall.service.imp.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();
运行成功之后的效果
运行结果如下,运行之后刷新之后就可以看到数据了
可以查看服务的提供者
可以查看应用,都是正常的
包括服务也可以查看
等等,可以查看一系列的信息,至此,服务提供者的配置和测试完成
服务消费者配置及测试
在 order-service-consumer 服务消费者项目中引入依赖
<!--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>
创建consumer.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://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>
把当前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());
启动类
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();
运行结果
dubbo-monitor-simple简易监控中心
执行命令,耐心等待,打包可能需要花费几分钟的时间
mvn package
打包成功
将打包之后生成的压缩包解压到当前目录
解压上面的文件并放到dubbo目录下(个人习惯)
进入配置文件
通过查看文件之后发现注册中心的地址配置是正确的
进入到bin目录中双击启动项目
如下提示启动成功
访问8080端口,发现正常
在服务提供者和消费者的xml中配置以下内容，再次启动服务提供和消费者启动类。
<!--dubbo-monitor-simple监控中心发现的配置-->
<dubbo:monitor protocol="registry"></dubbo:monitor>
<!--<dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor>-->
参考资料
资料链接: 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-simple监控中心发现的配置-->
<dubbo:monitor protocol="registry"></dubbo:monitor>
<!--<dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor>-->
参考资料
资料链接: https://pan.baidu.com/s/1EaOm8iQ9KnC2URypjfk-kw?pwd=8gdt 提取码: 8gdt 复制这段内容后打开百度网盘手机App，操作更方便哦
视频资料参考视频
以上是关于dubbo学习笔记的主要内容，如果未能解决你的问题，请参考以下文章