Dubbo 2.7.7 学习笔记 1

Dubbo 2.7.7 起步入门学习笔记

本文档基于 Dubbo 中文官方文档编写，详情请参见 Dubbo 中文官方文档

Dubbo 产生的背景

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。

image

单一应用架构

当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架 (ORM) 是关键。

垂直应用架构

当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，提升效率的方法之一是将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的 Web 框架 (MVC) 是关键。

分布式服务架构

当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架 (RPC) 是关键。

流动计算架构

当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心 (SOA) 是关键。

Dubbo 的架构

dubbo-architucture

各节点的说明

节点 角色说明
Provider 暴露服务的服务提供方
Consumer 调用远程服务的服务消费方
Registry 服务注册与发现的注册中心
Monitor 统计服务的调用次数和调用时间的监控中心
Container 服务运行容器

调用关系说明

  1. 服务容器负责启动，加载，运行服务提供者。

  2. 服务提供者在启动时，向注册中心注册自己提供的服务。

  3. 服务消费者在启动时，向注册中心订阅自己所需的服务。

  4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

  5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

  6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo 架构具有以下几个特点

Dubbo架构所拥有的特点分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。

连通性

  • 注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小
  • 监控中心负责统计各服务调用次数，调用时间等，统计先在内存汇总后每分钟一次发送到监控中心服务器，并以报表展示
  • 服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销
  • 服务消费者向注册中心获取服务提供者地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销
  • 注册中心，服务提供者，服务消费者三者之间均为长连接，监控中心除外
  • 注册中心通过长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者
  • 注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在本地缓存了提供者列表
  • 注册中心和监控中心都是可选的，服务消费者可以直连服务提供者

健壮性

  • 监控中心宕掉不影响使用，只是丢失部分采样数据
  • 数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务
  • 注册中心对等集群，任意一台宕掉后，将自动切换到另一台
  • 注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯
  • 服务提供者无状态，任意一台宕掉后，不影响使用
  • 服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复

伸缩性

  • 注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心
  • 服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者

Dubbo 前期准备

Zookeeper 安装

  1. zookeeper的 windows 安装

  2. 配置 zookeeper配置文件

    • 打开 conf目录下将 zoo_sample.cfg 配置文件复制并重命名为 zoo.cfg 配置文件
    • 修改配置文件
    # AdminServer 占用了 8080 端口，将其改用为9999
admin.serverPort=9999
# 这里原来是 Linux 中的路径显示，改为 window 路径并且需要手动创建 tmp_data 文件夹
dataDir=../tmp_data

  3. 运行 zookeeper服务器

    • 在 bin目录下通过命令启动 zookeeper服务
    xxx\zookeeper\apache-zookeeper-3.6.2-bin\apache-zookeeper-3.6.2-bin\bin> zkServer.cmd

  4. 运行 zookeeper客户端

    • 在 bin目录下通过命令启动 zookeeper客户端
    xxx\zookeeper\apache-zookeeper-3.6.2-bin\apache-zookeeper-3.6.2-bin\bin> zkCli.cmd
    • 启动后输入命令显示如下表示成功
    image

dubbo-admin 安装

  1. 下载 dubbo-admin

  2. 修改 dubbo-admin-server 配置文件

    • 进入 dubbo-admin 的 dubbo-admin-server 目录中
    cd dubbo-admin/dubbo-admin-server
    • 修改 dubbo-admin-server\src\main\resources\application.properties 配置文件
    # centers in dubbo2.7
admin.registry.address=zookeeper://127.0.0.1:2181
admin.config-center=zookeeper://127.0.0.1:2181
admin.metadata-report.address=zookeeper://127.0.0.1:2181

  3. 将 dubbo-admin-server 进行打包

    • 使用 maven进行打包：mvn clean package

  4. 启动 dubbo-admin-server

    • 进入生成的 target目录中，运行启动后台

      java -jar dubboxxx.jar

  5. 启动 dubbo-admin-ui

    • 由于 dubbo-admin 是一个前后端分离的项目，所以还需要启动前端项目

    • 需要提前安装 node.js 才可以使用 npm 命令来运行程序

      > npm install
