Dubbo + Zookeeper 原理以及在SpringBoot中实现Dubbo提供者和消费者案例

转x33g5p2x  于2022-05-13 转载在 Zookeeper  
字(5.8k)|赞(0)|评价(0)|浏览(763)

Dubbo

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

单一应用架构

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

适用于小型网站，小型管理系统，将所有功能都部署到一个功能里，简单易用。
缺点：

  1. 性能扩展比较难
  2. 协同开发问题
  3. 不利于升级维护

垂直应用架构

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

通过切分业务来实现各个模块独立部署，降低了维护和部署的难度，团队各司其职更易管理，性能扩展也更方便，更有真针对性。
缺点： 公用模块无法重复利用，开发性的浪费

分布式服务架构

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

流动计算框架

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

RPC

什么是RPC

RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。比如两个不同的服务 A、B 部署在两台不同的机器上，那么服务 A 如果想要调用服务 B 中的某个方法该怎么办呢？使用 HTTP请求 当然可以，但是可能会比较慢而且一些优化做的并不好。 RPC 的出现就是为了解决这个问题。
通俗理解：比如两个springbootA项目和springbootB项目，springbootA是client，springbootB是Service，然后springbootA调用springbootB服务方法。
RPC基本原理

步骤解析：

RPC两个核心模块：通讯、序列化。

Zookeeper安装

window系统可以使用linux的zookeeper，zookeeper安装解压后进入到bin目录下运行zkServer.cmd会报一个错误，我们只需要到conf目录下将zoo_sample.cfg复制一份再粘贴在当前目录下重命名为zoo.cfg即可

Dubbo安装

下载地址：https://github.com/apache/dubbo-admin/tree/master

生成jar包
在项目目录下打包dubbo-admin

执行以下命令：
mvn clean package-Dmaven.test.skip=true

打包成功后在项目的target里生成jar包

先开启zkService.cmd服务

运行dubbo的jar包

启动成功后，访问127.0.0.1:7001地址

登录账号密码都是root，登录成功会显示下面的界面。

dubbo+zookeeper代码实现

创建springboot项目1，提供者（provider-service）

1、导入依赖

  1. <!--  导入依赖：dubbo + zookeeper  -->
  2.         <dependency>
  3.             <groupId>org.apache.dubbo</groupId>
  4.             <artifactId>dubbo-spring-boot-starter</artifactId>
  5.             <version>2.7.3</version>
  6.             <exclusions>
  7.                 <exclusion>
  8.                     <artifactId>org.apache.dubbo</artifactId>
  9.                     <groupId>dubbo</groupId>
  10.                 </exclusion>
  11.             </exclusions>
  13.         </dependency>
  14.         <!--  zkclient  -->
  15.         <dependency>
  16.             <groupId>com.github.sgroschupf</groupId>
  17.             <artifactId>zkclient</artifactId>
  18.             <version>0.1</version>
  19.         </dependency>
  20.         <!--日志会冲突-->
  21.         <!--引入zookeeper-->
  22.         <dependency>
  23.             <groupId>org.apache.curator</groupId>
  24.             <artifactId>curator-framework</artifactId>
  25.             <version>2.12.0</version>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.apache.curator</groupId>
  29.             <artifactId>curator-recipes</artifactId>
  30.             <version>2.12.0</version>
  31.         </dependency>
  33.         <dependency>
  34.             <groupId>org.apache.zookeeper</groupId>
  35.             <artifactId>zookeeper</artifactId>
  36.             <version>3.4.6</version>
  37.             <!--排除这个slf4j-log4j12-->
  38.             <exclusions>
  39.                 <exclusion>
  40.                     <groupId>org.slf4j</groupId>
  41.                     <artifactId>slf4j-log4j12</artifactId>
  42.                 </exclusion>
  43.             </exclusions>
  44.         </dependency>

2、编写application.properties

  1. # 应用服务 WEB 访问端口
  2. server.port=8081
  3. # 应用名称
  4. dubbo.application.name=provider-service
  5. # 注册中心地址
  6. dubbo.registry.address=zookeeper://127.0.0.1:2181
  7. # 哪些服务要被注册
  8. dubbo.scan.base-packages=com.ckm.service

3、编写service

