Spring的@Value如何从Nacos配置中心获取值并自动刷新

2022-11-13 12:11:09 配置 获取 刷新

@Value从Nacos配置中心获取值并自动刷新

在使用Nacos作为配置中心时,除了@NacosValue可以做到自动刷新外,nacos-spring-context:0.3.4版本是支持@Value获取Nacos配置中心的值,并动态刷新的,该功能是Spri依靠ngValueAnnotationBeanPostProcessor类来实现:

@Override
    protected Tuple<String, NacosValueTarget> doWithAnnotation(String beanName,
            Object bean, Value annotation, int modifiers, Method method, Field field) {
        if (annotation != null) {
            if (Modifier.isStatic(modifiers)) {
                return Tuple.empty();
            }
 
            if (bean.getClass().isAnnotationPresent(NacosRefresh.class)) {
                String placeholder = resolvePlaceholder(annotation.value());
 
                if (placeholder == null) {
                    return Tuple.empty();
                }
 
                NacosValueTarget nacosValueTarget = new NacosValueTarget(bean, beanName,
                        method, field);
                nacosValueTarget.setAnnotationType(getAnnotationType().getSimpleName());
                logger.debug("@Value reGISter auto refresh");
                return Tuple.of(placeholder, nacosValueTarget);
            }
        }
        return Tuple.empty();
    }

分析其源码可以看到,如果bean上有注解@NacosRefresh,则会自动刷新。

在实际使用时,发现bean上的注解是@Configuration则不会自动刷新,而使用@Component则可以做到自动刷新。

代码如下:

@NacosRefresh
//@Component
@Configuration
public class BeanTest {
    
    @Value("${autofresh.test}")
    private String testValue;
    
    @NacosValue(value="${autofresh.test2}",autoRefreshed = true)
    private String testValue2;
 
    
    public String getTestValue2() {
        return testValue2;
    }
 
    
    public void setTestValue2(String testValue2) {
        this.testValue2 = testValue2;
    }
 
    
    public String getTestValue() {
        return testValue;
    }
 
    
    public void setTestValue(String testValue) {
        this.testValue = testValue;
    }
}

测试类:

@Test
     public void testValueRefreshinNacos() throws InterruptedException {
        System.out.println(beanTest.getTestValue());
        System.out.println(beanTest.getTestValue2()); 
        System.out.println("------修改前");
        
        Thread.sleep(1000*60);
        
        System.out.println(beanTest.getTestValue());
        System.out.println(beanTest.getTestValue2()); 
 
        System.out.println("------修改后");
     }

  

这就和@Component与@Configuration的区别有关了,@Component注解的bean是原生bean,@Configuration是被cglib动态增加的bean。

Nacos属性值自动刷新

1.@NacosValue获取最新值

引入jar包:  

          <dependency>
                 <groupId>com.alibaba.boot</groupId>
                 <artifactId>nacos-config-spring-boot-starter</artifactId>
                  <version>0.2.7</version>
            </dependency>

编写配置类:

       @Configuration
       @EnableNacosConfig(globalProperties = @NacosProperties(serverAddr = "127.0.0.1:8848"))
       @NacosPropertySource(dataid = "example", group="test",autoRefreshed = true)
        public class NacosConfiguration { }

编写测试类:

       @Controller
       public class ConfiGController {
         @NacosValue(value = "${test.data}", autoRefreshed = true)
           private boolean data;                                     
          @RequestMapping(value = "/test", method = GET)
          @ResponseBody
          public boolean get() { return data; }
      }

2.@Value获取最新值

引入jar包:  

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    <version>2.2.1.RELEASE</version>
</dependency>

引入配置:

spring:
  application:
    name: example
  cloud:
    nacos:
      config:
        extension-configs[0]:
          dataId: test.yml
          group: test
          refresh: true
        server-addr:  127.0.0.1:8848
        namespace: c845e96f-4423-4618-8c26-5e4d510f566a
        enabled: true
        refresh-enabled: true

编写测试类:

@RestController
@RefreshScope
public class TestController {
    @NacosValue(value = "${test.data}", autoRefreshed = true)
    private String data;
    @Value(value = "${test.data}")
    private String datas;
    @GetMapping("test")
    public String test() {
        return "data :" + data + ",datas="+datas;
    }
}

备注:

方式一@NacosValue获取最新值nacos配置信息需要写在配置类上

方式二@NacosValue获取不到值(如果需要使用该注解需要引入方式一的jar,但是不重启服务获取不到最新值),@Value获取最新值一定要加@RefreshScope注解,配置文件中配置refresh: true

以上为个人经验,希望能给大家一个参考,也希望大家多多支持。

相关文章