Dubbo+Zookeeper使用

这篇具有很好参考价值的文章主要介绍了Dubbo+Zookeeper使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

说明:Apache Dubbo 是一款 RPC 服务开发框架,用于解决微服务架构下的服务治理与通信问题,官方提供了 Java、Golang 等多语言 SDK 实现。

本文介绍Dubbo的简单使用及一些Dubbo功能特性,注册中心使用的是ZooKeeper,可在官网下载。

(另外,在阿里巴巴发出的《微服务治理技术白皮书》中各种注册中心的区别如下:)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

环境搭建

首先,搭建一个ZooKeeper + Dubbo的项目

(1)下载ZooKeeper

在上面提供的官网上下载ZooKeeper,解压到一个没有中文的路径下;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务
因为默认提供的配置文件是一个模板,解压后需要手动设置一下,将zookeeper默认的配置文件(zoo_sample.cfg)复制一份,并将文件名改为"zoo.cfg"

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

另外,修改zoo.cfg配置文件中的这行配置,默认的是Linux文件路径,修改为当前目录的上级目录(…/data);

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

启动,选择安装目录下bin文件夹下的zkServer.cmd文件,可双击启动或者在该目录下打开CMD窗口执行

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

没有报错,运行结果如下,表示启动成功

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

如果启动失败,提示此时不应有 jdk,参考:http://t.csdn.cn/52O2K

(2)创建项目

创建一个Zookper+Dubbo的项目,有两个微服务,一个用户服务(UserService),一个订单服务(OrderService),

  • 订单服务(消费者,Consumer):没有Service层,直接使用用户服务查询用户信息、用户名;

  • 用户服务(提供者,Provider):没有Controller层,提供查询用户信息、用户名的接口;

订单服务(OrderService)

Controlle层,两个接口,一个用于查找用户名,一个用于查找用户。实现暂时空着,待会儿使用Dubbo调用用户服务对应的接口

@RestController
@RequestMapping("order")
public class OrderController {

    @GetMapping("/name")
    public String getUserName(Integer id){
        return userService.getUserName(id);
    }

    @GetMapping("/user")
    public User getUser(Integer id){
        return userService.getUser(id);
    }
}
用户服务(UserService)

UserService实现类,实现两个接口,分别是查询用户名,返回固定值;查询用户,返回固定用户对象;

@Service
public class UserServiceImpl implements UserService {


    @Override
    public String getUserName(Integer id) {
        return "getUserName";
    }

    @Override
    public User getUser(Integer id) {
        User user = new User(30, "张三", "12456");
        return user;
    }
}

(3)配置

使用Dubbo前,需先导入依赖,我这里直接在父模块中添加,如下:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.hzy</groupId>
    <artifactId>user-provider</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/>
    </parent>

    <properties>
        <java.version>8</java.version>
        <spring-boot.version>2.2.1.RELEASE</spring-boot.version>
        <dubbo.version>2.7.5</dubbo.version>
        <curator.version>2.12.0</curator.version>
        <maven.compiler.source>11</maven.compiler.source>
        <maven.compiler.target>11</maven.compiler.target>
    </properties>
    
    <dependencies>
        <!--MVC框架-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>

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

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>${curator.version}</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>${curator.version}</version>
        </dependency>
    </dependencies>
</project>

设置各个服务的配置,两方面,一方面是zookeeper,一方面是dubbo的,如下:

(OrderService)

server:
  port: 8081
spring:
  application:
    name: dubbo-consumer
dubbo:
  registry:
    address: zookeeper://localhost:2181  # 连接到注册中心
  protocol:
    name: dubbo # 指定的协议
    port: 28081  # 指定的端口
  scan:
    basePackages: com.hzy.controller # 接口列表和接口中的方法列表

(UserService)

server:
  port: 8082
spring:
  application:
    name: dubbo-provider
dubbo:
  registry:
    address: zookeeper://localhost:2181  # 连接到注册中心
  protocol:
    name: dubbo # 指定的协议
    port: 28082  # 指定的端口
  scan:
    basePackages: com.hzy.controller # 接口列表和接口中的方法列表

(4)启动

依次 启动用户服务、订单服务,没有报错说明项目注册到zookeeper没有问题;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

打开zookeeper客户端,输入 ls /可查看到dubbo项,再输入ls /dubbo,可查看到注册的服务;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(5)使用

