Dubbo学习笔记

博主 351 2020-07-19

[TOC]
Dubbo学习笔记
参考视频Dubbo项目实战
Dubbo中文官网

第零章 初识分布式框架

  1. 什么是分布式框架
    分布式系统是若干独立系统的集合,但是用户使用起来像是在使用一套系统

  2. 为什么要使用分布式系统
    规模的逐步扩大和业务的复杂,单台计算机狂不住巨大的流量(双11)

  3. 应用架构的演变
    1)单一机构
    当网站流量很小的时候,我们将所有的应用放到一台服务器上,打包运行
    优点:开发简单,部署方便
    缺点:不容易扩展,性能难提升,维护不方便
    2)垂直应用架构
    将大应用拆分称为小应用(一般按照业务拆分),根据不同的访问频率决定各自业务部署的服务器数量
    优点:容易扩展
    缺点:页面一改,可能造成整个项目重新部署,业务和界面没有分离开,随着业务种类增加,如何解决业务之间的相互调用问题,订单服务器和用户服务器交互效率的问题
    3)分布式架构(基于RPC:远程过程调用 Remote Procedure Call)
    将业务拆分后,用某种方式实现各个业务模块的远程调用和复用,这时一个好的PRC框架就决定了你的分布式架构的性能,怎么调用,何时调用,服务器挂了怎么办等等。
    我们需要一个框架来帮我们解决这个问题


RPC 【Remote Procedure Call】是指远程过程调用,是一种进程间通信方式,是一种技 术思想,而不是规范。它允许程序调用另一个地址空间(网络的另一台机器上)的过程或函 数,而不用开发人员显式编码这个调用的细节。调用本地方法和调用远程方法一样。
RPC 的实现方式可以不同。例如 java 的 rmi, spring 远程调用等。
RPC 概念是在上世纪 80 年代由 Brue Jay Nelson(布鲁·杰伊·纳尔逊)提出。使用 PRC 可以 将本地的调用扩展到远程调用(分布式系统的其他服务器)。
RPC 的特点

  1. 简单:使用简单,建立分布式应用更容易。
  2. 高效:调用过程看起来十分清晰,效率高。
  3. 通用:进程间通讯的方式,有通用的规则。

Dubbo:Duboo是一个高性能的RPC框架,解决了分布式中的调用问题
优点:解决了分布式中的调用问题
缺点:假设有100台服务器,50台用户业务服务器,50台订单业务服务器,但是上线后发现,用户服务器使用率很小,但是订单服务器压力很大,最佳配比应该是1:4,这时就还需要一个统一管理的调度中心。

第一章 认识Dubbo

1.1 为什么Dubbo性能高
image.png
image.png

1.2 其他RPC框架
gRPC、Thrift、HSF

1.3 Dubbo的前世今生
image.png
image.png

第二章 Dubbo框架

2.1 dubbo概述
image.png

2.2 基本架构
摘自官网:
image.png
image.png
image.png

2.3 dubbo支持的协议
image.png
image.png

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
image.png
2)在另一个web工程创建接口的实现类
注意需要依赖1)中的jar包
image.png
3)在另一个web工程创建消费者
同样依赖1)中的jar包
image.png

该方案就是对直连方式的改造


2.6 dubbo常用标签
2.6.1 公用标签

<dubbo:application name="xx"/>
<dubbo:registry />

image.png

2.6.2 服务提供者标签
image.png

2.6.3 服务消费者
image.png

第三章 注册中心

image.png

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 关闭检查
image.png
image.png

4.3 重试次数
image.png

4.4 超时时间
image.png
一般会设置

4.5 版本号
image.png

第五章 监控中心

image.png
image.png
image.png
image.png
image.png
image.png