Dubbo 快速掌握 这篇就够了

news2024/12/25 22:34:33

1. Dubbo概述

Dubbo 是一款高性能、轻量级的开源Java RPC框架，由阿里巴巴公司开发并在2011年开源。它主要用于解决分布式系统中服务之间的通信问题，支持多种协议，如Dubbo、HTTP、Hessian等，具有服务注册、服务发现、负载均衡、故障转移等特性。

2. Zookeeper概述（Dubbo推荐使用Zookeeper作为注册中心）

ZooKeeper 是一个开源的分布式协调服务，主要用于分布式应用中的分布式协调。它是由 Apache 软件基金会开发的一个项目，旨在解决分布式应用中的一致性问题。
 

3. 安装Zookeeper

创建一个文件夹放置zookeeper压缩文件

使用tar命令进行压缩zookeeper文件

tar -zxvf apache-zookeeper-3.5.6-bin.tar.gz

创建一个目录用于存放zookeeper的数据 例如：zkdata

zoo_sample.cfg不生效，只有zoo.cfg才生效，需要将zoo_sample.cfg拷贝一份名为zoo.cfg的文件

cp zoo_sample.cfg zoo.cfg

然后进入解压后的zookeeper的配置文件zoo.cfg，在该配置文件中修改dataDir的值为存放zookeeper用于存放数据的目录地址（例如：zkdata的地址）

修改zoo.cfg的dataDir：

4. Zookeeper的基本操作 

返回zookeeper目录

进入bin目录中，zkServer.sh是zookeeper的可执行文件

启动 zookeeper的命令：

./zkServer.sh start

 查看 zookeeper的状态：

./zkServer.sh status

停止 zookeeper的命令：

./zkServer.sh stop

5.Dubbo快速入门示例

首先启动zookeeper 

防火墙未关闭问题

如果发现该提示则表示防火墙未关闭

 关闭防火墙命令

sudo systemctl stop firewalld

（1）dubbo的生产者：

引入依赖

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.4.1</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.4.1</version>
        </dependency>

填写配置

server:
  port: 8081
dubbo:
  registry:
    address: zookeeper://192.168.92.138:2181   #自己的zookeeper服务器的IP:默认端口号
  application:
    name: producer1 #注册进去的名字
  protocol:
    name: dubbo     #设置类型
    port: -1      #因为dubbo的服务器端口号是不能唯一的，所以，设置为-1会帮我们自动改变端口号
  config-center:
    timeout: 120000  #超时时间  （毫秒）

示例 ServiceImpl

@Service //注意这里是dubbo的Service注解
public class UserServiceImpl implements IUserService {

    @Override
    public String helloWorld() {
        return "Hello World" + LocalDateTime.now();
    }
}

启动类 

@SpringBootApplication
@ServletComponentScan
@EnableDubbo(scanBasePackages = "com.example.service.service")
public class DubboServiceApplication {

    public static void main(String[] args){
        SpringApplication.run(DubboServiceApplication.class,args);
    }
}

（2）dubbo的消费者：

引入依赖

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.4.1</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.4.1</version>
        </dependency>

        <dependency>
            <groupId>com.example</groupId>
            <artifactId>dubbo-service</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

填写配置

server:
  port: 8082

dubbo:
  application:
    name: consumer1
  protocol:
    name: dubbo
    port: -1
  registry:
    address: zookeeper://192.168.92.138:2181  #默认端口号为2181
  config-center:
    timeout: 12000  #超时时间

示例 controller

@RestController
@RequestMapping("/user")
public class UserController {

    @Reference
    private IUserService userService;

    @GetMapping("/hello")
    public String getHello(){
        return userService.helloWorld();
    }

}

启动类

@SpringBootApplication
@ServletComponentScan
@EnableDubbo(scanBasePackages = "com.example.web.controller")
public class DubboWebApplication {