使用Dubbo非常简单,只需如下操作:

  • 第一步:修改提供者Service注解,改为Dubbo依赖提供的;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

  • 第二步:将提供者的UserService接口复制一份到消费者这边来,注意结构要平行相同

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

  • 第三步:在消费者Controller层注入(引用)UserService接口;

  • 第四步:直接调用UserService中的接口;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(6)测试

重启两个服务(注意先启动提供者),使用fastRequest测试;

(获取用户名)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(获取用户信息)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

可以看到两个接口都可以正常返回,说明zookeeper+dubbo的结合已完成;

Dubbo特性

以下介绍Dubbo中的一些特性,更多特性用法可在官网中查看;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(1)启动检查

上面一直提到,需要先启动提供者,再启动消费者,这是因为消费者服务依赖于提供者,在启动时Dubbo会进行检查,发现提供者找不到会报错,程序启动失败。

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

可在消费者这边添加如下配置,取消启动检查

# 取消消费者检查
dubbo:
  consumer:
    check: false

再次启动就没有问题了

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(2)地址缓存

地址缓存是指,消费者与提供者联系建立起来了,服务消费者会把提供者的接口地址缓存一份,此时注册中心宕机,该请求仍可以正常访问;

发送请求,没得问题;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

关闭注册中心zookeeper;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

两个服务一直在打印未知错误;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

此时,访问刚刚的那个请求,仍然可以成功;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

换个重启服务后没发过的请求,也可以访问;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(3)对象传输

使用Dubbo可以传输自定义对象,但需要注意对象需要实现序列号接口,不然会报错;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

根据经验,凡是涉及到传输对象,都需要实现序列化接口,并且最好添加全参构造、无参构造,因为有些工具,底层可能是通过对象的全参构造来帮助我们实例化对象的。

(4)连接超时

Dubbo默认设置的连接超时是1秒,即当消费者发送的请求,1秒未得到返回即为超时,这个超时是可以设置的。

在提供者这边方法内设置2秒睡眠;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

消费者发送请求,返回超时错误;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

连接超时可以在消费者、提供者设置,并且可以在接口、方法上设置,优先级是消费者大于提供者,方法大于接口,如下我在消费者(@Reference)、提供者(@Service)双方设置超时时长;

(消费者,设置1500ms)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(提供者,设置3000ms)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(重启服务,发送请求,依旧报错,说明提供者设置的超时没有起作用,超时是以消费者的1500ms为准)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(互调设置,消费者设置3000ms,提供者1500ms,重启服务可以正常访问)

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(5)重试次数

重试次数,在之前连接超时错误的信息,可以看到一个“Tried 3 times”,表示尝试了3次,默认重试2次;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

同样,这个也可以在消费者、提供者双方设置

(提供者)

// 设置重试10次
@Service(timeout = 3000, retries = 10)

(消费者)

// 设置重试5次
@Reference(timeout = 1500, retries = 5)
private UserService userService;

同样,优先级是消费者大于提供者;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

注意

需要注意哦,不是所有操作都可以设置重试次数的,应该需要考虑当前请求所对应的操作是否为幂等性操作,即执行一次或多次结果都相同,不然会造成数据混乱。以数据库的增删改查操作为例:

  • 增:每增加一条数据,数据库表都是变化的,所以为非幂等性;

  • 删:与增同理,是非幂等性;

  • 改:视情况而定,看SQL语句是怎么写的,如果是"number + 1"这样的,是非幂等性;如果是“set name = #{name} where id = #{id}”这样的,就是幂等性的;

  • 查:多次查询(没有其他操作参与)数据库表都是一样的,所以是幂等性操作;

(6)多版本

多版本是指,如果存在多个提供者、消费者时,可以指定版本信息,让提供者指服务指定的消费者,消费者指消费指定的服务者;

(消费者,不指定版本信息)

@Reference(timeout = 3000, retries = 5)
private UserService userService;

(提供者,指定版本信息“V1.0”)

@Service(timeout = 3000, retries = 10, version = "V1.0")

请求失败,提示没有可用的提供者;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

修改消费者版本号为“V1.0”;

@Reference(timeout = 3000, retries = 5,version = "V1.0")

请求访问成功;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

