本文共 1329字,阅读大约需要 6分钟,文末有计时器可自行对时

概 述

业务微服务化以后,我们要求服务高可用,于是我们可以部署多个相同的服务实例,并引入负载均衡机制。而微服务注册中心作为微服务化系统的重要单元,其高可用也是非常必要的,因此在生产中我们可能需要多个微服务注册中心实例来保证服务注册中心的稳定性。本文就以 Eureka微服务注册中心为例,来实践一下如何 在线扩充Eureka Server实例来保证 微服务注册中心的高可用性!

本文内容脑图如下:

注: 本文首发于 作者公众号 CodeSheep ,可 长按 / 扫描 下面的 小心心 来订阅 ↓ ↓ ↓

原理与实验流程介绍

我们欲模拟如下过程:

  • 首先启动一个 eureka-server实例(eureka-server-1)

  • 再启动一个 eureka-client实例(eureka-client-1)并注册到 eureka-server-1中

  • 接下来我们启动第二个 eureka-server实例:eureka-server-2,并且让已启动的 eureka-server-1 和 eureka-client-1在不重启的情况下来感知到 eureka-server-2的加入

  • 同理我们可以在启动第三个 eureka-server实例:eureka-server-3,并且让已启动的 eureka-server-1 、eureka-server-2 和 eureka-client-1 在不重启的情况下来感知到 eureka-server-3的加入

  • 更多 eureka-server实例的加入原理完全相同,不再赘述

这样一来我们便实现了微服务注册中心的动态在线扩容!

而如何才能让已启动的服务能够在不重启的情况下来感知到新的 eureka-server 的加入呢?

为此我们引入 Spring Cloud Config 配置中心 config-server,并将 eureka-server和 eureka-client服务的配置文件由 config-server进行统一管理,这样一来对配置文件的修改如果可以通过某种机制来通知已启动的服务,那么问题便迎刃而解了!

我们给出整个过程的原理图如下:

接下来我们来实践这整个过程!

基础工程搭建

  • 创建一个 config-server工程

pom中关键依赖如下:

        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-config-server</artifactId>        </dependency>

主类添加相应注解:

@SpringBootApplication@EnableConfigServerpublic class ConfigServerApplication {  ...}

bootstrap.yml配置文件如下:

spring:  application:    name: config-server  cloud:    config:      server:        git:          uri: https://github.com/hansonwang99/xxxx          username: xxxx          password: xxxxserver:  port: 1115该 yml配置很重要,其连接了预先准备好的 git仓库,后续 eureka-server 和 eureka-client 的配置文件都是存于该git仓库中的!
  • 创建一个 eureka-server工程

pom中关键依赖如下:

        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-config</artifactId>        </dependency>

主类添加相应注解:

@SpringBootApplication@EnableEurekaServerpublic class EurekaServerApplication {  ...}

bootstrap.yml重要配置如下:

spring:  application:    name: eureka-server  cloud:    config:      uri: http://localhost:1115注意该 yml中关于 spring cloud config 的配置同样非常重要,因为此 eureka-server需要从 config-server中拉取配置!

最后我们还需要添加一个 controller便于测试:

@RestController@RequestMapping("/test")public class TestController {    @Autowired    EurekaClientConfigBean eurekaClientConfigBean;    @GetMapping("/eureka-service-info")    public Object getEurekaServerUrl(){        return eurekaClientConfigBean.getServiceUrl();    }}

这个 Rest Controller 接口的意图很简单:打印出当前到底有多少个 eureka-server实例在提供服务(从而可以直观的判断出 eureka-server的扩容是否已经成功)

  • 创建一个 eureka-client工程

pom中关键依赖如下:

        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-config</artifactId>        </dependency>

主类添加相应注解:

@SpringBootApplication@EnableDiscoveryClientpublic class EurekaClientApplication {    public static void main(String[] args) {        SpringApplication.run(EurekaClientApplication.class, args);    }}

bootstrap.yml 重要配置如下:

spring:  application:    name: eureka-client  cloud:    config:      uri: http://localhost:1115这里基本同上面 eureka-server的配置,不再赘述

同样,我们也在 eureka-client中添加一个 controller便于测试:

@RestController@RequestMapping("/test")public class TestController {    @Autowired    EurekaClientConfigBean eurekaClientConfigBean;    @GetMapping("/eureka-service-info")    public Object getEurekaServerUrl(){        return eurekaClientConfigBean.getServiceUrl();    }}三个工程的创建到此完毕!下来我们来依次启动各个工程
  • 首先启动 config-server工程

  • 然后用 peer1配置文件来启动 第一个eureka server,指令如下:
    mvn spring-boot:run -Dspring.profiles.active=peer1

启动过程的开始打印出如下信息,一目了然:


当然这个 peer1配置文件实际物理存在于git仓库之上:

  • 接下来我们启动 eureka_client工程,指令如下:
    mvn spring-boot:run -Dspring.profiles.active=peer1