接口

  1. package com.ckm.service;
  3. public interface TicketService {
  4.     String getTicket();
  5. }

实现类

  1. package com.ckm.service;
  3. import org.apache.dubbo.config.annotation.Service;
  4. import org.springframework.stereotype.Component;
  6. @Service //项目一启动就自动注册到注册中心！
  7. @Component //或者使用spring的Service
  8. public class TicketServiceImpl implements TicketService{
  10.     @Override
  11.     public String getTicket() {
  12.         return "hello TicketService func！";
  13.     }
  14. }

创建springboot项目2，消费者（consumer-service）

1、导入依赖

  1. <!--  导入依赖：dubbo + zookeeper  -->
  2.         <dependency>
  3.             <groupId>org.apache.dubbo</groupId>
  4.             <artifactId>dubbo-spring-boot-starter</artifactId>
  5.             <version>2.7.3</version>
  6.             <exclusions>
  7.                 <exclusion>
  8.                     <artifactId>org.apache.dubbo</artifactId>
  9.                     <groupId>dubbo</groupId>
  10.                 </exclusion>
  11.             </exclusions>
  13.         </dependency>
  14.         <!--  zkclient  -->
  15.         <dependency>
  16.             <groupId>com.github.sgroschupf</groupId>
  17.             <artifactId>zkclient</artifactId>
  18.             <version>0.1</version>
  19.         </dependency>
  20.         <!--日志会冲突-->
  21.         <!--引入zookeeper-->
  22.         <dependency>
  23.             <groupId>org.apache.curator</groupId>
  24.             <artifactId>curator-framework</artifactId>
  25.             <version>2.12.0</version>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.apache.curator</groupId>
  29.             <artifactId>curator-recipes</artifactId>
  30.             <version>2.12.0</version>
  31.         </dependency>
  33.         <dependency>
  34.             <groupId>org.apache.zookeeper</groupId>
  35.             <artifactId>zookeeper</artifactId>
  36.             <version>3.4.6</version>
  37.             <!--排除这个slf4j-log4j12-->
  38.             <exclusions>
  39.                 <exclusion>
  40.                     <groupId>org.slf4j</groupId>
  41.                     <artifactId>slf4j-log4j12</artifactId>
  42.                 </exclusion>
  43.             </exclusions>
  44.         </dependency>

2、编写application.properties

  1. # 应用服务 WEB 访问端口
  2. server.port=8082
  3. # 应用名称 --- 消费者取哪里拿服务需要暴露自己的名字
  4. dubbo.application.name=consumer-service
  5. #注册中心的地址
  6. dubbo.registry.address=zookeeper://127.0.0.1:2181

3、编写service
引用提供者可以使用pom坐标，也可以定义路径相同的接口，这里使用路径相同的接口！

相同的接口TicketService

  1. package com.ckm.service;
  3. public interface TicketService {
  4.     String getTicket();
  5. }

引用类

  1. package com.ckm.service;
  3. import org.apache.dubbo.config.annotation.Reference;
  4. import org.springframework.stereotype.Service;
  6. @Service //或者使用@Component
  7. public class UserService {
  9.     //拿到provider-service提供的票
  10.     @Reference //dubbo  --  引用  （可以pom坐标，也可以定义路径相同的接口！！！）
  11.     TicketService ticketService;
  13.     public void buyTicket(){
  14.         String ticket = ticketService.getTicket();
  15.         System.out.println(ticket);
  16.     }
  18. }

启动provider-service项目（ProviderServiceApplication运行）
启动zookeeper lib目录下的zkServer.cmd
启动dubbo生成的jar包dubbo-admin-0.0.1-SNAPSHOT.jar

在consumer-service消费者项目中编写单元测试

  1. package com.ckm;
  3. import com.ckm.service.UserService;
  4. import org.junit.jupiter.api.Test;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.boot.test.context.SpringBootTest;
  8. @SpringBootTest
  9. class ConsumerServiceApplicationTests {
  11.     @Autowired
  12.     UserService userService;
  14.     @Test
  15.     void contextLoads() {
  16.         userService.buyTicket();
  17.     }
  18. }

运行结果

整个项目目录结构图

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_44912902/article/details/124705065

内容来源于网络，如有侵权，请联系作者删除！

Javazookeeperspring学习笔记

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com