消息总线_Bus动态刷新全局广播-【官方】百战程序员_IT在线教育培训机构


xxxxxxxxxx
 <dependencies>
        <!--  引入Eureka client依赖   -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--  引入 config 依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <!--  引入 web 依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.22</version>
        </dependency>
    </dependencies>

新增yml配置文件bootstrap.yml


xxxxxxxxxx
spring:
  application:
    name: config-client
  cloud:
    config:
      label: master
      name: config
      profile: dev
      # 上述综合  master分支上config-dev.yml的配置文件
      # http://localhost:3344/master/config-dve.yml
      uri: http://localhost:3344
server:
  port: 3366
eureka:
  client:
    # 表示是否将自己注册到Eureka Server
    register-with-eureka: true
    # 示是否从Eureka Server获取注册的服务信息
    fetch-registry: true
    # Eureka Server地址
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
  instance:
    instance-id: cloud-config-center
    prefer-ip-address: true

management:
  endpoints:
    web:
      exposure:
        include: "*"

主启动类


xxxxxxxxxx
/**
 * 主启动类
 */
@Slf4j
@EnableEurekaClient
@SpringBootApplication
public class ConfigClient3366 {
    public static void main(String[] args) {
        SpringApplication.run(ConfigClient3366.class,args);
        log.info("********** ConfigClient3366 启动成功 *********");
    }
}

业务controller


xxxxxxxxxx
@RefreshScope
@RestController
public class ConfigClientController {

    @Value("${config.info}")
    private String configInfo;

    /**
     * 获取配置
     * @return
     */
    @GetMapping("/configinfo")
    public String getConfigInfo(){
        return configInfo;
    }

}

注意： 利用消息总线触发一个服务端ConfigServer的/bus/refresh端点,而刷新所有客户端的配置。

给3344,3355,3366工程添加消息总线支持

POM文件添加依赖


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

YML文件添加配置


xxxxxxxxxx
rabbitmq:
    host: 192.168.66.101
    port: 5672
    username: guest
    password: guest

一次发送出处生效

http://localhost:3355/actuator/busrefresh

Bus动态刷新定点通知

指具体某个实例生效而不是全部

示例


xxxxxxxxxx
http://localhost:3355/actuator/busrefresh/config-client:3355

消息总线_Docker安装RabbitMQ 消息驱动_什么是Spring Cloud Stream

北京市昌平区回龙观镇南店村综合商业楼2楼226室