> npm run dev

  6. 在 http://localhost:8082 中便可查看运行界面

    • 默认账户密码均为：root

Dubbo 入门案例

使用 XML 启动 Dubbo 案例

  1. 项目目录结构如下

    image

  1. Maven 核心配置文件如下

    <properties>
    <!-- 定义 dubbo 的版本 -->
    <dubbo.version>2.7.8</dubbo.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
        <version>${dubbo.version}</version>
    </dependency>
    <!-- 使用 zookeeper 作为注册中心-->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <version>${dubbo.version}</version>
        <type>pom</type>
    </dependency>
</dependencies>

  2. 在 dubbo-demo-xml-interface 中创建公共接口

    package com.study;
/**
 * 创建公共接口<p>
 * @author DeadBoty
 * @since 2020/10/23 16:22
 */
public interface DemoService {
    String sayHello(String name);
}

  3. 在 dubbo-demo-xml-provider 中创建接口实现类

    • 在 pom.xml 中添加 dubbo-demo-xml-interface 的依赖
    <dependencies>
    <dependency>
        <groupId>com.study</groupId>
        <artifactId>dubbo-demo-xml-interface</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
</dependencies>
    • 创建配置文件：provider.xml 
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="dubbo-demo-hello"  />

    <!-- 使用 zookeeper 广播注册中心暴露服务地址 -->
    <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181" /> -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" />

    <!-- 用 dubbo 协议在 20880 端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.study.DemoService" ref="demoService" />

    <!-- 和本地 bean 一样实现服务 -->
    <bean id="demoService" class="com.study.DemoServiceImpl" />
</beans>
    • 编写接口实现类
    package com.study;
/**
 * 公共接口实现类<p>
 * @author DeadBoty
 * @since 2020/10/23 17:17
 */
public class DemoServiceImpl implements DemoService {
    @Override
    public String sayHello(String name) {
        return "Hello, " + name;
    }
}
    • 编写启动方法
    package com.study;

/**
 * 服务提供方启动<p>
 * @author DeadBoty
 * @since 2020/10/23 17:21
 */
public class Provider {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("provider.xml");
        applicationContext.start();
        // 输入一个字符退出
        System.in.read();
    }
}
    • 在 dubbo-admin 的可视化中可以看到服务提供方
    image

  4. 在 dubbo-demo-xml-consumer 中实现服务的调用

    • 在 pom.xml 中添加 dubbo-demo-xml-interface 的依赖
    <dependencies>
    <dependency>
        <groupId>com.study</groupId>
        <artifactId>dubbo-demo-xml-interface</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
</dependencies>
    • 创建配置文件：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://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <dubbo:application name="consumer-of-hello-app"  />
    
    <!-- 使用 zookeeper 广播注册中心暴露发现服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    
    <!-- 生成远程服务代理，可以和本地 bean 一样使用 demoService -->
    <dubbo:reference id="demoService" interface="com.study.DemoService" />
    
</beans>
    • 编写服务消费启动
    package com.study;

/**
 * 服务消费方启动类<p>
 * @author DeadBoty
 * @since 2020/10/23 17:34
 */
public class Consumer {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
        DemoService demoService = applicationContext.getBean("demoService", DemoService.class);
        System.out.println(demoService.sayHello("法外狂徒张三"));
    }
}
    • 服务消费与提供方的关系
image

基于注解开发

Spring 的注解开发和 Spring Boot 相似，所以这里直接使用 Spring Boot 进行注解的开发

  1. 项目目录结构如下

    image

  2. Maven 中各部分的配置

    • dubbo-demo-annotation 的 pom.xml
    <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.4.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>

<dependencies>
   <!-- Dubbo Spring Boot Starter -->
   <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.7.7</version>
   </dependency>

   <!-- dubbo 依赖 -->
   <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.7.7</version>
   </dependency>

   <!-- 导入 curator 分布式协调服务 -->
   <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-framework</artifactId>
      <version>4.0.1</version>
   </dependency>

   <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-recipes</artifactId>
      <version>4.0.1</version>
   </dependency>

   <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter</artifactId>
   </dependency>

   <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
      <exclusions>
         <exclusion>
            <groupId>org.junit.vintage</groupId>
            <artifactId>junit-vintage-engine</artifactId>
         </exclusion>
      </exclusions>
   </dependency>
