当前位置:   article > 正文

SpringCloud学习笔记(八)使用Zookeeper做注册中心

SpringCloud学习笔记(八)使用Zookeeper做注册中心

专辑目录:SpringCloud学习日志

由于eureka2.0 已经闭源了,所以很多人会放弃使用eureka。

接下来我们就使用zookeeper来代替eureka。

首先告知我使用的是zookeeper3.3.6

使用zookeeper做注册中心是不需要像eureka那样先写一个server项目的,而是直接启动zookeeper就行了

首先我们启动zookeeper

zookeeper是使用临时节点的方式,是没有自我保护机制的,如果服务正常关闭,则服务也会注销掉。

zookeeper启动之后,我们不需要像eureka一样写一个注册中心,直接创建服务的项目注册就可以了。

于是我创建一个项目springcloud-zookeeper-member

 

在pom文件里将zookeeper依赖引入

 

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  5. <parent>
  6. <groupId>org.springframework.boot</groupId>
  7. <artifactId>spring-boot-starter-parent</artifactId>
  8. <version>2.0.1.RELEASE</version>
  9. <relativePath/> <!-- lookup parent from repository -->
  10. </parent>
  11. <groupId>com.study</groupId>
  12. <artifactId>springcloud-zookeeper-member</artifactId>
  13. <version>0.0.1-SNAPSHOT</version>
  14. <name>springcloud-zookeeper-member</name>
  15. <description>Demo project for Spring Boot</description>
  16. <properties>
  17. <java.version>1.8</java.version>
  18. </properties>
  19. <dependencyManagement>
  20. <dependencies>
  21. <dependency>
  22. <groupId>org.springframework.cloud</groupId>
  23. <artifactId>spring-cloud-dependencies</artifactId>
  24. <version>Finchley.M7</version>
  25. <type>pom</type>
  26. <scope>import</scope>
  27. </dependency>
  28. </dependencies>
  29. </dependencyManagement>
  30. <dependencies>
  31. <!-- SpringBoot 整合Web 组件 -->
  32. <dependency>
  33. <groupId>org.springframework.boot</groupId>
  34. <artifactId>spring-boot-starter-web</artifactId>
  35. </dependency>
  36. <!-- SpringBoot 整合 zookeeper 客户端-->
  37. <dependency>
  38. <groupId>org.springframework.cloud</groupId>
  39. <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  40. </dependency>
  41. </dependencies>
  42. <repositories>
  43. <repository>
  44. <id>spring-milestones</id>
  45. <name>Spring Milestones</name>
  46. <url>https://repo.spring.io/libs-milestone</url>
  47. <snapshots>
  48. <enabled>false</enabled>
  49. </snapshots>
  50. </repository>
  51. </repositories>
  52. <build>
  53. <plugins>
  54. <plugin>
  55. <groupId>org.springframework.boot</groupId>
  56. <artifactId>spring-boot-maven-plugin</artifactId>
  57. </plugin>
  58. </plugins>
  59. </build>
  60. </project>

然后创建配置文件application.yml

 

  1. server:
  2. ### 端口号
  3. port: 8100
  4. spring:
  5. application:
  6. ## 服务名称,集群时要求名称相同
  7. name: zk-member
  8. cloud:
  9. zookeeper:
  10. ### zookeeper的连接路径
  11. connect-string: 127.0.0.1:2181

然后我们写一个主函数来启动服务

 

  1. package com.study;
  2. import org.springframework.boot.SpringApplication;
  3. import org.springframework.boot.autoconfigure.SpringBootApplication;
  4. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  5. @SpringBootApplication
  6. // zookeeper和connsul 使用@EnableDiscoveryClient来注册服务
  7. @EnableDiscoveryClient
  8. public class AppZookeeper {
  9. // 主进程
  10. public static void main(String[] args) {
  11. SpringApplication.run(AppZookeeper.class, args);
  12. }
  13. }

然后在写一个controller来进行测试调用

 

  1. package com.study.api.controller;
  2. import org.springframework.beans.factory.annotation.Value;
  3. import org.springframework.web.bind.annotation.RequestMapping;
  4. import org.springframework.web.bind.annotation.RestController;
  5. @RestController
  6. public class MemberController {
  7. @Value("${server.port}")
  8. private String port;
  9. @RequestMapping("/get")
  10. public String get(){
  11. return "会员服务的端口号:"+port;
  12. }
  13. }

然后问题来了,我们的访问路径呢?直接“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接口

 

轮询的效果就出来了。

 

 

声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号