SpringBoot11：分布式Dubbo、Zookeeper

news2024/11/17 13:30:36

什么是分布式系统？

建立在网络之上的软件系统，是若干个独立的计算机的集合，但是对用户来说，就像单个系统一样。可以利用更多的机器，处理更多的数据

注意：只有当单个节点不够用的时候，才需要考虑分布式

Dubbo文档

官网：入门文档 | Apache Dubbo

什么是Dubbo？一个 RPC 框架，支持多种语言

单一应用架构：

①所有功能部署在一起，适合小型网站

②缺点：难扩展、不利于协同开发和升级维护

垂直应用架构：

①将一个大应用拆成几个互不相干的小应用，来提升效率。核心是MVC

②缺点：公共模块无法重复利用

分布式服务架构：

当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务。核心是RPC（分布式服务框架）

流动计算架构：

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

什么是RPC？

RPC（Remote Procedure Call 远程过程调用）是一种通信方式。举例：同一台电脑上，a()方法调b()方法，叫本地过程调用。这台电脑上的a()方法，调另一台电脑上的b()方法，叫远程过程调用。

RPC核心：通讯、序列化

Dubbo详解

服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。

服务消费者（Consumer）：调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

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

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

安装zookeeper

什么是zookeeper？一个注册中心（服务注册与发现）

下载地址：http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.5.10/

1、下载那个带bin的压缩包

2、解压之后，在conf目录下，复制zoo_sample.cfg，粘贴到当前目录，并重命名为zoo.cfg

3、双击运行bin目录下的zkCli.cmd测试

create -e /qiu 1234       //创建一个节点/qiu的值为1234
get /qiu                  //获取/qiu这个节点的值

安装Dubbo

下载地址：GitHub - apache/dubbo-admin at master

1、选择master-0.2.0下载

 2、在dubbo-admin-master-0.2.0目录下，运行cmd

mvn clean package -Dmaven.test.skip=true

运行之后，在dubbo-admin\target目录下会有一个dubbo的jar包

 3、运行zookeeper

 4、在dubbo-admin\target目录下，使用cmd运行dubbo

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

5、在浏览器访问http://localhost:7001/        初始用户名为root，密码也为root

登录成功后，长这样：

SpringBoot整合Dubbo和Zookeeper

一、搭建框架

1、创建一个空的工程

2、创建一个叫provider-server的module（springboot 2.7.8+web依赖）

3、编写service

①service接口

public interface TicketService {
    public String getTicket();
}

②service实现类

public class TicketServiceImpl implements TicketService{
    @Override
    public String getTicket() {
        return "《丘丘说Java》";
    }
}

4、再创建一个叫consumer-server的module（springboot 2.7.8+web依赖）

5、编写一个service

public class UserService {
    //想拿到provider提供的票
}

6、更改他们的端口号

思考：这是2个不同的application，怎么样才能在consumer里面，拿到provider提供的票？

解决方式：将服务提供者注册到注册中心，在让服务消费者去注册中心消费

二、服务提供者

1、导入依赖

        <!--dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.22</version>
        </dependency>
        <!--zookeeper-->
        <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.14</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
         </dependency>

2、配置application.properties

#服务应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#哪些服务要被注册
dubbo.scan.base-packages=com.service

3、在service实现类中加上dubbo的注解，然后dubbo就会扫描指定包（com.service）下，带有@Service注解的服务，将它发布在指定的注册中心（zookeeper://127.0.0.1:2181）

4、启动ProviderService主启动类

5、启动zookeeper

6、启动dubbo：在dubbo的dubbo-admin\target目录下，运行cmd

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

7、在浏览器访问

三、服务消费者

1、导入依赖（和provider的依赖一样）

        <!--dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.22</version>
        </dependency>
        <!--zookeeper-->
        <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.14</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
         </dependency>

2、配置application.properties

#消费者去哪里拿服务需要暴露自己的名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

3、把provider的 TicketService 接口，复制到consumer

4、 继续编写service

import org.apache.dubbo.config.annotation.Reference;
@Component
public class UserService {
    //想拿到provider提供的票，需要去注册中心拿到服务
    @Reference  //引用，
    TicketService ticketService;
    public void buyTicket(){
        String ticket = ticketService.getTicket();
        System.out.println("在注册中心拿到的 ------> " + ticket);
    }
}

 

 5、编写测试类

@SpringBootTest
class ConsumerServerApplicationTests {

    @Autowired
    UserService userService;

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

}

6、运行测试类（前提：zookeeper服务已开启）

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/354567.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

杭州电子科技大学2023年MBA招生考试成绩查询和复查申请的通知

杭州电子科技大学2023年MBA招生考试成绩查询和复查申请的通知

