构建高可用的Config Server、使用Spring Cloud Bus刷新配置

- 日理万妓 2021-08-29 12:53 200阅读 0赞

构建高可用的Config Server

当服务实例很多时,所有的服务实例需要同时从配置中心Config Server读取配置文件,这时可以考虑将配置中心Config Server做成一个微服务,并且将其集群化,从而达到高可用。配置中心Config Server 高可用的架构图如下图所示。ConfigServer和Config Client向Eureka Server注册,且将Config Server多实例集群部署。
在这里插入图片描述

构建Eureka Server

依赖:

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.cloud</groupId>
  4. <artifactId>spring-cloud-starter-eureka-server</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.boot</groupId>
  8. <artifactId>spring-boot-starter-web</artifactId>
  9. </dependency>
  10. </dependencies>

配置:

  1. server:
  2. port: 8761
  3. spring:
  4. application:
  5. name: eureka-client
  6. eureka:
  7. client:
  8. fetch-registry: false
  9. register-with-eureka: false
  10. service-url:
  11. defaultZone: http://localhost:${ server.port}/eureka/

启动类:

  1. @SpringBootApplication
  2. @EnableEurekaServer
  3. public class EurekaServerApplication {
  4. public static void main(String[] args) {
  5. SpringApplication.run(EurekaServerApplication.class, args);
  6. }
  7. }

构建Config Server

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.cloud</groupId>
  4. <artifactId>spring-cloud-config-server</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.cloud</groupId>
  8. <artifactId>spring-cloud-starter-eureka</artifactId>
  9. </dependency>
  10. </dependencies>

配置:

  1. server:
  2. port: 8769
  3. spring:
  4. application:
  5. name: config-server
  6. cloud:
  7. config:
  8. server:
  9. git:
  10. uri: https://github.com/ActonZhang1024/springcloud-config.git
  11. search-paths: springcloud-config
  12. label: master
  13. eureka:
  14. client:
  15. service-url:
  16. defaultZone: http://localhost:8761/eureka/

构造Config Client

  1. <dependencies>
  2. <dependency>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-web</artifactId>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.cloud</groupId>
  8. <artifactId>spring-cloud-starter-config</artifactId>
  9. </dependency>
  10. <dependency>
  11. <groupId>org.springframework.cloud</groupId>
  12. <artifactId>spring-cloud-starter-eureka</artifactId>
  13. </dependency>
  14. </dependencies>

配置:bootstrap.yml

  1. spring:
  2. application:
  3. name: config-client
  4. cloud:
  5. config:
  6. label: master
  7. name: eureka-client
  8. profile: dev
  9. discovery:
  10. service-id: config-server
  11. enabled: true

配置:application.yml

  1. eureka:
  2. client:
  3. service-url:
  4. defaultZone: http://localhost:8761/eureka/

依次启动eureka-server、config-server 和config-client工程,注意这里需要config-server启动成功并且向eureka-server 注册完成后,才能启动config-client, 否则config-client 找不到config-server。通过控制台可以发现,config-client向地址为htp://localhost:8769的config-server读取了配置文件。访问htp://localhost:8762/foo,浏览器显示:
在这里插入图片描述

可见,config-server 从远程Git仓库读取了配置文件,config-client 从config-server读取了配置文件。

那么如何搭建高可用的Config Server 呢?只需要将Config Server 多实例部署,用IDEA开启多个Config Server 实例,端口分别为8769和8768。在浏览器上访问Eureka Server 的主页htp://ocalhost:8761/,界面如图
在这里插入图片描述
多次启动config-client 工程,从控制台可以发现它会轮流地从ht:///clthost:/8768 和htp://ocalhost:8769的Config Server读取配置文件,并且做了负载均衡。

在这里插入图片描述
在这里插入图片描述

使用Spring Cloud Bus刷新配置

Spring Cloud Bus是用轻量的消息代理将分布式的结点连接起来,可以用于广播配置文件的更改或者服务的监管管理。一个关键的思想就是,消息总线可以为微服务做监控,也可以实现应用程序之间相互通信。Spring Cloud Bus可选的消息代理组建包括RabbitMQ、AMQP和Kafka等。本节讲述的是用RabbitMQ作为SpringCloud的消息组件去刷新更改微服务的配置文件。

为什么需要用SpringCloudBus去刷新配置呢?
如果有几十个微服务,而每一个服务又是多实例,当更改配置时,需要重新启动多个微服务实例,会非常麻烦。Spring Cloud Bus的一个功能就是让这个过程变得简单,当远程Git仓库的配置更改后,只需要向某一个微服务实例发送一个 Post请求,通过消息组件通知其他微服务实例重新拉取配置文件。如下图所示,当远程Git 仓库的配置更改后,通过发送“/bus/refresh” Post请求给某一个微服务实例,通过消息组件,通知其他微服务实例,更新配置文件。
在这里插入图片描述
本节是在上一节的例子上进行改造的,只需要改造configclient工程。首先,需要在pom文件中引入用RabbitMQ实现的Spring Cloud Bus的起步依赖spring-loud-starter-bus-amqpo如果读者需要自己实践,则需要安装RabbitMQ服务器。pom文件添加的依赖如下:

  1. <dependency>
  2. <groupId>org.springframework.cloud</groupId>
  3. <artifactId>spring-cloud-starter-bus-amqp</artifactId>
  4. </dependency>

在工程的配置文件application.yml添加RabbitMQ的相关配置,host 为RabbitMQ服务器的IP地址,port 为RabbitMQ服务器的端口,username 和password为RabbitMQ服务器的用户名和密码。通过消息总线更改配置,需要经过安全验证,为了方便讲述,先把安全验证屏蔽掉,也就是将management. security. enabled改为false。 代码清单如下:

  1. spring:
  2. rabbitmq:
  3. host: localhost
  4. port: 5672
  5. username: guest
  6. password: guest
  7. management:
  8. security:
  9. enabled: false

最后,需要在更新的配置类上加@ RefreshScope注解,只有加上了该注解,才会在不重启服务的情况下更新配置,如本例中更新配置文件foo变量的值。代码清单如下:

  1. @RestController
  2. @RefreshScope
  3. public class Controller {
  4. @Value("${foo}")
  5. String foo;
  6. @RequestMapping("/foo")
  7. public String hi() {
  8. System.out.println(foo);
  9. return foo;
  10. }
  11. }

依次启动工程,其中config-client开启两个实例,端口分别为8762和8763。启动完成后,在浏览器上访问htp://ocalhost:8762/foo或者htp://calhost:8763/foo,浏览器显示:
在这里插入图片描述
更改远程Git仓库,将foo的值改为“foo version 2”。通过Postman或者其他工具发送一个Post请求htp://ocahost:8762/bus/re/resh 请求发送成功,再访问htp://ocalhost:8762/foo或者http://localhost:8763/foo,浏览器都会显示:
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

可见,通过向8762端口的微服务实例发送Post请求http://localhost:8762/bus/refresh,请求刷新配置,由于使用了Spring Cloud Bus,其他服务实例(如案例中的8763端口的服务实例)会接收到刷新配置的消息,也会刷新配置。

另外,“a/bus/refresh“ API接口可以指定服务,即使用“destination”参数,例如“/bus/refresh?destination=eureka-client:**”,即刷新服务名为eureka-client的所有服务实例。

发表评论

表情:
评论列表 (有 0 条评论,200人围观)

还没有评论,来说两句吧...

相关阅读