Spring Cloud 实现 ZooKeeper 注册发现
一、配置虚拟机和 zookeeper
首先关闭 Linux 的防火墙：systemctl stop firewalld 然后可以使用 systemctl status firewalld 进行确认。
如果本机和虚拟机之间的网络连接方式为：NAT，则注意实际上连接
虚拟机终端输入ifconfig查看 ens33 下的端口号
查看主机与虚拟机之间通信是否畅通
- 虚拟机端口号：ifconfig查看 ens33 下的端口号
- 主机端口号：网络连接下的 VMnet8 的端口号
- 使用虚拟机 ping 主机，使用主机 ping 虚拟机确保都可以 ping 通
二、服务提供者模块：cloud-provider-payment8004
二、三 两个大的步骤就是分别将服务提供者和服务消费者注入 Zookeeper。
步骤一：pom.xml 文件
排除 zookeeper-discovery 中自带的 zookeeper，同时引入与 linux 相同版本的 zookeeper
排除引入 zookeeper 的日志，因为日志会冲突
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18<!--SpringBoot整合Zookeeper客户端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
<exclusions>
<!--先排除自带的zookeeper3.5.3-->
<exclusion>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
</exclusion>
</exclusions>
</dependency>
<!--添加zookeeper3.4.14版本-->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.14</version>
</dependency>
步骤二：yml 文件
1
2
3
4
5
6
7
8
9
10
11
12# 8004 表示注册到 Zookeeper 服务器的支付服务提供者的端口号
server:
port: 8004
spring:
application:
# 服务别名
name: cloud-provider-payment
cloud:
zookeeper:
# ip地址为linux中的网络接口，2181为zookeeper的默认端口
connect-string: 192.168.238.151:2181步骤三：主类需要标注：
@EnableDiscoveryClient步骤四：Controller 类和主类
1
2
3
4
5
6
7
8
9
10
11
12
13
14package com.gjxaiou.springcloud.controller;
public class PaymentController {
private String serverPort;
public String paymentZk() {
return "Spring Cloud with Zookeeper: " + serverPort + "\t" + UUID.randomUUID().toString();
}
}然后启动 Zookeeper 和 8004 服务。
测试1：系统是否正常
从 Linux 层面：能看到服务名即为配置成功
1
2[zk: localhost:2181(CONNECTED) 3] ls /services
[cloud-provider-payment]网址测试：
http://localhost:8004/payment/zk可以看到一行 JSON 消息。
测试2：Zookeeper 属性查看
- 查看容器是否启动：
docker ps - 进入容器：
docker exec -it zookeeper实例标识 /bin/bash - 进入bin目录：
cd bin - 登录 server：
zkCli.sh -server 127.0.0.1:2181 - 查看目录：
ls /
1 | 获取服务名 |
服务节点是临时的
关闭 8004 后在linux终端中,一段时间后失去连接
1 | [zk: localhost:2181(CONNECTED) 18] ls /services/cloud-provider-payment |
再开启8004，再次查看流水号可以发现流水号跟之前的不一样 ，所以服务节点是临时的，在关闭服务后完全删除。
三、消费者模块：cloud-consumerzk-order80
步骤一：pom.xml 文件
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18<!--SpringBoot整合Zookeeper客户端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
<exclusions>
<!--先排除自带的zookeeper3.5.3-->
<exclusion>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
</exclusion>
</exclusions>
</dependency>
<!--添加zookeeper3.4.14版本-->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.14</version>
</dependency>步骤二：新建并配置
application.yml1
2
3
4
5
6
7
8server:
port: 80
spring:
application:
name: cloud-consumerzk-order80
cloud:
zookeeper:
connect-string: 192.168.238.151:2181步骤三：主类增加
@EnableDiscoveryClient注解。步骤四：自定义配置类生成 RestTemplate
1
2
3
4
5
6
7
8
9
10
11
12
13package com.gjxaiou.springcloud.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
public class ApplicationContextConfig {
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}步骤五：Controller 调用 8004 服务
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23package com.gjxaiou.springcloud.controller;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
public class OrderZKController {
public static final String INVOKE_URL = "http://cloud-provider-payment";
private RestTemplate restTemplate;
public String paymentInfo(){
String result = restTemplate.getForObject(INVOKE_URL + "/payment/zk", String.class);
return result;
}
}
测试
linux 查看节点是否注册上
1
2[zk: localhost:2181(CONNECTED) 1] ls /services
[cloud-provider-payment, cloud-consumerzk-order80]网址登陆查看
http://localhost:8004/payment/zk
http://localhost/consumer/payment/zk