步骤如下:
**1. 构建消费端模块:cloud-comsumerzk-order80**
**2. 当前模块添加 zookeeper-discovery 依赖**
```xml
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
...
</dependencies>
```
**3. 在当前模块的`application.yml`配置 zookeeper 相关**
```yml
server:
port: 80
spring:
application:
name: cloud-comsumer-order
cloud:
zookeeper:
#zookeeper地址
connect-string: 192.168.1.17:2181
```
**4. 在当前启动类上标注注解`@EnableDiscoveryClient`**
```java
@SpringBootApplication
@EnableDiscoveryClient
public class OrderZKMain80 {
public static void main(String[] args) {
SpringApplication.run(OrderZKMain80.class, args);
}
}
```
**5. 在当前模块注入 RestTemplate 组件方便访问服务端**
```java
@Configuration
public class ApplicationContextConfig {
@Bean
@LoadBalanced
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}
```
**6. 当前模块的 controller 层**
```java
@RestController
@RequestMapping("/comsumer")
public class OrderController {
@Resource
private RestTemplate restTemplate;
//cloud-payment-service 为服务端的 spring.application.name 配置
public static final String PAYENT_URL = "http://cloud-payment-service";
@GetMapping("/payment/zk")
public String getpaymentInfo() {
String res = restTemplate.getForObject(PAYENT_URL + "/payment/zk", String.class);
return res;
}
}
```
**7. 测试**
(1)启动 Zookeeper。
```shell
# zkServer.sh start
# jps
2621 QuorumPeerMain --出现该进行则启动成功
```
记住需要到 Linux 中关闭防火墙,外面应用才可以访问到 Zookeeper。
```shell
-- 关闭防火墙
# systemctl stop firewalld
--查看防火墙是否关闭
# firewall-cmd --state
not running
-- 禁止防火墙开机自启动
# systemctl disable firewalld.service
```
(2)启动服务端模块、消费端模块。
访问消费端模块:http://localhost:80/comsumer/payment/zk 。得到如下响应。
```
serverPort:8004
```
(3)到 Zookeeper 中查看消费端的注册信息。
```shell
--切换到 Zookeeper 的安装目录
# cd /opt/install/zookeeper
--启动 zookeeper 客户端工具
# bin/zkCli.sh
--查看 zookeeper 节点
[zk: localhost:2181(CONNECTED) 16] ls /
[services, zookeeper]
[zk: localhost:2181(CONNECTED) 17] ls /services
[cloud-comsumer-order, cloud-payment-service]
[zk: localhost:2181(CONNECTED) 18] ls /services/cloud-comsumer-order
[476aad5c-4f02-44b2-b42d-741bea0ed116]
--获取节点信息
[zk: localhost:2181(CONNECTED) 19] get /services/cloud-comsumer-order/476aad5c-4f02-44b2-b42d-741bea0ed116
{"name":"cloud-comsumer-order","id":"476aad5c-4f02-44b2-b42d-741
```
完整的注册信息如下:
```json
{
"name":"cloud-comsumer-order",
"id":"476aad5c-4f02-44b2-b42d-741bea0ed116",
"address":"USER-20210829ES",
"port":80,
"sslPort":null,
"payload":{
"@class":"org.springframework.cloud.zookeeper.discovery.ZookeeperInstance",
"id":"application-1",
"name":"cloud-comsumer-order",
"metadata":{
}
},
"registrationTimeUTC":1637399316399,
"serviceType":"DYNAMIC",
"uriSpec":{
"parts":[
{
"value":"scheme",
"variable":true
},
{
"value":"://",
"variable":false
},
{
"value":"address",
"variable":true
},
{
"value":":",
"variable":false
},
{
"value":"port",
"variable":true
}
]
}
}
```
- 微服务
- 微服务是什么?
- 微服务架构
- 微服务优缺点
- 微服务技术栈
- 微服务框架对比
- SpringCloud
- SpringCloud是什么
- SpringCloud与SpringBoot对比
- SpringCloud与Dubbo对比
- Rest微服务案例
- 总体介绍
- 父工程构建步骤
- 公共模块构建步骤
- 服务端模块构建步骤
- 消费端模块构建步骤
- Eureka服务注册与发现
- Eureka是什么
- Eureka原理
- Eureka注册服务中心构建
- 向Eureka注册已有微服务
- Eureka的自我保护机制
- Eureka服务发现
- Eureka集群配置
- Eureka与Zookeeper对比
- Ribbon负载均衡
- Ribbon是什么
- Ribbon负载均衡演示
- 构建服务端模块
- 构建消费端模块
- Ribbon核心组件IRule
- 自定义负载均衡策略
- Ribbon均衡策略优先级
- 轮询策略算法
- OpenFeign负载均衡
- OpenFeign是什么
- 负载均衡演示
- 日志打印功能
- 导出功能
- Hystrix断路器
- Hystrix是什么
- 服务熔断
- Hystrix服务端构建
- 服务熔断演示
- 服务熔断类型
- HystrixProperty配置汇总
- 服务降级
- Hystrix客户端构建
- 服务降级演示
- fallbackFactory
- 熔断与降级
- 服务监控
- 网关服务Zuul
- Zuul是什么
- Zuul路由服务构建
- 设置访问映射规则
- Config分布式配置中心
- Config分布式配置中心是什么
- Config服务端与Git通信
- Config客户端获取配置
- Config客户端动态刷新
- Bus消息总线
- Bus消息总线是什么
- Bus消息总线原理
- 广播通知设计思想
- 广播通知演示
- 定点通知演示
- Stream消息驱动
- 为什么要引入Stream
- Stream消息驱动是什么
- Stream设计思想
- Stream流程和注解
- Stream案例演示
- 重复消费问题
- 消息持久化
- Sleuth分布式链路跟踪
- Sleuth是什么
- 搭建链路监控
- SpringCloud Alibaba
- Nacos注册与配置中心
- Nacos是什么
- 安装并运行Nacos
- Nacos注册中心
- 服务端入住Nacos
- 消费端入住Nacos
- Nacos负载均衡演示
- 服务注册中心对比
- Nacos的AP和CP转化
- Nacos配置中心
- 基础配置演示
- Nacos分类配置
- Nacos集群搭建
- Sentinel实现熔断与限流
- Sentinel是什么
- Sentinel环境搭建
- Sentinel监控微服务演示
- Sentinel流控规则
- 流量监控的作用
- 设置流控规则
- Sentinel降级规则
- 熔断降级作用
- 设置降级规则
- Sentinel热点限流
- 什么是热点
- 设置热点限流
- Sentinel系统限流
- @SentinelResource
- @SentinelResource属性
- @SentinelResource限流演示
- @SentinelResource熔断演示
- 规则持久化
- 熔断框架比较
- Seata分布式事务
- 分布式事务问题
- Seata是什么
- Seata分布式事务过程
- Seata环境搭建
- 演示示例
- 业务说明
- 数据库环境准备
- 微服务环境准备
- 测试
- Consul服务注册与发现
- Consul是什么
- Consul能做什么
- 环境搭建
- Windows平台
- 服务端入住Consul
- 消费端入住Consul
- 注册中心对比
- Zookeeper服务注册与发现
- Zookeeper是什么
- 环境搭建
- 服务端入住Zookeeper
- 消费端入住Zookeeper
- 网关服务Gateway
- Gateway是什么
- Gateway能做什么
- Gateway对比Zuul
- 三大核心概念
- Gateway工作流
- 环境搭建
- 网关路由配置方式
- 配置文件配置
- 代码中配置
- 动态路由
- Predicate断言
- 断言是什么
- 常用断言
- Filter过滤器
- 过滤器是什么
- 过滤器种类
- 自定义过滤器