【Spring Cloud】Spring Cloud之整合Spring Cloud Bus以及最佳实践

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

一、整合步骤

1）加入Maven坐标

　　　　　　　<!-- actuator监控模块 -->

            <dependency>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-starter-actuator</artifactId>

                <version>2.0..RELEASE</version>

            </dependency>

            <!--amqp-->

            <dependency>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-starter-amqp</artifactId>

                <version>2.0..RELEASE</version>

            </dependency>

            <!--spring cloud bus-->

            <dependency>

                <groupId>org.springframework.cloud</groupId>

                <artifactId>spring-cloud-starter-bus-amqp</artifactId>

                <version>2.0..RELEASE</version>

            </dependency>

2) 添加配置

spring.rabbitmq.host=localhost

spring.rabbitmq.port=

spring.rabbitmq.username=guest

spring.rabbitmq.password=guest


# 开放actuator/bus-refresh断点

management:

  endpoints:

    web:

      exposure:

        include: bus-refresh

3）程序代码引入配置参数的地方，添加@RefreshScope 注解，如下：

/**

 * @author zhangboqing

 * @date 2019-09-03

 */

@RestController

@RefreshScope

public class UserController {

    @Value("${pro1}")

    private String pro1;

    @ApiOperation(value = "用户模块-GET操作")

    @GetMapping(value = "get")

    public ApiResponseT get() {

        return ApiResponseT.builder().setData(pro1);

    }

}

4）启动程序，访问打印参数。然后修改参数，post方式请求http://localhost:10802/actuator/bus-refresh来刷新程序参数值，再访问参数发现值自动就更新来。
在同一个程序多实例的情况下，刷新其中一个实例，其他实例也会自动被刷新。

二、Spring Cloud Bus整合最佳实践

1）上面的整合步骤，在整个架构上如下图所示，这些微服务应用的实例中都引入了Spring Cloud Bus，所以它们都连接到了RabbitMQ的消息总线上。

我们可以从Git仓库中配置的修改到发起actuator/bus-refresh的POST请求这一步可以通过Git仓库的Web Hook来自动触发。由于所有连接到消息总线上的应用都会接收到更新请求，所以在WebHook中就不需要维护所有节点内容来进行更新，这样就不用通过Web Hook来逐个进行刷新每个程序配置的问题。

注意：actuator/bus-refresh断点有提供destination参数，用来定位具体要刷新的应用程序。此时总线上的各应用实例会根据destination属性的值来判断是否为自己的实例名，

，实例的默认命名按此规则生成：${spring.cloud.client.hostname}:${spring.applica-tion.name}:${spring.application.instance_id:${server.port}}}；

若符合才进行配置刷新，若不符合就忽略该消息。比如，我们可以请求actuator/bus/refresh?destination=user:9000或者actuator/bus/refresh?destination=user:**