消息总线 Spring Cloud Bus

缺乏、安全感 2023-02-26 04:20 23阅读 0赞

## SpringCloud视频教程： ##

[https://ke.qq.com/course/2805647?tuin=a3e3fb1&from\_uin=171851697&from=1000201007][https_ke.qq.com_course_2805647_tuin_a3e3fb1_from_uin_171851697_from_1000201007]

## 个人博客纯净版 ##

[http://www.51ufo.cn/%E5%BE%AE%E6%9C%8D%E5%8A%A1/%E5%88%86%E5%B8%83%E5%BC%8F/2020/07/11/SpringCloud%E5%85%A5%E9%97%A814-%E6%B6%88%E6%81%AF%E6%80%BB%E7%BA%BF-Spring-Cloud-Bus.html][http_www.51ufo.cn_E5_BE_AE_E6_9C_8D_E5_8A_A1_E5_88_86_E5_B8_83_E5_BC_8F_2020_07_11_SpringCloud_E5_85_A5_E9_97_A814-_E6_B6_88_E6_81_AF_E6_80_BB_E7_BA_BF-Spring-Cloud-Bus.html]

Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来。它可以用于广播配置文件的更改或者服务之间的通讯，也可以用于监控。这节课讲述的是用Spring Cloud Bus实现通知微服务架构的配置文件的更改。 准备工作

本文还是基于上一篇文章来实现。按照官方文档，我们只需要在配置文件中配置 spring-cloud-starter-bus-amqp ；这就是说我们需要装rabbitmq。至于怎么使用 rabbitmq，请自行百度

**改造config-client**

在pom文件加上起步依赖spring-cloud-starter-bus-amqp，完整的配置文件如下：

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
            <version>2.0.4.RELEASE</version>
        </dependency>
        <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>
    </dependencies>

在配置文件bootstrap.yml中加上rabbitmq的配置，包括rabbitmq的地址、端口，用户名、密码。并需要加上spring.cloud.bus的三个配置，具体如下：

server:
      port: 8881
    spring:
      application:
        name: config-client
      cloud:
        config:
          uri: http://localhost:8888/
          label: master
          profile: dev
        bus:
          enabled: true
          trace:
            enabled: true
      rabbitmq:
        host: 192.168.192.10
        port: 5672
        username: guest
        password: guest
    management:
      endpoints:
        web:
          exposure:
            include: bus-refresh

在Application启动类添加`@RefreshScope`注解 ，代码如下

@RefreshScope
    @RestController
    @SpringBootApplication
    public class Application {
        public static void main(String[] args) {
            SpringApplication.run(Application.class, args);
        }
        @Value("${user.name}")
        String name;
        @RequestMapping(value = "/hello")
        public String hi(){
            return "hello," + name;
        }
    }

分别启动config-server和config-client服务，在浏览器中访问[http://localhost:8881/hello][http_localhost_8881_hello] 返回信息如下：

hello,zhangsan

将git配置中的user.name属性改为如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoYW9qdW5tYQ_size_16_color_FFFFFF_t_70][]

通过postman发送post请求调用localhost:8881/actuator/bus-refresh，如下：

![postman.png][]

配置刷新后在浏览器再次访问[http://localhost:8881/hello][http_localhost_8881_hello]，返回信息如下：

hello,lisi

此时说明刷新配置生效了。

本文代码git地址 [https://gitee.com/xmingtx/springcloud-lesson.git][https_gitee.com_xmingtx_springcloud-lesson.git]

[https_ke.qq.com_course_2805647_tuin_a3e3fb1_from_uin_171851697_from_1000201007]: https://ke.qq.com/course/2805647?tuin=a3e3fb1&from_uin=171851697&from=1000201007
[http_www.51ufo.cn_E5_BE_AE_E6_9C_8D_E5_8A_A1_E5_88_86_E5_B8_83_E5_BC_8F_2020_07_11_SpringCloud_E5_85_A5_E9_97_A814-_E6_B6_88_E6_81_AF_E6_80_BB_E7_BA_BF-Spring-Cloud-Bus.html]: http://www.51ufo.cn/%E5%BE%AE%E6%9C%8D%E5%8A%A1/%E5%88%86%E5%B8%83%E5%BC%8F/2020/07/11/SpringCloud%E5%85%A5%E9%97%A814-%E6%B6%88%E6%81%AF%E6%80%BB%E7%BA%BF-Spring-Cloud-Bus.html
[http_localhost_8881_hello]: http://localhost:8881/hello
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoYW9qdW5tYQ_size_16_color_FFFFFF_t_70]: /images/20230209/82944af56e754508a8aa80117b384464.png
[postman.png]: /images/20230209/c524ccf03d2648ee902bca4ca2f1131b.png
[https_gitee.com_xmingtx_springcloud-lesson.git]: https://gitee.com/xmingtx/springcloud-lesson.git