SpringCloud(七)手把手教你使用消息总线Bus实现动态刷新-永久免费的源码丞旭猿-丞旭猿

还记得在上篇文章中使用Config配置中心的时候，如果远程配置文件修改了，那么需要post刷新请求，配置客户端才会获取最新的配置。这个问题就是如果配置中心修改了，我们需要向每个微服务刷新，大大提高了操作难度。而消息总线Bus使用消息队列中的发布订阅模式来帮我们解决了这个问题。

1. 简介

Spring Cloud Bus将分布式系统的节点与轻量级消息代理链接。这可以用于广播状态更改（例如配置更改）或其他管理指令。一个关键的想法是，Bus就像一个扩展的Spring Boot应用程序的分布式执行器，但也可以用作应用程序之间的通信渠道。当前唯一的实现是使用AMQP代理作为传输，但是相同的基本功能集（还有一些取决于传输）在其他传输的路线图上。（复制的官方文档）

简单的来说通过消息中间件作为传输，来广播命令。

接下来就是项目案例了，在本例中使用RabbitMQ作为消息中间件。

2. 安装RabbitMQ

安装rabbitmq可直接在docker中docker search rabbitmq进行下载启动，此处不过多介绍。

启动成功后的RabbitMQ，在浏览器中输入http://localhost:15672//可以看到如下界面，就说明RabbitMQ安装和启动成功.

3. 配置中心config-server-8600

我们依旧通过config-server-8600项目来作为配置中心，要对Bus的支持，我们需要引入一些依赖并修改配置。

3.1 pom.xml引入依赖

config-server-8600中需要引入消息总线和监控中心的依赖

org.springframework.cloudspring-cloud-starter-bus-amqporg.springframework.bootspring-boot-starter-actuator

然后总的pom.xml内容如下

xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">springcloudtestcom.elio.springcloud1.0-SNAPSHOT4.0.0springcloud-config-server-8600org.springframework.cloudspring-cloud-config-serverorg.springframework.cloudspring-cloud-starter-bus-amqporg.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.bootspring-boot-starter-web

3.2 修改application.yml配置文件

需要加入RabbitMQ的相关配置，还有就是暴露刷新接口。注意：

其中rabbitmq的服务端口是5672，而15672支持客户端的接口，不要配置错了。
bus-refresh 将会是刷新接口的地址，接下来会通过http://localhost:8600/actuator/bus-refresh接口来进行刷新

rabbitmq:
    host: localhost  rabbitmq主机
    port: 5672       rabbitmq端口，注意是5672而不是15672
    username: guest  用户名
    password: guest  密码

management:
  endpoints:
    web:
      exposure:
        include: bus-refresh  指定刷新地址

然后总的application.yml配置内容如下

server:
  port: 8600 端口号

spring:
  application:
    name: springcloud-config-server  应用名称
  cloud:
    config:
      server:
        git:
          uri: https:  git地址
          username:   git账号名
          password:   git账号密码
  rabbitmq:
    host: localhost  rabbitmq主机
    port: 5672       rabbitmq端口，注意是5672而不是15672
    username: guest  用户名
    password: guest  密码

eureka:
  instance:
    instance-id: ${spring.application.name}:${server.port}
  client:
    fetch-registry: true
    register-with-eureka: true
    service-url:
      defaultZone: http://localhost:8300/eureka/,http://localhost:8301/eureka/

management:
  endpoints:
    web:
      exposure:
        include: bus-refresh  指定刷新地址

4. 配置客户端product-provider-8100

完成了配置中心的配置后，接下来就是要配置客户端product-provider-8100了。

4.1 修改pom.xml引入依赖

org.springframework.cloudspring-cloud-starter-bus-amqporg.springframework.bootspring-boot-starter-actuator

4.2 修改bootstrap.yml配置文件

bootstrap.yml 只用加入rabbitMQ的相关配置即可

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

总的bootstrap.yml内容如下

spring:
  cloud:
    config:
      name: configtest  获取配置文件的名称
      profile: pro  配置的策略pro-生产 test-测试 dev-开发
      label: master  分支
      discovery:
        enabled: true  开启配置信息发现
        service-id: springcloud-config-server  指定配置中心的service-id
  rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest

eureka:
  instance:
    instance-id: ${spring.application.name}:${server.port}
  client:
    fetch-registry: true
    register-with-eureka: true
    service-url:
      defaultZone: http://localhost:8300/eureka/,http://localhost:8301/eureka/

management:
  endpoints:
    web:
      exposure:
        include: refresh,health

4.3 确定访问接口

获取远程配置文件的接口是没有变动的，记得要加上@RefreshScope注解

@RestController@Slf4j@RequestMapping("/")@RefreshScopepublicclassProductProviderController{@ResourceprivateProductServiceproductService;@Value("${spring.application.name}")privateStringinstantName;@Value("${server.port}")privateStringport;@Value("${hello}")privateStringhello;@GetMapping("product/provider/get/config/info")publicResultgetConfigInfo()throwsException{returnnewResult(200,"",this.hello);}}

5. 测试

依次启动eureka-server-8300，eureka-server-8301，config-server-8600，product-provider-8100项目后，接下来进行以下步骤：

修改码云上的configtest-pro.yml文件，文件内容修改成如下

hello: hello from configtest-pro modified three times

然后打开cmd窗口，输入以下命令

curl -X POST http://localhost:8600/actuator/bus-refresh

命令窗口

然后浏览器地址中输入product-provider-8100的访问接口http://localhost:8100/product/provider/get/config/info

成功刷新

最终测试结果和预期的一样，在这个例子中笔者只用一个微服务来做测试，其实多个微服务效果一样，可以通过消息总件的形式，就能够实现广播配置文件变动事件了。

6.总结

本文简单的介绍了如何通过Bus + RabbitMQ来实现动态刷新，具体的原理和工作流程本文没有叙述，希望对只是想通过小实践来学习的同学有所帮助。

声明：本文部分素材转载自互联网，如有侵权立即删除。

1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！邮箱：cxysz1@tom.com
2. 分享目的仅供大家学习和交流，您必须在下载后24小时内删除！
3. 不得使用于非法商业用途，不得违反国家法律。否则后果自负！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系管理员处理！
6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，请使用WINRAR解压,如遇到无法解压的请联系管理员！
8. 精力有限，不少源码未能详细测试（解密），不能分辨部分源码是病毒还是误报，所以没有进行任何修改，大家使用前请进行甄别
丞旭猿论坛

THE END

行业资讯