}
@Override
public User getUser(Integer id) {
User user = new User(30, "张三", "12456");
return user;
}
}
#### （3）配置
使用Dubbo前，需先导入依赖，我这里直接在父模块中添加，如下：
4.0.0
<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>
设置各个服务的配置，两方面，一方面是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没有问题；
打开zookeeper客户端，输入 `ls /`可查看到dubbo项，再输入`ls /dubbo`，可查看到注册的服务；
#### （5）使用
使用Dubbo非常简单，只需如下操作：
* 第一步：修改提供者Service注解，改为Dubbo依赖提供的；
* 第二步：将提供者的UserService接口复制一份到消费者这边来，**注意结构要平行相同**；
*
* 第三步：在消费者Controller层注入（引用）UserService接口；
* 第四步：直接调用UserService中的接口；
#### （6）测试
重启两个服务（注意先启动提供者），使用fastRequest测试；
（获取用户名）
（获取用户信息）
可以看到两个接口都可以正常返回，说明zookeeper+dubbo的结合已完成；
### Dubbo特性
以下介绍Dubbo中的一些特性，更多特性用法可在[官网]( )中查看；
#### （1）启动检查
上面一直提到，需要先启动提供者，再启动消费者，这是因为消费者服务依赖于提供者，在启动时Dubbo会进行检查，发现提供者找不到会报错，程序启动失败。
可在消费者这边添加如下配置，取消启动检查
取消消费者检查
dubbo:
consumer:
check: false
再次启动就没有问题了
#### （2）地址缓存
地址缓存是指，消费者与提供者联系建立起来了，服务消费者会把提供者的接口地址缓存一份，此时注册中心宕机，该请求仍可以正常访问；
发送请求，没得问题；
关闭注册中心zookeeper；
两个服务一直在打印未知错误；
此时，访问刚刚的那个请求，仍然可以成功；
换个重启服务后没发过的请求，也可以访问；
#### （3）对象传输
使用Dubbo可以传输自定义对象，但需要注意对象需要实现序列号接口，不然会报错；
根据经验，凡是涉及到传输对象，都需要实现序列化接口，并且最好添加全参构造、无参构造，因为有些工具，底层可能是通过对象的全参构造来帮助我们实例化对象的。
#### （4）连接超时
Dubbo默认设置的连接超时是1秒，即当消费者发送的请求，1秒未得到返回即为超时，这个超时是可以设置的。
在提供者这边方法内设置2秒睡眠；
消费者发送请求，返回超时错误；
连接超时可以在消费者、提供者设置，并且可以在接口、方法上设置，**优先级是消费者大于提供者，方法大于接口**，如下我在消费者（@Reference）、提供者（@Service）双方设置超时时长；
（消费者，设置1500ms）
（提供者，设置3000ms）
（重启服务，发送请求，依旧报错，说明提供者设置的超时没有起作用，超时是以消费者的1500ms为准）
（互调设置，消费者设置3000ms，提供者1500ms，重启服务可以正常访问）
#### （5）重试次数
重试次数，在之前连接超时错误的信息，可以看到一个“Tried 3 times”，表示尝试了3次，默认重试2次；
同样，这个也可以在消费者、提供者双方设置
（提供者）
// 设置重试10次
@Service(timeout = 3000, retries = 10)
（消费者）
// 设置重试5次
@Reference(timeout = 1500, retries = 5)
private UserService userService;
同样，优先级是消费者大于提供者；
##### 注意
需要注意哦，不是所有操作都可以设置重试次数的，应该需要考虑当前请求所对应的操作是否为幂等性操作，即执行一次或多次结果都相同，不然会造成数据混乱。以数据库的增删改查操作为例：
* 增：每增加一条数据，数据库表都是变化的，所以为非幂等性；
* 删：与增同理，是非幂等性；
* 改：视情况而定，看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”)
请求失败，提示没有可用的提供者；
修改消费者版本号为“V1.0”；
@Reference(timeout = 3000, retries = 5,version = “V1.0”)
请求访问成功；
使用Dubbo的这种特性，可以实现灰度发布，即版本更新不是一下全部更新，而是在系统中设置多个版本，如新版本的接口设置10个，旧版本的接口设置5个，实现“缓更新，慢发布”，减少系统出现异常的风险，比如一些金融、支付类的软件。
#### （7）负载均衡
可使用“loadbalance”属性设置接口的负载均衡策略，支持以下四种策略：
* RandomLoadBalance：加权随机，默认算法，默认权重相同；
* RoundRobinLoadBalance：加权轮询，默认权重相同；
* LeastActiveLoadBalance：最少活跃优先+加权随机，能者多劳；
* ConsistentHashLoadBalance：一致性Hash，确定入参，确定提供者，适用于有状态的请求；
注意使用并不是直接new它们类，而是进入到它们对应的类里面，查看它们的这行代码中写的名称
将该名称作为负载均衡属性的值
@Reference(loadbalance = “random”)
private UserService userService;
在代码中打印一行标识，开启两个服务，发送十几条请求，可以看到两边服务均有访问，数量不等；
提供者，消费者两边都可以设置，都有效；
#### （8）失败降级
失败降级是指访问失败时，返回一个降级方案，即“打了折扣”的响应结果，使用mock属性设置，如下：
@Reference(mock = “return 请求错误”)
private UserService userService;
另外，还可以有其他几种用法：
调用失败，返回请求错误
mock = “return 请求错误”
不发起远程调用，直接返回null，不管请求成功与否，都返回null
mock = “force:return null”
发起远程调用，失败后返回null
mock = “fail:return null”
发起远程调用，失败后抛异常
mock = “throw”
调用失败后使用自己实现的降级方案
mock = “自定义类的全限定类名”
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数大数据工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年大数据全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上大数据开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录大纲截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且后续会持续更新文章来源：https://www.toymoban.com/news/detail-852687.html
如果你觉得这些内容对你有帮助，可以添加VX：vip204888 （备注大数据获取）
因此收集整理了一份《2024年大数据全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友。
[外链图片转存中…(img-s4Faq2XJ-1712830332378)]
[外链图片转存中…(img-96SHEz3a-1712830332378)]
[外链图片转存中…(img-MKbZs2bs-1712830332379)]
[外链图片转存中…(img-pdwpnt73-1712830332379)]
[外链图片转存中…(img-mN58K4ss-1712830332380)]
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上大数据开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录大纲截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且后续会持续更新
如果你觉得这些内容对你有帮助，可以添加VX：vip204888 （备注大数据获取）
[外链图片转存中…(img-ZnWgl2RB-1712830332380)]文章来源地址https://www.toymoban.com/news/detail-852687.html
到了这里，关于Dubbo+Zookeeper使用_dubbo zookeeper配置的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
