Dubbo学习

Posted 2021-03-07 DarJeely

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Dubbo学习相关的知识，希望对你有一定的参考价值。

https://www.cnblogs.com/wq-9/p/10989931.html

Dubbo

一、概念

1 Dubbo 介绍

Dubbo 是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的
RPC 实现服务的输出和输入功能，可以和 Spring 框架无缝集成。Dubbo 框架，是基于容器
运行的.。容器是 Spring。
官方网站 : http://dubbo.apache.org/
阿里巴巴已经将 dubbo 框架捐献给了 Apache 软件基金会

dubbo的详细说明：https://blog.csdn.net/weixin_41485592/article/details/81952499

https://blog.csdn.net/houshaolin/article/details/76408399

dubbo 阿里开源的一个SOA服务治理框架，从目前来看把它称作是一个RCP远程调用框架更为贴切。

单从RPC框架来说，功能较完善，支持多种传输和序列化方案。

所以想必大家已经知道他的核心功能了：就是远程调用。

2 单体架构

单体架构也称之为单体系统或者是单体应用。就是一种把系统中所有的功能、模块耦合
在一个应用中的架构方式。其优点为：项目易于管理、部署简单。缺点：测试成本高、可伸
缩性差、可靠性差、迭代困难、跨语言程度差、团队协作难

3 SOA 架构: Service-Oriented Architecture

面向服务的架构（SOA）是一个组件模型，它将应用程序拆分成不同功能单元（称为服
务）通过这些服务之间定义良好的接口和契约联系起来。接口是采用中立的方式进行定义的，
它应该独立于实现服务的硬件平台、操作系统和编程语言。这使得构建在各种各样的系统中
的服务可以以一种统一和通用的方式进行交互。

4 RPC 远程过程调用 : Remote Procedure Call Protocol

远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底
层网络技术的协议。RPC 协议假定某些传输协议的存在，如 TCP 或 UDP，为通信程序之间
携带信息数据。在 OSI 网络通信模型中，RPC 跨越了传输层和应用层。RPC 使得开发包括
网络分布式多程序在内的应用程序更加容易。

二、 Dubbo 框架结构

1 Dubbo 角色介绍

1.1registry

注册中心. 是用于发布和订阅服务的一个平台.用于替代 SOA 结构体系框架中的 ESB 服
务总线的。

1.1.1发布

开发服务端代码完毕后, 将服务信息发布出去. 实现一个服务的公开.
1.1.2订阅
客户端程序,从注册中心下载服务内容这个过程是订阅.
订阅服务的时候, 会将发布的服务所有信息,一次性下载到客户端.
客户端也可以自定义, 修改部分服务配置信息. 如: 超时的时长, 调用的重试次数等.

1.2consumer

服务的消费者, 就是服务的客户端.
消费者必须使用 Dubbo 技术开发部分代码. 基本上都是配置文件定义.

1.3provider

服务的提供者, 就是服务端.
服务端必须使用 Dubbo 技术开发部分代码. 以配置文件为主

1.4container

容器. Dubbo 技术的服务端(Provider), 在启动执行的时候, 必须依赖容器才能正常启动.
默认依赖的就是 spring 容器. 且 Dubbo 技术不能脱离 spring 框架.
在 2.5.3 版本的 dubbo 中, 默认依赖的是 spring2.5 版本技术. 可以选用 spring4.5 以下版
本.
在 2.5.7 版本的 dubbo 中, 默认依赖的是 spring4.3.10 版本技术. 可以选择任意的 spring
版本.

1.5monitor

监控中心. 是 Dubbo 提供的一个 jar 工程.
主要功能是监控服务端(Provider)和消费端(Consumer)的使用数据的. 如: 服务端是什么,
有多少接口,多少方法, 调用次数, 压力信息等. 客户端有多少, 调用过哪些服务端, 调用了
多少次等.

2 Dubbo 架构图的执行流程

2.1Dubbo 执行流程

0 start: 启动 Spring 容器时,自动启动 Dubbo 的 Provider

1 register: Dubbo 的 Provider 在启动后自动会去注册中心注册内容.注册的内容包括:

1.1 Provider 的 IP
1.2 Provider 的端口.
1.3 Provider 对外提供的接口列表.哪些方法.哪些接口类
1.4 Dubbo 的版本.
1.5 访问 Provider 的协议