    public static void main(String[] args){
        SpringApplication.run(DubboWebApplication.class,args);
    }
}

 （3）测试

打开浏览器的地址：http://localhost:8082/user/hello

显示效果：

 

6.Dubbo-admin（图形化界面）

（1）首先下载node

（2）下载 Dubbo-admin

下载链接：https://github.com/apache/dubbo-admin

下载dubbo-admin 解压后我们进入…\dubbo-admin-develop\dubbo-admin-server\src\main\resources目录，找到 application.properties配置文件 进行配置修改

（3）修改该配置文件中的 zookeeper 地址：

（将127.0.0.01修改为自己的虚拟机地址）

说明：

admin.registry.address注册中心

admin.config-center 配置中心

admin.metadata-report.address元数据中心 

（4）在 dubbo-admin-develop 目录执行打包命令

mvn clean package

 （5）启动后端

切换目录到：dubbo-Admin-develop\dubbo-admin-distribution\target

打开cmd

执行下面的命令启动 dubbo-admin，dubbo-admin后台由SpringBoot构建。

java -jar .\dubbo-admin-0.1.jar

 （6）启动图形化界面

在dubbo-admin-ui 目录下执行命令

npm run dev

浏览器输入所显示的地址，用户名密码都是root

7.Dubbo高级特性

（1）设置超时和重启

  • timeout：调用超时时间，默认值1000，单位为毫秒。
  • retries：重试次数，默认值2。

（2）多版本

  • version：服务版本，用于区分同一接口的不同版本。

在生产者中的Impl里的@Service和消费者中的controller的@Reffrence的可以通过设置版本，版本必须一致生产者才能为消费者服务。

 

（3）负载均衡

负载均衡策略有四种：

  • random（随机）：随机选择一个服务提供者实例。
  • roundRobin（轮询）：按顺序轮流选择一个服务提供者实例。
  • leastRequest（最少请求）：选择请求最少的服务提供者实例。
  • consistentHash（一致性哈希）：基于一致性哈希算法选择服务提供者实例。

在生产者中的Impl里的@Service和消费者中的controller的@Reffrence的可以通过loadbalance属性设置负载均衡策略的模式

 

（4）集群容错

常见的集群容错模式：

  • failover（失败自动切换）：当出现失败情况时，重试其他服务器。通常用于读操作，但重试会带来更长延迟。可通过 retries 属性设置重试次数。

  • failfast（快速失败）：只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。

  • failback（失败自动恢复）：后台记录失败请求，定时重发。通常用于消息通知操作。

  • failsafe（失败安全）：出现异常时，直接忽略。通常用于写入审计日志等操作。

 

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

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

相关文章

基于大语言模型抽取文本中的实体和关系

基于大语言模型抽取文本中的实体和关系

在基于大语言模型图数据库存储中&#xff0c;要从文本中提取实体&#xff0c;实体属性和关系。 实体关系抽取是从文本中的句子里抽取出一对实体并给出实体间关系的任务。 该任务的输入是一句话&#xff0c;输出是一个spo三元组&#xff08;subject-predicate-object&#xff…
阅读更多...
【数据结构】TreeMap和TreeSet

【数据结构】TreeMap和TreeSet

目录 前言TreeMap实现的接口内部类常用方法 TreeSet实现的接口常用方法 前言 Map和set是一种专门用来进行搜索的容器或者数据结构&#xff0c;其搜索的效率与其具体的实例化子类有关。 一般把搜索的数据称为关键字&#xff08;Key&#xff09;&#xff0c; 和关键字对应的称为…
阅读更多...
【C#】知识汇总

【C#】知识汇总

目录 1 概述1.1 GC&#xff08;Garbage Collection&#xff09;1.1.1 为什么需要GC&#xff1f;1.1.2 GC的工作原理工作原理什么是Root&#xff1f;GC算法&#xff1a;Mark-Compact 标记压缩算法GC优化&#xff1a;Generational 分代算法 1.1.3 GC的触发时间1.1.4 如何减少垃圾…
阅读更多...
MFC核心技术探索

