spring cloud config 结合 spring cloud bus实现配置自定的刷新

爱被打了一巴掌 2024-02-19 18:44 305阅读 0赞

在线上环境中，有时候我们希望系统中的某些配置参数在修改后，可以立即生效而不用重新启动服务。由上一节我们知道，我们可以把配置文件统一放到配置服务中进行管理，这一节我们在配置中心中整合**spring cloud bus**并结合**git** 的**webhook**实现配置的自动刷新。

整合spring cloud bus后我们可以获取到一些新的端点：

POST **/bus/refresh: 用于刷新配置**

POST  **/bus/refresh?destination=spring.application.name:port 刷新具体的某个微服务，port和前面的name可以使用通配符 \***

## **需求** ##

实现系统中的配置的自动刷新

## **实现步骤（在上一节代码的基础上）** ##

**1、安装 erlang 和 rabbitmq, 需要注意 rabbitmq不同的版本需要不同的erlang的版本，参考链接 [https://www.rabbitmq.com/which-erlang.html][https_www.rabbitmq.com_which-erlang.html]**

**2、config server 和 config client 端同时引入以下依赖**

<dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>
    <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

**3、需要动态刷新配置的地方加上 @RefreshScope 注解**

**此处是从配置中心获取 msg 这个字段的值，记住这个controller 的访问路径，下方演示需要用到**

@RestController
    @RefreshScope
    public class PrintMsgController {
    	@Value("${msg}")
    	private String msg;
    	/**
    	 * 打印msg消息
    	 *
    	 * @return
    	 */
    	@GetMapping("print/msg")
    	public String print() {
    		return msg;
    	}
    }

**4、找到 git 的远程仓库，配置 webhook,这里以 github为例**  
![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC8wODU1LzE5MjBiYzkxLTE1YzYtMzlmMS1iMmE3LWJkZjhiMGFiYTNmNC5wbmc][]  
 **5、配置中心和配置客户端的代码 配置文件和上节差不多，唯一不同的是加入了 rabittmq 的配置**

spring: 
      rabbitmq: 
        host: localhost
        port: 5672
        username: guest
        password: guest

## **运行结果** ##

![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC8wODYxLzdiYzBiYWNiLTUzMTUtMzI5MS05NDk3LTM3M2E4ZDYwZTNmNC5naWY][]

**解释：**

**1、演示 config server 的代码**

**2、演示 config client 的代码**

**3、服务注册中心上各个服务注册的情况**

**4、演示 webhook的配置（webhook配置的地址需要是外网可以访问的，我上方的例子是使用了一个内网穿透工具）**

**5、更新 git 仓库上的配置，看各个客户端是否都更新**

**6、取消webhook，然后开效果**

**7、在 chrome 浏览器中演示如何只更新某个具体的微服务或使用通配符更新**

## **完整代码** ##

**配置动态刷新完整代码：[https://gitee.com/huan1993/spring-cloud-parent/tree/master/config/config-bus-webhook][https_gitee.com_huan1993_spring-cloud-parent_tree_master_config_config-bus-webhook]**

[https_www.rabbitmq.com_which-erlang.html]: https://www.rabbitmq.com/which-erlang.html
[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC8wODU1LzE5MjBiYzkxLTE1YzYtMzlmMS1iMmE3LWJkZjhiMGFiYTNmNC5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/f0ce013e71fb47398ea1faaed5abdd5f.png
[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC8wODYxLzdiYzBiYWNiLTUzMTUtMzI5MS05NDk3LTM3M2E4ZDYwZTNmNC5naWY]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/617e70858083404fafcac26f76e766f7.png
[https_gitee.com_huan1993_spring-cloud-parent_tree_master_config_config-bus-webhook]: https://gitee.com/huan1993/spring-cloud-parent/tree/master/config/config-bus-webhook