赞
踩
专辑目录:SpringCloud学习日志
由于eureka2.0 已经闭源了,所以很多人会放弃使用eureka。
接下来我们就使用zookeeper来代替eureka。
首先告知我使用的是zookeeper3.3.6
使用zookeeper做注册中心是不需要像eureka那样先写一个server项目的,而是直接启动zookeeper就行了
首先我们启动zookeeper
zookeeper是使用临时节点的方式,是没有自我保护机制的,如果服务正常关闭,则服务也会注销掉。
zookeeper启动之后,我们不需要像eureka一样写一个注册中心,直接创建服务的项目注册就可以了。
于是我创建一个项目springcloud-zookeeper-member
在pom文件里将zookeeper依赖引入
- <?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-parent</artifactId>
- <version>2.0.1.RELEASE</version>
- <relativePath/> <!-- lookup parent from repository -->
- </parent>
- <groupId>com.study</groupId>
- <artifactId>springcloud-zookeeper-member</artifactId>
- <version>0.0.1-SNAPSHOT</version>
- <name>springcloud-zookeeper-member</name>
- <description>Demo project for Spring Boot</description>
-
- <properties>
- <java.version>1.8</java.version>
- </properties>
-
- <dependencyManagement>
- <dependencies>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-dependencies</artifactId>
- <version>Finchley.M7</version>
- <type>pom</type>
- <scope>import</scope>
- </dependency>
- </dependencies>
- </dependencyManagement>
-
- <dependencies>
- <!-- SpringBoot 整合Web 组件 -->
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-web</artifactId>
- </dependency>
-
- <!-- SpringBoot 整合 zookeeper 客户端-->
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
- </dependency>
- </dependencies>
-
- <repositories>
- <repository>
- <id>spring-milestones</id>
- <name>Spring Milestones</name>
- <url>https://repo.spring.io/libs-milestone</url>
- <snapshots>
- <enabled>false</enabled>
- </snapshots>
- </repository>
-
- </repositories>
- <build>
- <plugins>
- <plugin>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-maven-plugin</artifactId>
- </plugin>
- </plugins>
- </build>
- </project>
![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)
然后创建配置文件application.yml
- server:
- ### 端口号
- port: 8100
-
- spring:
- application:
- ## 服务名称,集群时要求名称相同
- name: zk-member
- cloud:
- zookeeper:
- ### zookeeper的连接路径
- connect-string: 127.0.0.1:2181
然后我们写一个主函数来启动服务
- package com.study;
-
- import org.springframework.boot.SpringApplication;
- import org.springframework.boot.autoconfigure.SpringBootApplication;
- import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
-
- @SpringBootApplication
- // zookeeper和connsul 使用@EnableDiscoveryClient来注册服务
- @EnableDiscoveryClient
- public class AppZookeeper {
- // 主进程
- public static void main(String[] args) {
- SpringApplication.run(AppZookeeper.class, args);
- }
- }
然后在写一个controller来进行测试调用
- package com.study.api.controller;
-
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.web.bind.annotation.RequestMapping;
- import org.springframework.web.bind.annotation.RestController;
-
- @RestController
- public class MemberController {
- @Value("${server.port}")
- private String port;
-
- @RequestMapping("/get")
- public String get(){
- return "会员服务的端口号:"+port;
- }
- }
![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)
然后问题来了,我们的访问路径呢?直接“localhost:8100/get” 肯定是不能这样做的。
我们先下载一个zookeeper的连接管理工具,方便我们查看和操作
https://issues.apache.org/jira/secure/attachment/12436620/ZooInspector.zip
下载解压之后打开 /build/zookeeper-dev-ZooInspector.jar 弹出如下窗口,点击“播放”键弹出连接窗口
然后点“OK”连接。连接成功之后左边就会出列表
因为我其他项目也在用zookeeper所以多了几个菜单,无视就好,我们展开services菜单可以看到zk-member下有一个uuid,
这就是刚刚我们启动的member服务了。右边有连接信息,但是因为是json字符串的所以不方便看。
这时我们在不关闭这个服务的时候直接在application.yml改端口号再启动
这时候刷新一下zookeeper管理器会看到新的uuid出现,这时便成功集群了。
因为节点是临时的,所以如果关闭服务之后服务就会从zookeeper中剔除(非正常关闭会有缓存延迟)
服务注册完之后我们应该关心的是如何互相调用。所以这里我拷贝一个order服务改为使用zookeeper
就是改依赖和@EnableDiscoveryClient注解 ,还有application.yml。 然后把调用member的地址改一下
然后启动order服务,注册到zookeeper之后刷新是这样的
我们用浏览器来调用getOrder接口
轮询的效果就出来了。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。