使用Dubbo的这种特性,可以实现灰度发布,即版本更新不是一下全部更新,而是在系统中设置多个版本,如新版本的接口设置10个,旧版本的接口设置5个,实现“缓更新,慢发布”,减少系统出现异常的风险,比如一些金融、支付类的软件。

(7)负载均衡

可使用“loadbalance”属性设置接口的负载均衡策略,支持以下四种策略:

  • RandomLoadBalance:加权随机,默认算法,默认权重相同;

  • RoundRobinLoadBalance:加权轮询,默认权重相同;

  • LeastActiveLoadBalance:最少活跃优先+加权随机,能者多劳;

  • ConsistentHashLoadBalance:一致性Hash,确定入参,确定提供者,适用于有状态的请求;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

注意使用并不是直接new它们类,而是进入到它们对应的类里面,查看它们的这行代码中写的名称

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

将该名称作为负载均衡属性的值

@Reference(loadbalance = "random")
private UserService userService;

在代码中打印一行标识,开启两个服务,发送十几条请求,可以看到两边服务均有访问,数量不等;
Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

提供者,消费者两边都可以设置,都有效;

(8)失败降级

失败降级是指访问失败时,返回一个降级方案,即“打了折扣”的响应结果,使用mock属性设置,如下:

@Reference(mock = "return 请求错误")
private UserService userService;

另外,还可以有其他几种用法:

#  调用失败,返回请求错误
mock = "return 请求错误"

# 不发起远程调用,直接返回null,不管请求成功与否,都返回null
mock = "force:return null"

# 发起远程调用,失败后返回null
mock = "fail:return null"

# 发起远程调用,失败后抛异常
mock = "throw"

# 调用失败后使用自己实现的降级方案
mock = "自定义类的全限定类名"

其中,最后一种方法最好用,搞一下


降级降级方案,实现接口就可以

public class UserServiceMock implements UserService {
    @Override
    public String getUserName(Integer id) {
        return "降级方案";
    }

    @Override
    public User getUser(Integer id) {
        return new User(-1,"降级对象","降级密码");
    }
}

mock设置为降级方案的全限定类名

    @Reference(mock = "com.hzy.mock.UserServiceMock")
    private UserService userService;

测试,连接超时,走了降级

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

(9)集群容错

使用场景(官方);多个服务器部署同一集群中,运行同一应用程序,如果一台服务器出现故障,其他服务器将接管负载,确保应用程序对用户仍然可用。

Failover Cluster(默认设置):失败自动切换,当出现失败,重试其它服务器。通常用于读操作,但重试会带来更长延迟。可通过 retries=“2” 来设置重试次数(不含第一次)。

其他配置如下:

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

使用如下:

@Reference(cluster = "failover")
private UserService userService;

同样,也是使用对应的策略,就进入到对应的类中,使用对应的名称作为属性值;

Dubbo+Zookeeper使用,dubbo,zookeeper,微服务

Nacos+Dubbo

Nacos作为注册中心Dubbo使用与ZooKeeper基本相同,在使用上,不同的地方只有以下两点:

  • 导入的依赖,配置不同;

  • 注解不同,ZooKeeper使用@Service、@Reference注解;Nacos使用@DubboService、@DubboReference注解;

总结

总结成一句话,Dubbo是替代Feign的;

另外提一句,Dubbo是使用自定义的协议,所以如果需要考虑提高Dubbo效率,可以从传输协议、对象序列化方式这些方面入手;

文中代码的GitHub地址:https://github.com/Heapfiy/dubbo-simple.git文章来源地址https://www.toymoban.com/news/detail-623569.html