MFC核心技术探索

原文地址&#xff1a;李浩的博客 lihaohello.top 本文采用逐步调试的方法&#xff0c;带你一起探索MFC程序的执行流程、窗体创建、消息映射、运行时类型识别、对象动态创建这些核心机制。 相信读者在深入理解这些核心机制后&#xff0c;会由衷感叹于MFC框架实现的精妙&#xf…
阅读更多...
Outh2四种授权模式详解

Outh2四种授权模式详解

1.oauth 2.0 简介 2.各个角色介绍 3.四种模式 4.授权码模式 ①&#xff1a;获取授权码 ②&#xff1a;申请授权接口 ③&#xff1a;申请token ④&#xff1a;申请token接口 5.简单模式 6.密码模式 7.客户端模式
阅读更多...
StarRocks 存算分离 Data Cache 二三事

StarRocks 存算分离 Data Cache 二三事

前言 StarRocks 存算分离模式架构中&#xff0c;数据导入后&#xff0c;会被写入远端对象存储。而对象存储由于其访问延迟较高特性&#xff0c;如果没有任何优化&#xff0c;每次查询直接访问后端对象存储&#xff0c;那么性能就会变得非常差&#xff0c;也就失去了 StarRocks…
阅读更多...
【C#】一个项目移动了位置，或者换到其他电脑上，编译报错 Files 的值“IGEF，解决方法

【C#】一个项目移动了位置，或者换到其他电脑上，编译报错 Files 的值“IGEF，解决方法

文章目录 1 问题分析2 本文解决方法 一个项目可以正常运行编译的项目&#xff0c;所有路径均为相对路径。 移动了位置&#xff0c;或者换到其他电脑上&#xff0c;编译报错 Files 的值“IGEF&#xff0c; 1 问题分析 这个错误信息表明在处理文件时&#xff0c;Files 的值出…
阅读更多...
tiktok 搜索接口请求与翻页

tiktok 搜索接口请求与翻页

这几天有小伙伴问tk的搜索接口的问题， 一个是搜索热门接口请求返回 {“status_code”: 0}，这个使用curl_cffi的requests库改一下指纹请求就行了。 再一个就是翻页问题 细心一些比对一下翻页参数都能做到的（小伙伴以为只改个offset就完事了） 要不然你只能得到这样的结果：…
阅读更多...
JavaWeb—XML_Tomcat10_HTTP

JavaWeb—XML_Tomcat10_HTTP

一、XML XML是EXtensible MarkupLanguage的缩写&#xff0c;翻译过来就是可扩展标记语言。所以很明显&#xff0c;XML和HTML一样都是标记语言&#xff0c;也就是说它们的基本语法都是标签。 可扩展:三个字表面上的意思是XML允许自定义格式。但这不代表你可以随便写; 在XML基…
阅读更多...
极狐GitLab 如何设置访问令牌前缀？

极狐GitLab 如何设置访问令牌前缀？

极狐GitLab 是 GitLab 在中国的发行版&#xff0c;专门面向中国程序员和企业提供企业级一体化 DevOps 平台&#xff0c;用来帮助用户实现需求管理、源代码托管、CI/CD、安全合规&#xff0c;而且所有的操作都是在一个平台上进行&#xff0c;省事省心省钱。可以一键安装极狐GitL…
阅读更多...
GSON转换将Long类型转换Double导致精度丢失的问题排查

GSON转换将Long类型转换Double导致精度丢失的问题排查

问题描述 项目中同步订单时发现一个问题&#xff0c;同一条的数据&#xff0c;order_id和item_id为Long类型&#xff0c;在同步时&#xff0c;数值变了。比如原本是6930414387088791188变成了69304143870884512001。 问题排查 经过排查发现http请求的返回参数是正常的&#…
阅读更多...
树形结构数据数据查询优化过程

