Dubbo学习

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

Dubbo

 

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。

 

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

 

2.3创建服务

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

2.3.1创建接口

/* 服务接口*

@author Administrator**/

public interface DubboService

{

String showMsg(String str);

}

2.3.2创建接口实现类

 

2.3.3配置服务

 

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 坐标

<!-- https://mvnrepository.com/artifact/com.101tec/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 文件

 

4.3编写 Consumer

4.3.1接口

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

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 创建表

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 文件

 

4.2创建 dubbo-pojo

4.2.1创建项目

 4.2.2创建 Users 实体

 

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 文件

 

4.4创建 dubbo-user-provider

4.4.1创建项目

4.5创建 dubbo-user-interface

4.5.1创建项目

4.5.2修改 POM 文件

 

4.6创建 dubbo-user-service

4.6.1创建项目

4.6.2修改 POM 文件

 

4.6.3配置 MyBatis 与 Dubbo

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

 

 

 

 

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 文件

 

4.10创建 dubbo-user-portal

4.10.1 创建项目

4.10.2 修改 POM 文件

 

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

 

 

 

 

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);
}
}

 

5.1.2实现添加用户业务

5.1.2.1 dubbo-user-portal-service

Pom 文件

 

业务接口以及接口实现

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

 

dubbo-user-portal

 

 

 

 

测试

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

 

5.2.2实现查询用户业务

5.2.2.1 dubbo-user-portal-service