其依然需要通过 spring cloud config 去git仓库拉取 eureka-client的 peer1配置文件,这一点从 eureka-client的启动过程中也能看到:

  • 接下来我们用浏览器访问仅存在的一个 eureka-server微服务注册中心,可以看到有服务已经注册上去了:

    既然 config-server / eureka-server / eureka-client 三个服务已经启动了,那么接下来我们来测试一下:

浏览器访问 eureka-client的 Rest接口: localhost:1114/test/eureka-service-info:

同理,浏览器访问 eureka-server的 Rest接口: localhost:1111/test/eureka-service-info:

OK,一切正常,但目前微服务注册中心仅一个 eureka-server实例,下来我们来 在线动态扩容微服务注册中心实例。

扩充一次 Eureka Server

接下来我们再用 peer2配置文件来 启动第二个 eureka server,指令如下:

mvn spring-boot:run -Dspring.profiles.active=peer2

启动完毕后,浏览器访问微服务注册中心第一个实例 eureka-server-1: localhost:1111/ 发现第二个微服务注册中心实例 eureka-server-2已经成功启动并加入

为了让已启动的 eureka-client和 eureka-server-1能在线感知到 eureka-server-2的加入,此时我们需要修改两个地方:

  • 修改 Git上eureka-client的配置文件:
    server:      port: 1114    spring:      application:        name: eureka-client    eureka:      client:        serviceUrl:          defaultZone: http://localhost:1111/eureka/,http://localhost:1112/eureka/  # 此处改为包含两个eureka-server
  • 修改 Git上第一个eureka-server(eureka-server-1)的配置文件:
    server:      port: 1111    spring:      application:        name: eureka-server    eureka:      instance:        hostname: localhost        preferIpAddress: true      client:        registerWithEureka: true        fetchRegistry: true        serviceUrl:          defaultZone: http://localhost:1112/eureka/ # 此处改为第二个eureka-server地址      server:          waitTimeInMsWhenSyncEmpty: 0          enableSelfPreservation: false

Git仓库里配置文件的修改完毕并不能触发已启动的 eureka-client和 eureka-server-1 在线更新,我们还需要向 eureka-client服务和 eureka-server-1服务来 POST两个请求来激活刚才所修改的配置:

POST localhost:1111/actuator/refresh  // 激活 eureka-client服务的配置POST localhost:1114/actuator/refresh // 激活 eureka-server-1 服务的配置

POST请求一旦发出,我们从控制台里能直观看到更新配置文件的详情:

配置文件更新完毕,浏览器再次访问 eureka-client的 Rest接口: localhost:1114/test/eureka-service-info:

再扩充一次 Eureka Server

接下来还可以再用 peer3配置文件来启动第三个 eureka server加入高可用微服务注册中心集群,过程和上面类似,此处不再赘述!当然更多 eureka-server实例的扩充原理也相同。

后 记

由于能力有限,若有错误或者不当之处,还请大家批评指正,一起学习交流!
  • 我的个人博客:www.codesheep.cn (程序羊)

如果有兴趣,也可以抽时间看看作者更多系列的原创文章:

我的半年技术博客之路利用K8S技术栈打造个人私有云连载文章Spring Boot Admin 2.0 上手体验利用TICK搭建Docker容器可视化监控中心从一份配置清单详解Nginx服务器配置Docker容器可视化监控中心搭建利用ELK搭建Docker容器化应用日志中心高效编写Dockerfile的几条准则Docker容器跨主机通信Spring Boot应用监控实战RPC框架实践之:Google gRPCRPC框架实践之:Apache Thrift微服务调用链追踪中心搭建

作者更多 务实、能看懂、可复现的 原创文章尽在公众号 CodeSheep,欢迎订阅 ⬇️⬇️⬇️

©著作权归作者所有:来自51CTO博客作者mb5fdcae83766b7的原创作品,如需转载,请注明出处,否则将追究法律责任

更多相关文章

  1. 注册中心 Eureka 源码解析 —— 应用实例注册发现(一)之注册
  2. 注册中心 Eureka 源码解析 —— 注册表 InstanceRegistry 类关系
  3. 注册中心 Eureka 源码解析 —— 应用实例注册发现 (四)之自我保护
  4. 注册中心 Eureka 源码解析 —— Eureka-Server 启动(二)之 EurekaB
  5. 注册中心 Eureka 源码解析 —— 应用实例注册发现 (三)之下线
  6. 注册中心 Eureka 源码解析 —— Eureka-Server 启动(一)之 ServerC
  7. 注册中心 Eureka 源码解析 —— 调试环境搭建
  8. 注册中心 Eureka 源码解析 —— Eureka-Client 初始化(二)之 Eurek

随机推荐

  1. 【同说】小天童鞋:“不断学习,不断成长”
  2. 熔断器 Hystrix 源码解析 —— 命令执行(
  3. 关于前端学习路线的一些建议(含面试自测题
  4. 关于 Babel 你必须知道的基础知识
  5. 继 GitHub 后微软又收购了 npm
  6. 熔断器 Hystrix 源码解析 —— 命令合并
  7. 【51CTO学员故事】6年拿下8个软考证书
  8. 微服务调用链追踪中心搭建
  9. 4.dockerfile
  10. 数据结构之集合和映射