</dependencies>
    • dubbo-demo-provider 的 pom.xml
    <parent>
    <artifactId>dubbo-demo-annotation</artifactId>
    <groupId>com.study</groupId>
    <version>1.0-SNAPSHOT</version>
</parent>
<dependencies>
    <!-- 导入 Spring Web 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>com.study</groupId>
        <artifactId>dubbo-demo-interface</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
</dependencies>
    • dubbo-demo-consumer 的 pom.xml
    <parent>
    <artifactId>dubbo-demo-annotation</artifactId>
    <groupId>com.study</groupId>
    <version>1.0-SNAPSHOT</version>
</parent>
<dependencies>
    <!-- 导入 Spring Web 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>com.study</groupId>
        <artifactId>dubbo-demo-interface</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>

</dependencies>

  3. 在 dubbo-demo-interface 创建公共接口

    package com.study;

/**
 * 创建公共接口<p>
 * @author DeadBoty
 * @since 2020/10/23 16:22
 */
public interface DemoService {
    String sayHello(String name);
}

  4. 在 dubbo-demo-provider 中创建接口实现类

    • dubbo 的配置文件： application.yml 
    # 定义端口号
server:
  port: 8181
# 定义 dubbo 相关配置
dubbo:
  application:
    name: annotation-demo-provider
  protocol:
    name: dubbo
    port: 20880
  registry:
    protocol: zookeeper
    address: 127.0.0.1:2181
    • 接口实现类
    package com.study.service;

/**
 * 公共接口的具体实现<p>
 * @author DeadBoty
 * @since 2020/10/25 14:59
 */
@Service
// 需要提供的服务
@DubboService
public class DemoServiceImpl implements DemoService {

    @Override
    public String sayHello(String name) {
        return "你好~~~ " + name;
    }

}
    • 启动类
    package com.study;

/**
 * Spring Boot 启动类<p>
 * @author DeadBoty
 * @since 2020/10/25 14:53
 */
@SpringBootApplication
// 启动 Dubbo 的注解
@EnableDubbo
public class ProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}

  5. 在 dubbo-demo-consumer 中实现服务的调用

    • dubbo 的配置
    server:
  port: 8182
dubbo:
  application:
    name: annotation-demo-consumer
  registry:
    protocol: zookeeper
    address: 127.0.0.1:2181
    • 远程调用服务
    package com.study.controller;

/**
 * 服务消费调用<p>
 * @author DeadBoty
 * @since 2020/10/25 14:59
 */
@RestController
@RequestMapping("/demo")
public class DemoController {
    // 使用 @DubboReference 来实现远程方法引用服务
    @DubboReference
    DemoService demoService;

    @GetMapping("/{name}")
    public String sayHello(@PathVariable String name) throws JsonProcessingException {
        ObjectMapper mapper = new ObjectMapper();
        // 返回了 Json 数据
        return mapper.writeValueAsString(demoService.sayHello(name));
    }
}
    • 启动类
    package com.study;

/**
 * 服务消费端启动类<p>
 * @author DeadBoty
 * @since 2020/10/25 14:42
 */
@SpringBootApplication
@EnableDubbo
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

  6. 启动服务后调用方法 http://localhost:8182/demo/%E6%B3%95%E5%A4%96%E7%8B%82%E5%BE%92%E5%BC%A0%E4%B8%89

    • 结果如下：
    image
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 203,271评论 5赞 476
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,275评论 2赞 380
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 150,151评论 0赞 336
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,550评论 1赞 273
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,553评论 5赞 365
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,559评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,924评论 3赞 395
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,580评论 0赞 257
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,826评论 1赞 297
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,578评论 2赞 320
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,661评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,363评论 4赞 318
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,940评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,926评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,156评论 1赞 259
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,872评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,391评论 2赞 342