SpringCloud(十四)springCloud bus 消息总线刷新配置

前言:

     在微服务中,我们将使用轻量级消息代理,通过一个共用的消息主题,让系统中所有微服务都连上来,主题中的消息会被所有监听者消费,所以称为消息总线。spring cloud bus将分布式节点用轻量级消息连接起来,他可以用于服务间通讯,例如:配置文件的更改。可以用kafka、rabbitmq等

 代码:

      基于springboot2.0

首先基于上一篇的代码(搭建eureka、config、一个测试功能的微服务)

eureka和配置中心config不用做任何更改


修改测试微服务的pom.xml,加入下面这两个依赖

<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>

第一个包,需要rabbitmq,所以需要搭建rabbitmq服务器,第二个是程序监控的包,用于暴露bus-refresh端口,用作刷新配置

<?xml version="1.0" encoding="UTF-8"?>
<project 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">
    <modelVersion>4.0.0</modelVersion>

    <artifactId>eureka-service</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>eureka-service</name>

    <parent>
        <groupId>com.xhx.springcloud</groupId>
        <artifactId>springcloud15-bus</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </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>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

修改bootstrap.yml,其中spring.cloud.config.name 可写多个参数,根据名字在配置中心拉取配置文件,我把rabbitmq的配置也放在了git上

spring:
  cloud:
    config:
      discovery:
        enabled: true
        service-id: config-service
      label: master
      profile: prd
      name: eureka-service,rabbit-mq
    bus:
      refresh:
        enabled: true
  application:
    name: eureka-service
management:
  endpoints:
    web:
      exposure:
        #暴露bus-refresh节点,通过此节点刷新配置
        include: '*'

rabbitmq的dev和prd环境配置如下(自己做测试,所以写的一样的配置)

spring:
  rabbitmq:
    host: 192.168.94.151
    port: 5672
    username: admin
    password: admin
    virtual-host: /

在eureka-sevice配置文件中加入user.name,一会测试时修改他的value

server:
  port: 8082
eureka:
  client:
    service-url:
      default-zone: http://localhost:8761/eureka
  instance:
    #租期到期时间
    lease-expiration-duration-in-seconds: 60
    #租期更新时间间隔,即每15秒发送一次心跳
    lease-renewal-interval-in-seconds: 15
user:
  name: xuhaixing02


在读取配置的那个类上加入@RefreshScope,必须加,否则刷新不生效

package com.xhx.springcloud.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.validation.Valid;

/**
 * xuhaixing
 * 2018/6/3 16:18
 */
@RestController
@RequestMapping(value = "hello")
@RefreshScope
public class HelloController {

    @Value("${user.name}")
    private String name;

    @RequestMapping(value = "getName")
    public String getName(){
        return name;
    }
}


然后启动就可以了:

第一次访问:



把上面的值修改成xuhaixing01,直接再请求值未生效。需要先请求127.0.0.1:8082/actuator/bus-refresh

看程序的控制台日志,在请求配置中心下载配置


仔细观察全部打印出来的日志,还发现了,在刷新user.name注入的值


再次请求,结果已经变成了xuhaixing01



这样必须手动刷新,还是不好,如果有外网可以访问的固定ip,可以配置git的webhooks,设置去请求这个方法,来达到刷新配置的目的

127.0.0.1:8082/actuator/httptrace 可以看到调用


我的git代码地址

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在,都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多程序园信息
开发小院