根据往年的情况&#xff0c;2023杭州电子大学MBA考试初试成绩可能将于2月21日公布&#xff0c;最早于20号出来&#xff0c;为了广大考生可以及时查询到自己的分数&#xff0c;杭州达立易考教育为大家汇总了信息。根据教育部和浙江省教育考试院关于硕士研究生招生考试工作的统一…
阅读更多...
volatile 关键字的使用

volatile 关键字的使用

写博客的目的第一是做笔记&#xff0c;第二是在错误的基础上不断刷新认知&#xff0c;这两天会写三篇关于嵌入式容易混淆的知识点&#xff0c;有错误欢迎拍砖&#xff01; 1、volatile关键字的使用 关于volatile 关键字&#xff0c;如果你的理解仅仅是讲“是从内存直接取数据…
阅读更多...
CoreDNS

CoreDNS

目录 文章目录目录本节实战前言1、环境变量2、DNS1.DNS 解析过程2.根域名服务器3.顶级域名服务器4.权威性域名服务器5.dig 域名3、CoreDNS1.CoreDNS 扩展配置&#xff08;1&#xff09;开开启日志服务&#xff08;2&#xff09;特定域名使用自定义 DNS 服务器&#xff08;3&…
阅读更多...
K8s集群部署（二进制安装部署详细手册）

K8s集群部署（二进制安装部署详细手册）

一、简介 K8s部署主要有两种方式&#xff1a;1、Kubeadm Kubeadm是一个K8s部署工具&#xff0c;提供kubeadm init和kubeadm join&#xff0c;用于快速部署Kubernetes集群。 2、二进制 从github下载发行版的二进制包&#xff0c;手动部署每个组件&#xff0c;组成Kubernetes集群…
阅读更多...
SSM项目搭建保姆级教程

SSM项目搭建保姆级教程

文章目录1、什么是SSM框架1.1、持久层1.2、业务层1.3、表现层1.4、View层1.5、SpringMVC执行流程1.6、MyBatis2、SSM实战搭建2.1、创建工程2.2、添加依赖2.3、配置spring.xml文件2.4、配置web.xml文件2.5、log4j.properties2.6、准备表2.7、实体类2.8、mapper2.9、service2.10、…
阅读更多...
GuLi商城-SpringCloud-OpenFeign测试远程调用

GuLi商城-SpringCloud-OpenFeign测试远程调用

1. Feign 简介 Feign 是一个声明式的 HTTP 客户端&#xff0c;它的目的就是让远程调用更加简单。Feign 提供了HTTP请 求的模板&#xff0c;通过编写简单的接口和插入注解&#xff0c;就可以定义好 HTTP 请求的参数、格式、地址等信 息。Feign 整合了 Ribbon&#xff08;负载…
阅读更多...
操作系统 二（进程管理）

操作系统 二（进程管理）

一、进程的定义及特征进程的定义由程序、数据、进程控制块三部分组成为了使程序可以并发执行&#xff0c;且可以对并发执行的程序加以描述和控制。不同角度的定义&#xff1a;进程是程序的一次执行&#xff1b;进程是一个程序及其数据在处理机上顺序执行时所发生的活动&#xf…
阅读更多...
IDEA Maven Helper插件（详细使用教程）

IDEA Maven Helper插件（详细使用教程）

一、引言 在写Java代码的时候&#xff0c;我们可能会出现Jar包的冲突的问题&#xff0c;这时候就需要我们去解决依赖冲突了&#xff0c;而解决依赖冲突就需要先找到是那些依赖发生了冲突&#xff0c;当项目比较小的时候&#xff0c;还比较依靠IEDA的【Diagrams】查看依赖关系&…
阅读更多...
dom基本操作

dom基本操作

1、style修改样式 基本语法&#xff1a; 元素.style.样式’值‘ 注意: 1.修改样式通过style属性引出 2.如果属性有-连接符&#xff0c;需要转换为小驼峰命名法 3.赋值的时候&#xff0c;需要的时候不要忘记加css单位 4.后面的值必须是字符串 <div></div> // 1、…
阅读更多...
《Hadoop篇》------HDFS与MapReduce

《Hadoop篇》------HDFS与MapReduce

目录 一、HDFS角色职责总结 二、CheckPoint机制 三、Mapreduce序列化 四、Mapper 4.1、官方介绍 4.2、Split计算 4.3、Split和block对应关系 4.4、启发式算法 五、MapTask整体的流程 六、压缩算法 6.1、压缩算法适用场景 6.2、压缩算法选择 6.2.1、Gzip压缩 6.2…
阅读更多...
独家 | ChatGPT提高你日常工作的五个特点以及如何使用它来提高代码质量

独家 | ChatGPT提高你日常工作的五个特点以及如何使用它来提高代码质量