2 subscribe: 订阅.当 Consumer 启动时,自动去 Registry 获取到所已注册的服务的信息.
3 notify: 通知.当 Provider 的信息发生变化时, 自动由 Registry 向 Consumer 推送通知.
4 invoke: 调用. Consumer 调用 Provider 中方法
4.1 同步请求.消耗一定性能.但是必须是同步请求,因为需要接收调用方法后的结
果.
5 count:次数. 每隔 2 分钟,provoider 和 consumer 自动向 Monitor 发送访问次数.Monitor
进行统计.

3 Dubbo 支持的协议

3.1Dubbo 协议(官方推荐协议)

优点：
采用 NIO 复用单一长连接，并使用线程池并发处理请求，减少握手和加大并发效率，
性能较好（推荐使用）
缺点：
大文件上传时,可能出现问题(不使用 Dubbo 文件上传)

3.2RMI(Remote Method Invocation)协议

1) 优点:
JDK 自带的能力。可与原生 RMI 互操作，基于 TCP 协议
2) 缺点:
偶尔连接失败.

3.3Hessian 协议

1) 优点:

可与原生 Hessian 互操作，基于 HTTP 协议

2) 缺点:

需 hessian.jar 支持，http 短连接的开销大

4 Dubbo 支持的注册中心

4.1Zookeeper(官方推荐)

1) 优点:
支持分布式.很多周边产品.
2) 缺点:
受限于 Zookeeper 软件的稳定性.Zookeeper 专门分布式辅助软件,稳定较优

4.2Multicast

1) 优点:

去中心化,不需要单独安装软件.

2) 缺点:
2.2.1 Provider 和 Consumer 和 Registry 不能跨机房(路由)

4.3Redis

1) 优点:
支持集群,性能高
2) 缺点:
要求服务器时间同步.否则可能出现集群失败问题.

4.4Simple

1) 优点:
标准 RPC 服务.没有兼容问题
2) 缺点:
不支持集群

三、 Dubbo 入门案例

1 安装 Zookeeper

请看 zookeeper 视频

2 创建 Provider

2.1创建工程

Provider 工程类型是 jar 类型

2.2修改 POM 文件添加 Dubbo 的坐标

2.2.1关于版本的问题。在 Dubbo 的 2.5.3 版本中对于 spring
的支持是 2.5.x。替换低版本的 spring。

View Code

2.2.2Dubbo 的 2.5.4 版本中对于 spring 的支持为 4.3.10

View Code

2.3创建服务

服务：项目中对外界所提供的能力
服务标准：接口+接口实现类
接口：对外界描述当前服务的信息，如协议类型，服务提供者的地址，发布的服务名
称，服务中方法名称等信息。
接口实现类：对发布的接口中的标准的具体实现。

2.3.1创建接口

/* 服务接口*

@author Administrator**/

public interface DubboService

{

String showMsg(String str);

}

2.3.2创建接口实现类

View Code

2.3.3配置服务

View Code

2.4启动 Provider

2.4.1启动 Zookeeper 注册中心

2.4.2启动 Spring 容器

2.4.2.1 通过 SpringAPI 启动容器

在 ApplicationContext 接口中未定义 start()方法，需要时用接口实现类

2.4.2.2 启动时异常信息

JDK 版本不符合要求。注意 dubbo2.5.4 要求 jdk 必须是 1.8 或者以上的版本

2.4.2.3 工具名称为：zkclient

修改 POM 文件添加 zkclient 坐标

<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>

2.4.2.4 启动代码