树形结构数据数据查询优化过程

树形结构数据统计查询优化过程 初始方案&#xff1a; 组织树数据结构如下&#xff1a; 数据请求参数&#xff1a; 原技术方案&#xff1a; public List<Map<String, List<Long>>> getSelectParam(List<DepartmentQueryDTO> departmentList, Stri…
阅读更多...
图论（二）：图的度分析——度数bar图度数等级图度数直方图根据度数渲染节点颜色

图论（二）：图的度分析——度数bar图度数等级图度数直方图根据度数渲染节点颜色

本期所用数据集&#xff0c;空手道俱乐部关系数据集&#xff1a; 数据集中共有34个节点&#xff0c;每个节点代表俱乐部中的一名成员数据集中共有78条边&#xff0c;每条边表示两名成员之间的友谊关系或社交联系常见数据集格式为GML和TXT格式&#xff0c;还可能包含其他格式的…
阅读更多...
检索增强生成算法

检索增强生成算法

检索增强生成算法&#xff08;Retrieval-Augmented Generation&#xff0c;RAG)是由Patrick Lewis等人于2020年提出的&#xff08;https://arxiv.org/pdf/2005.11401&#xff09;&#xff0c;主要用于辅助大规模语言模型&#xff08;Large Language Models, LLMs&#xff09;在…
阅读更多...
【网络】代理服务器

【网络】代理服务器

目录 正向代理 反向代理 个人主页&#xff1a;东洛的克莱斯韦克-CSDN博客 正向代理 正向代理&#xff08;Forward Proxy&#xff09;是一种常见的网络代理方式&#xff0c;它位于客户端和目标 服务器之间&#xff0c;代表客户端向目标服务器发送请求。正向代理服务器接收客户…
阅读更多...
晓北斗 - 北斗七星、北斗导航系统

晓北斗 - 北斗七星、北斗导航系统

北斗导航 北斗卫星导航 芯片、模块、天线、板卡等基础产品,是北斗系统应用的基础。通过卫星导航专项的集智攻关,我国实现了卫星导航基础产品的自主可控,形成了完整的产业链。 北斗卫星导航系统&#xff08;Beidou Navigation Satellite System&#xff0c;简称&#xff1a;BD…
阅读更多...
Effective-Java-Chapter5-泛型

Effective-Java-Chapter5-泛型

https://github.com/clxering/Effective-Java-3rd-edition-Chinese-English-bilingual/blob/dev/Chapter-5/Chapter-5-Introduction.md 准则一 不要使用原始类型 首先来看一下什么是原始类型呢&#xff1f; List 对应的原始类型是 List&#xff0c;那其实就是说不带参数化类…
阅读更多...
Selenium + Python 自动化测试13（HTML报告）

Selenium + Python 自动化测试13（HTML报告）

我们的目标是&#xff1a;按照这一套资料学习下来&#xff0c;大家可以独立完成自动化测试的任务。 上一篇我们讨论了unittest中discover 的构建&#xff0c;可以组织测试更多测试用例。 本篇文章我们接着讲。如何生成HTML报告&#xff0c;提高我们测试报告的可读性。 1、引入…
阅读更多...
IOS 01 CocoaPods 安装与使用

IOS 01 CocoaPods 安装与使用

什么是CocoaPods CocoaPods是一个依赖管理工具&#xff0c;类似Java语言的Maven&#xff0c;Gradle这样的工具&#xff1b;只是他是管理iOS&#xff0c;macOS等平台项目的依赖而已。 同类软件 Carthage&#xff0c;Swift官方提供的Swift Package Manager。 流行程度 Cocoa…
阅读更多...
若依框架将Mybatis改成MybatisPlus

若依框架将Mybatis改成MybatisPlus

1.引入MybatisPlus的maven依赖 <mybatis-plus.version>3.2.0</mybatis-plus.version> <dependencies><!-- mybatis-plus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifac…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023