[TOC]
Dubbo学习笔记
参考视频Dubbo项目实战
Dubbo中文官网
第零章 初识分布式框架
-
什么是分布式框架
分布式系统是若干独立系统的集合,但是用户使用起来像是在使用一套系统 -
为什么要使用分布式系统
规模的逐步扩大和业务的复杂,单台计算机狂不住巨大的流量(双11) -
应用架构的演变
1)单一机构
当网站流量很小的时候,我们将所有的应用放到一台服务器上,打包运行
优点:开发简单,部署方便
缺点:不容易扩展,性能难提升,维护不方便
2)垂直应用架构
将大应用拆分称为小应用(一般按照业务拆分),根据不同的访问频率决定各自业务部署的服务器数量
优点:容易扩展
缺点:页面一改,可能造成整个项目重新部署,业务和界面没有分离开,随着业务种类增加,如何解决业务之间的相互调用问题,订单服务器和用户服务器交互效率的问题
3)分布式架构(基于RPC:远程过程调用 Remote Procedure Call)
将业务拆分后,用某种方式实现各个业务模块的远程调用和复用,这时一个好的PRC框架就决定了你的分布式架构的性能,怎么调用,何时调用,服务器挂了怎么办等等。
我们需要一个框架来帮我们解决这个问题
RPC 【Remote Procedure Call】是指远程过程调用,是一种进程间通信方式,是一种技 术思想,而不是规范。它允许程序调用另一个地址空间(网络的另一台机器上)的过程或函 数,而不用开发人员显式编码这个调用的细节。调用本地方法和调用远程方法一样。
RPC 的实现方式可以不同。例如 java 的 rmi, spring 远程调用等。
RPC 概念是在上世纪 80 年代由 Brue Jay Nelson(布鲁·杰伊·纳尔逊)提出。使用 PRC 可以 将本地的调用扩展到远程调用(分布式系统的其他服务器)。
RPC 的特点
- 简单:使用简单,建立分布式应用更容易。
- 高效:调用过程看起来十分清晰,效率高。
- 通用:进程间通讯的方式,有通用的规则。
Dubbo:Duboo是一个高性能的RPC框架,解决了分布式中的调用问题
优点:解决了分布式中的调用问题
缺点:假设有100台服务器,50台用户业务服务器,50台订单业务服务器,但是上线后发现,用户服务器使用率很小,但是订单服务器压力很大,最佳配比应该是1:4,这时就还需要一个统一管理的调度中心。
第一章 认识Dubbo
1.1 为什么Dubbo性能高
1.2 其他RPC框架
gRPC、Thrift、HSF
1.3 Dubbo的前世今生
第二章 Dubbo框架
2.1 dubbo概述
2.2 基本架构
摘自官网:
2.3 dubbo支持的协议
2.4 直连方式
调用远程方法获取学生总人数
2.4.1 创建服务提供者
项目名称 link-userservice-provider
步骤:
1)创建一个web工程(maven)
2)创建一个实体bean查询的结果
3)提供一个服务接口:xxxx
4)实现这个服务接口
5)配置dubbo服务提供者的核心配置文件
6)添加监听器
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.wkcto.dubbo</groupId>
<artifactId>001-link-userservice-provider</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>
<!-- Spring依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.2.5.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>5.2.5.RELEASE</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo
dubbo依赖
-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.2</version>
</dependency>
</dependencies>
</project>
dubbo-userservice-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://dubbo.apache.org/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">
<!-- 服务的提供者声明名称:必须保证服务名称的唯一性,它的名称是dubbo内部使用的唯一标志-->
<dubbo:application name="001-link-userservice-provider"/>
<!-- 访问服务协议的名称及端口号,dubbo官方推荐使用的是dubbo协议,端口号默认为20880
name:指定协议的名称
port:指定协议的端口号,默认为20880
-->
<dubbo:protocol name="dubbo" port="20880"/>
<!-- 暴露服务接口
interface:要暴露的接口,写类的全限定名
ref:接口引用的实现类在spring容器中的标识
registry:如果不使用注册中心,则值为N/A
-->
<dubbo:service interface="com.wkcto.dubbo.service.UserService" ref="userService"
registry="N/A"/>
<!-- 将接口的实现类加载到spring容器-->
<bean id="userService" class="com.wkcto.dubbo.service.impl.UserServiceImpl"></bean>
</beans>
UserService接口和实现类
public interface UserService {
/**
* 根据用户id获取用户信息
* @param id
* @return
*/
User queryUserById(Integer id);
}
public class UserServiceImpl implements UserService {
@Override
public User queryUserById(Integer id) {
User user = new User();
user.setId(1001);
user.setName("lisi");
user.setAge(20);
return user;
}
}
public class User {
private Integer id;
private String name;
private Integer age;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
}
2.4.2 创建消费者服务
步骤:
1)创建maven web工程:服务的消费者
2)创建pom文件:添加需要的依赖(spring,dubbo)
3)配置dubbo的核心配置文件
4)编写controller
5)配置中央调度器
pom.xml
处理要添加spring和dubbo,还需要依赖提供者的jar包
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.2.5.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>5.2.5.RELEASE</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.2</version>
</dependency>
<dependency>
<groupId>com.wkcto.dubbo</groupId>
<artifactId>001-link-userservice-provider</artifactId>
<version>1.0.0</version>
</dependency>
Controller
@Controller
public class UserController {
@Autowired
private UserService userService;
@RequestMapping("/user")
public String userDetail(Model model, Integer id){
User user = userService.queryUserById(id);
model.addAttribute("user", user);
return "userDetail";
}
}
application.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:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd">
<!-- 开启组件扫描-->
<context:component-scan base-package="com.wkcto.dubbo.controller" />
<!-- 开启注解驱动-->
<mvc:annotation-driven/>
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="prefix" value="/"/>
<property name="suffix" value=".jsp" />
</bean>
</beans>
dubbo-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"
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">
<!-- 声明服务消费者的名称:保证唯一性-->
<dubbo:application name="002-link-consumer"/>
<!-- 引用远程服务接口
id:远程服务接口对象的名称
interface:要调用的远程接口的全限定类名
url:访问服务接口的地址
registry:不使用注册中心,值为N/A
-->
<dubbo:reference id="userService"
interface="com.wkcto.dubbo.service.UserService"
url="dubbo://localhost:20880"
registry="N/A" />
</beans>
web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
version="4.0">
<!-- 中央调度器-->
<servlet>
<servlet-name>dispatcherServlet</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:application.xml, classpath:dubbo-consumer.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>dispatcherServlet</servlet-name>
<url-pattern>/</url-pattern>
</servlet-mapping>
</web-app>
userDeatil.jsp
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
<title>用户详情</title>
</head>
<body>
<h1>用户详情</h1>
<div>用户表示:${user.id}</div>
<div>用户名称:${user.name}</div>
</body>
</html>
在消费者服务可以直接new出提供者的接口实现类,存在问题
dubbo官方推荐必须有一个接口工程,它是一个maven工程
要求接口工程里存放的内容如下:
1.对外暴露的服务接口(service接口)
2.实体bean对象
2.5 服务化最佳实践
2.5.1 分包
建议将服务接口,服务模型等均放在公共包中
2.5.2 粒度
服务接口尽可能大粒度,每个服务方法应代表一个功能,而不是某功能的一个步骤
服务接口建议以业务场景为单位划分,并对相近业务做抽象,防止接口数量爆炸
不建议使用过于抽象的通用接口,如Map query(Map),这样的接口没有明确语义,会给后期维护带来不便
2.5.3 版本
每个接口都应该定义版本号,区分同一个接口的不同实现
eg:<dubbo:service interface="com.xxx.xxxService" version="1.0.0">
2.5.4 服务化最佳案例
1)在一个maven普通java工程创建接口和bean
2)在另一个web工程创建接口的实现类
注意需要依赖1)中的jar包
3)在另一个web工程创建消费者
同样依赖1)中的jar包
该方案就是对直连方式的改造
2.6 dubbo常用标签
2.6.1 公用标签
<dubbo:application name="xx"/>
<dubbo:registry />
2.6.2 服务提供者标签
2.6.3 服务消费者
第三章 注册中心
3.1 在linux上下载zookeeper
[linux安装zookeeper]‰(https://www.wuminggao.cn/archives/zookeeperinstall)
3.2 使用注册中心
参考这个仓库
使用linux服务器上的zookeeper
将注册中心的地址改变即可
<dubbo:registry address="zookeeper://ip:2181"/>
3.3 版本号version的使用
一个接口可能有多个版本,在保留旧版本的情况下,使用新版本
第四章 dubbo的配置
4.1 配置原则
在服务提供者配置访问参数,因为服务提供者更了解服务的各种参数
4.2 关闭检查
4.3 重试次数
4.4 超时时间
一般会设置
4.5 版本号
第五章 监控中心