初识Spring Cloud--Spring Cloud Bus在服务配置中心的简单应用

骑猪看日落 2022-03-09 10:44 156阅读 0赞

前面对配置中心进行了讲解，我们可以很明显的感受到使用spring cloud在处理配置方面的便捷性，然而，当托管到git等工具上的配置一旦发生变化，若采用前面的架构我们的每一个客户端都需要发送一遍请求，这势必会照成一些问题，这时候，spring cloud bus横空出世了。

下面，我们直接进入正题，通过一个简单的例子来进行测试：

首先，我们需要做一些准备的工作：安装zookeeper和kafka，考虑到这只是一个简单的测试，这里笔者通过docker进行了单机版的kafka部署:

![20190312234516441.PNG][]

进入kafka容器，创建Topic:

![20190312234557704.PNG][]

环境的搭建告一段落。

下面给出使用总线之后的新架构:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70][]

之前的项目中我们使用的spring-cloud版本都是Greenwich.M3，奈何这个版本比较新，暂时还不支持bus，所以我们这里需要将config server(sc10)，以及client(sc11)上的版本降级到Finchley.SR1，这边也算是一个坑吧，困扰了我很长时间。

![20190331115547575.PNG][]

我们添加bus相关的maven 依赖:

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-bus-kafka</artifactId>
    			<version>2.0.0.RELEASE</version>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-stream-kafka</artifactId>
    			<version>2.0.1.RELEASE</version>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-bus</artifactId>
    			<version>2.0.0.RELEASE</version>
    		</dependency>

然后对sc10以及sc11进行如下的配置：

首先是server端的配置：

spring.kafka.bootstrap-servers=your_ip:9092
    spring.kafka.consumer.group-id=test
    management.endpoints.web.exposure.include=*
    spring.cloud.bus.refresh.enabled=true

随后是client端的配置：

spring.kafka.bootstrap-servers=your_ip:9092
    spring.cloud.bus.refresh.enabled=true
    management.endpoints.web.exposure.include=*

下面我们来启动这两个服务：

![20190331120349210.PNG][]

在client端添加@RefreshScope注解：

@RefreshScope
    @RestController
    public class ConfigClientRestController {
        @Value("${spring.application.name}")
        private String applicationName;
        @Value("${eureka.client.serviceUrl.defaultZone}")
        private String eurekaServers;
        @Value("${server.port}")
        private String port;
        @Value("${info.company.name}")
        private String companyName;
    
        @GetMapping("/config")
        private Object getConfig() {
            String str = "applicationName  " + applicationName + "eurekaServers  " + eurekaServers + "port  " + port +"companyName  " + companyName;
            return str;
        }
    }

我们先来看看未进行更新时的配置信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 1][]

更改git上的代码:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 2][]

进行刷新：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 3][]

在一次查看client端的配置，bingo~修改成功！

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 4][]

[配置文件链接][Link 1]

[20190312234516441.PNG]: /images/20220309/498a294e9a4c46b0a962e18fcbca2a86.png
[20190312234557704.PNG]: /images/20220309/45eaf8dfd6ef4836b8fbf3df8dde1cbd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70]: /images/20220309/9c689129ff434791a39bfea496959b57.png
[20190331115547575.PNG]: /images/20220309/02a4337e36b44d07ac4277e08967289b.png
[20190331120349210.PNG]: /images/20220309/d76fb9f1c5ad409dbe40a2e85ad62dc4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 1]: /images/20220309/f5c38ba9af2941f49084837a5a749aec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 2]: /images/20220309/360dc0da3a994e6b8bb8273aaa8900e0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 3]: /images/20220309/169f97b0049746e9828b44a58b991204.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 4]: /images/20220309/d58f7192b406456592d9929711620265.png
[Link 1]: https://github.com/MemoryExplosion/cloudservice-config