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

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

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、导入依赖

<!--  导入依赖：dubbo + zookeeper  -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
            <exclusions>
                <exclusion>
                    <artifactId>org.apache.dubbo</artifactId>
                    <groupId>dubbo</groupId>
                </exclusion>
            </exclusions>

        </dependency>
        <!--  zkclient  -->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--日志会冲突-->
        <!--引入zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

2、编写application.properties

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

3、编写service

接口

package com.ckm.service;

public interface TicketService {
    String getTicket();
}

实现类

package com.ckm.service;

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Service //项目一启动就自动注册到注册中心！
@Component //或者使用spring的Service
public class TicketServiceImpl implements TicketService{

    @Override
    public String getTicket() {
        return "hello TicketService func！";
    }
}

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

1、导入依赖

<!--  导入依赖：dubbo + zookeeper  -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
            <exclusions>
                <exclusion>
                    <artifactId>org.apache.dubbo</artifactId>
                    <groupId>dubbo</groupId>
                </exclusion>
            </exclusions>

        </dependency>
        <!--  zkclient  -->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--日志会冲突-->
        <!--引入zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

2、编写application.properties

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

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

相同的接口TicketService

package com.ckm.service;

public interface TicketService {
    String getTicket();
}

引用类

package com.ckm.service;

import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service //或者使用@Component
public class UserService {

    //拿到provider-service提供的票
    @Reference //dubbo  --  引用  （可以pom坐标，也可以定义路径相同的接口！！！）
    TicketService ticketService;

    public void buyTicket(){
        String ticket = ticketService.getTicket();
        System.out.println(ticket);
    }

}

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

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

package com.ckm;

import com.ckm.service.UserService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ConsumerServiceApplicationTests {

    @Autowired
    UserService userService;

    @Test
    void contextLoads() {
        userService.buyTicket();
    }
}

运行结果

整个项目目录结构图

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

原文链接 : 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