到了这里,关于Dubbo+Zookeeper使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Dubbo+Zookeeper使用

    说明:Apache Dubbo 是一款 RPC 服务开发框架,用于解决微服务架构下的服务治理与通信问题,官方提供了 Java、Golang 等多语言 SDK 实现。 本文介绍Dubbo的简单使用及一些Dubbo功能特性,注册中心使用的是ZooKeeper,可在官网下载。 (另外,在阿里巴巴发出的《微服务治理技术白皮

    2024年02月14日
    浏览(35)
  • Dubbo3使用Zookeeper作为注册中心的方案讨论!详解DubboAdmin与PrettyZoo来监控服务的优劣!

    文章目录 一:Dubbo注册中心的基本使用 二:Zookeeper注册中心的使用 1:依赖引入 2:实际开发 三:Zookeeper作为注册中心的使用展示 1:启动注册Zookeeper服务 2:引入注册中心 (一):Provider (二):Consumer 3:启动服务结果展示 4:监控服务的两种手段         我们使用的和分析讲解

    2024年02月05日
    浏览(41)
  • Dubbo 3.x结合Zookeeper实现远程服务基本调用

    ZooKeeper和Dubbo是两个在分布式系统中常用的开源框架,它们可以协同工作,提供服务注册与发现、分布式协调等功能。 - 服务注册与发现: Dubbo服务提供者将自己的信息(如IP地址、端口、服务名等)注册到ZooKeeper上,作为服务的提供者。 Dubbo服务消费者从ZooKeeper上获取服务提

    2024年01月17日
    浏览(38)
  • Dubbo与Zookeeper、SpringMVC整合和使用(入门级)

    介绍就不过多的说明。可以参考http://blog.csdn.net/congcong68/article/details/41113239博客里面写的相关介绍。 后续会补充完善SpringMVC部分 微信扫一扫,支持一下我的个人微信小程序 开发工具 MyEclipse 10.7 JDK 1.7 容器 Tomcat 8(运行dubbo) zookeeper版本 zookeeper-3.4.6 dubbo dubbo-admin-2.5.3 dubbo-admin-

    2024年02月22日
    浏览(43)
  • 【rpc】Dubbo和Zookeeper结合使用,它们的作用与联系(通俗易懂,一文理解)

    目录 Dubbo是什么?         把系统模块变成分布式,有哪些好处,本来能在一台机子上运行,为什么还要远程调用 Zookeeper是什么? 它们进行配合使用时,之间的关系 服务注册 服务发现 动态地址管理         Dubbo是一种开源的高性能、轻量级的分布式服务框架,它致力

    2024年02月09日
    浏览(50)
  • SpringBoot + Dubbo + zookeeper实现

    目录 一,框架搭建 1. 启动zookeeper ! 2. IDEA创建一个空项目; 3.创建一个模块,实现服务提供者:provider-server , 选择web依赖即可 4.项目创建完毕,我们写一个服务,比如卖票的服务 编写接口 编写实现类 编写service 二,服务提供者 1,第一步  zookeeper的包我们去maven仓库下载,

    2024年04月26日
    浏览(40)
  • Spingboot整合Dubbo+zookeeper

    2023-12-26 19:38:05 最近学习分布式技术:Dubbo+zookeeper,准备写一个demo用springboot整合dubbo和zookeeper。但是看了网上一些教程都是几年前的,试着跟着写了几个demo没一个跑起来,基本是maven依赖方面的问题。 1、点击创建一个springboot项目 2、勾选web和lombok 3、创建 4、修改IDEA的Maven配置

    2024年02月04日
    浏览(49)
  • SpringBoot整合Dubbo+Zookeeper

    Dubbo概述 学习Dubbo前你要了解这些 安装zk Zookeeper概述与安装 Dubbo在zk中的存储结构 Dubbo的注册中心有哪些 1、 Multicast :Multicast 注册中心不需要启动任何中心节点,只要广播地址一样,就可以互相发现。 2、 Zookeeper 是 Apache Hadoop 的子项目,是一个树型的目录服务,支持变更推

    2024年02月04日
    浏览(43)
  • 记录 Dubbo+Zookeeper 学习Demo

    结合Dubbo官网学习如何完成SpringBoot+Dubbo+Zookeeper集成的学习,本次采用环境如下: 开发工具:IntelliJ IDEA Community Edition 2023.2.5 (IDEA社区版 2023.2.5) 开发环境:JDK 1.8,Windows 11 Dubbo 3.2.0-beta.4,SpringBoot 2.7.8, Zookeeper 3.8.4 辅助程序:dubbo-admin-develop 下载地址:https://zookeeper.apache.

    2024年03月15日
    浏览(60)
  • dubbo和zookeeper作用以及关系

    Dubbo建议使用Zookeeper作为服务的注册中心。 Zookeeper的作用: zookeeper用来注册服务和进行负载均衡,哪一个服务由哪一个机器来提供必需让调用者知道,简单来说就是ip地址和服务名称的对应关系。当然也可以 通过硬编码的方式把这种对应关系在调用方业务代码中实现,但是如

    2024年02月14日
    浏览(39)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包