public class Start {
public static void main(String[] args) throws
Exception {
ClassPathXmlApplicationContext ac = new
ClassPathXmlApplicationContext("application-dubbo.
xml");
ac.start();
System.in.read();
}
}

2.4.2.5 使用 DubboAPI 启动 Provider

public class Start {
public static void main(String[] args) throws
Exception {
/*ClassPathXmlApplicationContext ac = new 
ClassPathXmlApplicationContext("application-dubbo.
xml");
ac.start();
System.in.read();*/
//Main 类下的 main 方法在启动时默认的回去
classpath:/META-INF/spring/*.xml
Main.main(args);
}
}

特点：
1，自带线程阻塞
2，支持优雅关系

2.5注册中心中的服务发布信息

使用 zkCli.sh 连接 ZooKeeper 服务，使用 ls 命令查看服务信息。
ls /dubbo/服务接口名称/providers
显示结果如下：

dubbo%3A%2F%2F192.168.2.108%3A20880%2Fcom.bjsxt.service.DubboService%3Fanyh
ost%3Dtrue%26application%3Dmyprovider%26dubbo%3D2.5.4%26generic%3Dfalse%26interfa
ce%3Dcom.bjsxt.service.DubboService%26methods%3DshowMsg%26pid%3D3936%26side%3
Dprovider%26timestamp%3D1536807891514

转换结果如下：

dubbo://192.168.2.108:20880/com.bjsxt.service.DubboService?anyhost=true&application=m
yprovider&dubbo=2.5.4&generic=false&interface=com.bjsxt.service.DubboService&methods=sh
owMsg&pid=3936&side=provider×tamp=1536807891514

3 Dubbo Admin 管理平台搭建

3.1安装 Admin 管理平台

Admin 管理平台是一个 war 项目
在 Linux 系统中安装 JDK 以及 tomcat。
使用 unzip 命令解压 zip 压缩包。
删除 tomcat/webapps 目录下的 ROOT 目录
将解压出来的 ROOT 目录拷贝到 tomcat/webapps 目录下

3.2配置 Admin 管理平台

进入

/usr/local/tomcat/webapps/ROOT/WEB-INF找到dubbo.properties配置如下。

Address:zookeeper 的链接地址。如果是集群给一个就可以了
Root.password 设置默认 root 用户的密码
Guest.password 设置默认 guest 用户的密码

3.3访问 Admin 管理平台

4 创建 Consumer

4.1创建工程

4.2修改 POM 文件

View Code

4.3编写 Consumer

4.3.1接口

public interface UserService {
void test(String str);
}

4.3.2接口实现类

View Code

4.4配置 Consumer

View Code

4.5测试 Consumer

4.5.1测试结果

四、 Dubbo 实战案例

1 案例介绍

1.1需求：完成对用户表的 CRUD 操作

1.2项目架构方式：SOA 面向服务架构

1.3技术选型：Maven，SpringMVC，Spring，Mybatis，Dubbo，
Zookeeper，mysql

2 创建表

CREATE TABLE `users` (
`userid` int(11) NOT NULL AUTO_INCREMENT,
`username` varchar(30) DEFAULT NULL,
`userage` int(11) DEFAULT NULL,
PRIMARY KEY (`userid`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;

3 项目设计

4 创建项目

4.1创建 dubbo-parent

4.1.1创建项目

4.1.2修改 POM 文件

View Code

4.2创建 dubbo-pojo

4.2.1创建项目

4.2.2创建 Users 实体

View Code

4.3dubbo-mapper

4.3.1创建项目

4.3.2创建 UsersMapper 接口

package com.bjsxt.mapper;
public interface UsersMapper {
}

4.3.3创建 UsersMapper 映射配置文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD 
Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper
namespace="com.bjsxt.mapper.UserMapper" >
</mapper>

4.3.4修改 POM 文件

View Code

4.4创建 dubbo-user-provider

4.4.1创建项目

4.5创建 dubbo-user-interface

4.5.1创建项目

4.5.2修改 POM 文件

View Code

4.6创建 dubbo-user-service

4.6.1创建项目

4.6.2修改 POM 文件

View Code

4.6.3配置 MyBatis 与 Dubbo

spring的配置文件默认在resources下的META-INF下的spring下读取。

View Code

4.6.4测试整合

关于 dubbo 与 spring 的 jar 注入问题。
在开发时对于 spring 的 jar 的处理上我们有两种方案
1，依赖 dubbo 的坐标导入 spring 的容器所依赖的 jar 包。在使用过程中缺少 spring 的
组件时，我们在手动添加坐标。
2，在添加 dubbo 的坐标中剔除已包含的 spring 的 jar 包。自己手动导入所有使用 spring
组件的坐标。

4.7创建 dubbo-user-consumer

4.7.1创建项目

4.8创建 dubbo-user-portal-service

4.8.1创建项目

4.9修改 POM 文件

View Code

4.10创建 dubbo-user-portal

4.10.1 创建项目

4.10.2 修改 POM 文件

View Code

4.10.3 配置 SpringMVC，Spring，web.xml，Dubbo

View Code

4.10.4 测试整合

5 实现业务

5.1添加用户

5.1.1实现添加用户服务

5.1.1.1 dubbo-mapper

public interface UsersMapper {
void insertUsers(Users users);
}

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD 
Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper
namespace="com.bjsxt.mapper.UsersMapper">
<insert id="UsersMapper"
parameterType="com.bjsxt.pojo.Users">
insert into users(username,userage) 
values(#{username},#{userage})
</insert>
</mapper>

5.1.1.2 dubbo-user-interface

public interface AddUserDubboService {
void addUser(Users users);
}

5.1.1.3 dubbo-user-service

@Service
public class AddUserDubboServiceImpl implements
AddUserDubboService {
 @Autowired
 private UsersMapper usersMapper;
 
@Override
public void addUser(Users users) {
this.usersMapper.insertUsers(users);
}
}

View Code

5.1.2实现添加用户业务

5.1.2.1 dubbo-user-portal-service

Pom 文件

View Code

业务接口以及接口实现

public interface UserService {
void addUsers(Users users);
}

View Code

dubbo-user-portal

View Code

测试

5.2查询用户

5.2.1实现查询用户服务

5.2.1.1 dubbo-user-interface

public interface FindUserDubboService {
List<Users> selectUsersAll();
}

5.2.1.2 dubbo-user-service

@Service
public class FindUserDubboServiceImpl implements
FindUserDubboService {
@Autowired
private UsersMapper usersMapper;
@Override
public List<Users> selectUsersAll() {
return this.usersMapper.selectAll();
}
}

5.2.1.3 application-dubbo.xml

View Code

5.2.2实现查询用户业务

5.2.2.1 dubbo-user-portal-service

View Code

以上是关于Dubbo学习的主要内容，如果未能解决你的问题，请参考以下文章

Dubbo 源码学习系列优化篇《工厂模式在Dubbo中的应用》

稳定性耗时监控原因分析-- dubbo rpc 框架的线程池,io 连接模型. 客户端,服务端

dubbo学习远程调用原理

dubbo基础学习总结

IOS开发－OC学习－常用功能代码片段整理

java SpringRetry学习的代码片段

Dubbo学习

Dubbo

Dubbo

一、 概念

1 Dubbo 介绍

2 单体架构

3 SOA 架构: Service-Oriented Architecture

4 RPC 远程过程调用 : Remote Procedure Call Protocol

二、 Dubbo 框架结构

1 Dubbo 角色介绍

1.1registry

1.1.1发布

1.2consumer

1.3provider

1.4container

1.5monitor

2 Dubbo 架构图的执行流程

2.1Dubbo 执行流程

3 Dubbo 支持的协议

3.1Dubbo 协议(官方推荐协议)

3.2RMI(Remote Method Invocation)协议

3.3Hessian 协议

4 Dubbo 支持的注册中心

4.1Zookeeper(官方推荐)

4.2Multicast

4.3Redis

4.4Simple

三、 Dubbo 入门案例

1 安装 Zookeeper

2 创建 Provider

2.1创建工程

2.2修改 POM 文件添加 Dubbo 的坐标

2.3创建服务

2.3.1创建接口

2.3.2创建接口实现类

2.3.3配置服务

2.4启动 Provider

2.4.1启动 Zookeeper 注册中心

2.4.2启动 Spring 容器

2.4.2.1 通过 SpringAPI 启动容器

2.4.2.2 启动时异常信息

2.4.2.3 工具名称为：zkclient

2.4.2.4 启动代码

2.4.2.5 使用 DubboAPI 启动 Provider

2.5注册中心中的服务发布信息

3 Dubbo Admin 管理平台搭建

3.1安装 Admin 管理平台

3.2配置 Admin 管理平台

3.3访问 Admin 管理平台

4 创建 Consumer

4.1创建工程

4.2修改 POM 文件

4.3编写 Consumer

4.3.1接口

4.3.2接口实现类

4.4配置 Consumer

4.5测试 Consumer

4.5.1测试结果

四、 Dubbo 实战案例

1 案例介绍

1.1需求：完成对用户表的 CRUD 操作

1.2项目架构方式：SOA 面向服务架构

1.3技术选型：Maven，SpringMVC，Spring，Mybatis，Dubbo，Zookeeper，mysql

2 创建表

3 项目设计

4 创建项目

4.1创建 dubbo-parent

4.1.1创建项目

4.1.2修改 POM 文件

4.2创建 dubbo-pojo

4.2.1创建项目

4.2.2创建 Users 实体

4.3.2创建 UsersMapper 接口

4.3.3创建 UsersMapper 映射配置文件

4.3.4修改 POM 文件

4.4创建 dubbo-user-provider

4.4.1创建项目

4.5创建 dubbo-user-interface

4.5.1创建项目

4.5.2修改 POM 文件

一、概念

1.3技术选型：Maven，SpringMVC，Spring，Mybatis，Dubbo，
Zookeeper，mysql