SpringCloud如何实现微服务架构的分布式部署？

本文共计1537个文字，预计阅读时间需要7分钟。

目录

一、问题分析及解决方案

1.问题分析

2.解决方案

二、手动刷新

1.添加服务监控

2.暴露服务端点

3.刷新业务类controller

4.手动刷新

三、自动刷新

1.总线是什么

2.基本原理

3.一、问题什么是

目录

• 一、问题分析及解决方案
• 1、问题分析
• 2、解决方案
• 二、手动刷新
• 1、添加服务监控
• 2、暴露服务端点
• 3、刷新业务类controller
• 4、手动刷新
• 三、自动刷新
• 什么是总线
• 基本原理

一、问题分析及解决方案

1、问题分析

上一章我们讲过远程仓储统一管理配置信息，客户端可以通过统一配置服务中心 config server 服务端获取配置信息。现在我们来做一个改变，并进行分析。

首先启动注册中心、统一配置中心configserver服务端、订单服务。浏览器访问地址：localhost:9000/order/getConfig 查看效果。

然后将远程仓储的订单服务dev环境的信息进行改变，在info上增加版本 version=01。

浏览器访问地址：localhost:9000/order/getConfig 查看效果

重新启动订单服务，浏览器访问地址localhost:9000/order/getConfig 查看效果

我们看到，远端仓储的配置信息改变，如果不重新启动订单服务，则无法刷新远端仓储的配置信息。

2、解决方案

使用动态刷新，动态刷新分为两种形式，一种是手动刷新，一种是自动刷新。

二、手动刷新

1、添加服务监控

在pom文件中添加服务监控依赖spring-boot-starter-actuator ，修改pom如下：

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="maven.apache.org/POM/4.0.0" xmlns:xsi="www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="maven.apache.org/POM/4.0.0 maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>springcloudbase</artifactId> <groupId>com.hwadee.springcloud2022</groupId> <version>0.0.1-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <groupId>com.hwadee.springcloud</groupId> <artifactId>orderServer9000</artifactId> <dependencies> <!-- 统一配置服务中心客户端依赖 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> <!--动态健康监控 可以用于动态感知配置变化--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!--web依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- 管理公共api --> <dependency> <groupId>com.hwadee.springcloud</groupId> <artifactId>springcloud-api</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> <!--Eureka Client--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <!-- 方便创建类的gettter setter --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> </dependencies> </project>

2、暴露服务端点

让客户端能感受到配置的更新。

暴露服务端点，让客户端能感受到配置的更新，在bootstrap配置文件中修改如下：

spring:
cloud:
config:
label: master # 指定分支
name: order # 指定应用名称
profile: dev # 指定激活环境
uri: localhost:7009 #硬编码 指定访问 config server 远程仓储的地址的ip和端口

#暴露服务端点，让客户端能感受到配置的更新
management:
endpoints:
web:
exposure:
include: "*"

3、刷新业务类controller

刷新业务类controller，在订单服务的controller上使用注解 @RefreshScope ，使用后具备刷新能力，@Refreshscope用来在不需要重启徽服务情况下,将当前scope域中信息刷新为最新配置信息，订单服务的controller代码修改如下：

import com.hwadee.springcloud.entity.Product; import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/order") @RefreshScope public class OrderController { @Value("${env}") private String env; @Value("${port}") private String port; @Value("${info}") private String info; @RequestMapping(value = "/getConfig") public Product getConfigInfo() { Product product = new Product(); product.setName(env +"环境 端口："+ port +" "+ info); return product; } }

4、手动刷新

在cmd窗口进行手动刷新，必须是post请求，且地址固定：curl -X POST "localhost:9000/actuator/refresh"。

再次访问：localhost:9000/order/getConfig

三、自动刷新

问题：每个微服务如果需要加载最新配置信息，必须向每个微服务手动发送post请求，才能加载最新配置信息。因为微服务一般是集群方式，所以此种方式不方便，我们可以使用一个组件Bus总线，实现自动刷新。Bus总线支持RubbitMQ和kafak消息代理。

什么是总线

在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费，所以称它为消息总线。在总线上的各个实例，都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。

基本原理

ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候，它会把这个信息放入到Topic中，这样其它监听同一Topic的服务就能得到通知，然后去更新自身的配置。

到此这篇关于SpringCloud Config统一配置中心问题分析解决与客户端动态刷新实现的文章就介绍到这了,更多相关SpringCloud Config配置中心内容请搜索自由互联以前的文章或继续浏览下面的相关文章希望大家以后多多支持自由互联！