翻译&#xff1a;陈超 校对&#xff1a;赵茹萱本文约3200字&#xff0c;建议阅读8分钟 本文介绍了ChatGPT提高日常工作的五个特点。ChatGPT已经完全改变了代码开发模式。然而&#xff0c;大多数软件开发者和数据专家们仍然不使用ChatGPT来完善——并简化他们的工作。这就是我们…
阅读更多...
【Python】缺失值可视化工具库：missingno

【Python】缺失值可视化工具库：missingno

文章目录一、前言二、下载二、使用介绍2.1 绘制缺失值条形图2.2 绘制缺失值热力图2.3 缺失值树状图三、参考资料一、前言 在我们进行机器学习或者深度学习的时候&#xff0c;我们经常会遇到需要处理数据集缺失值的情况&#xff0c;那么如何可视化数据集的缺失情况呢&#xff1…
阅读更多...
MSR寄存器访问

MSR寄存器访问

1.介绍 MSR是CPU的一组64位寄存器&#xff0c;每个MSR都有它的地址值&#xff08;如下图所示&#xff09;&#xff0c;可以分别通过RDMSR 和WRMSR 两条指令进行读和写的操作。 如图中为8个P-state寄存器&#xff0c;地址分别为0xC001 0064 ~ 0xC001 006B&#xff0c;每个寄存…
阅读更多...
FyListen 在 MVP 架构中的内存优化表现

FyListen 在 MVP 架构中的内存优化表现

FyListen 在 MVP 中的内存优化表现 本文只是分享个人开源框架的内存优化测试&#xff0c;你可以直接跳到最后&#xff0c;参考内存泄漏的分析过程&#xff01; 项目地址&#xff1a; https://github.com/StudyNoteOfTu/fylisten2-alpha1 由于使用到 AOP&#xff0c;所以直接…
阅读更多...
【嵌入式开发】microcom安装与使用

【嵌入式开发】microcom安装与使用

microcom安装与使用1.安装2.使用3.用法4.测试三级目录1.安装 sudo apt-get install microcom -yQ&#xff1a;报错E: 在更改保留软件包的同时使用了 -y 选项&#xff0c;但没有搭配 --allow-change-held-packages. A&#xff1a;sudo apt-get install microcom -y --allow-cha…
阅读更多...
软件测试面试复述，想知道你面试不过的原因吗？

软件测试面试复述，想知道你面试不过的原因吗？

最近有机会做一些面试工作&#xff0c;主要负责面试软件测试人员招聘的技术面试。 之前一直是应聘者的角色&#xff0c;经历了不少次的面试之后&#xff0c;多少也积累一点面试的经验&#xff0c;现在发生了角色转变。初次的面试就碰到个工作年限比我长的&#xff0c;也没有时…
阅读更多...
PowerShell Install Office 2021 Pro Plus Viso Professional

PowerShell Install Office 2021 Pro Plus Viso Professional

前言 微软Office在很长一段时间内都是最常用和最受欢迎的软件。从小型创业公司到大公司，它的使用比例相当。它可以很容易地从微软的官方网站下载。但是，微软只提供安装程序，而不提供完整的软件供下载。这些安装文件通常比较小。下载并运行后，安装的文件将从后端服务器安装M…
阅读更多...
5.1配置IBGP和EBGP

5.1配置IBGP和EBGP

5.2.1实验1&#xff1a;配置IBGP和EBGP 实验目的 熟悉IBGP和EBGP的应用场景掌握IBGP和EBGP的配置方法 实验拓扑 实验拓扑如图5-1所示&#xff1a; 图5-1&#xff1a;配置IBGP和EBGP 实验步骤 IP地址的配置 R1的配置 <Huawei>system-view Enter system view, return …
阅读更多...
Python每日一练(20230218)

Python每日一练(20230218)

目录​​​​​​​ 1. 旋转图像 2. 解码方法 3. 二叉树最大路径和 1. 旋转图像 给定一个 n n 的二维矩阵 matrix 表示一个图像。请你将图像顺时针旋转 90 度。 你必须在原地旋转图像&#xff0c;这意味着你需要直接修改输入的二维矩阵。请不要 使用另一个矩阵来旋转图像…
阅读更多...
[LeetCode 1237]找出给定方程的正整数解

[LeetCode 1237]找出给定方程的正整数解

题目描述 题目链接&#xff1a;[LeetCode 1237]找出给定方程的正整数解 给你一个函数 f(x, y) 和一个目标结果 z&#xff0c;函数公式未知&#xff0c;请你计算方程 f(x,y) z 所有可能的正整数 数对 x 和 y。满足条件的结果数对可以按任意顺序返回。 尽管函数的具体式子未知…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023