Nacos Spring

本文将介绍 nacos-spring-context 中的一些关键的特性：

• 注解驱动
• 依赖注入
• 外部化配置
• 事件驱动

1. 注解驱动

1.1. 启用 Nacos

@EnableNacos是一个模块驱动的注解，它支持 Nacos Spring 的所有功能，包括服务发现和配置管理。它等于 @EnableNacosDiscovery 加上 @EnableNacosConfig，可以单独配置并在不同场景中使用。

1.2. 配置监听

假设在 Nacos 服务中有一个配置，其 dataId 是 "testDataId" 而 groupId 是默认组（"DEFAULT_GROUP"）。 现在，您可以使用 ConfigService#publishConfig 方法更改其内容：

@NacosInjected
private ConfigService configService;
@Test
public void testPublishConfig() throws NacosException {
    configService.publishConfig(DATA_ID, DEFAULT_GROUP, "9527");
}

然后您可以添加一个监听器，它将监听配置的变化。 您可以通过在 Spring Bean 中添加配置变更监听器方法来执行此操作：

@NacosConfigListener(dataId = DATA_ID)
public void onMessage(String config) {
    assertEquals("mercyblitz", config); // asserts true
}

下面的代码具有相同的效果：

configService.addListener(DATA_ID, DEFAULT_GROUP, new AbstractListener() {
    @Override
    public void receiveConfigInfo(String config) {
        assertEquals("9527", config); // asserts true
    }
});

另外，@NacosConfigListener 支持更丰富的类型转换。

• 请参看： Simple Sample of @NacosConfigListener

1.2.1. 类型

@NacosConfigListener 的类型转换包括内置和自定义实现。 默认情况下，内置类型转换基于 Spring DefaultFormattingConversionService，这意味着它包好了大多数情况以及 Spring 框架更高级版本的丰富功能。

例如，前面示例中的内容 "9527" 也可以通过带 "int" 或 "Integer" 参数的方法进行监听：:

@NacosConfigListener(dataId = DATA_ID)
public void onInteger(Integer value) {
    assertEquals(Integer.valueOf(9527), value); // asserts true
}
@NacosConfigListener(dataId = DATA_ID)
public void onInt(int value) {
    assertEquals(9527, value); // asserts true
}

当然, nacos-spring-context 为开发人员提供弹性扩展。 如果定义名为nacosConfigConversionService的Spring Bean，其类型为ConversionService，则将忽略DefaultFormattingConversionService。 此外，您可以自定义NacosConfigConverter接口的实现，以指定类型转换的侦听器方法：

public class UserNacosConfigConverter implements NacosConfigConverter<User> {
    @Override
    public boolean canConvert(Class<User> targetType) {
        return true;
    }
    @Override
    public User convert(String source) {
        return JSON.parseObject(source, User.class);
    }
}

UserNacosConfigConverter 类绑定在 @NacosConfigListener.converter() 属性上，如下:

@NacosInjected
private ConfigService configService;
@Test
public void testPublishUser() throws NacosException {
    configService.publishConfig("user", DEFAULT_GROUP, "{\"id\":1,\"name\":\"mercyblitz\"}");
}
@NacosConfigListener(dataId = "user", converter = UserNacosConfigConverter.class)
public void onUser(User user) {
    assertEquals(Long.valueOf(1L), user.getId()); 
    assertEquals("mercyblitz", user.getName());
}

• 请参看：Type Conversion Sample of @NacosConfigListener

1.2.2. 超时时间

由于运行自定义的 NacosConfigConverter 可能需要一些时间，因此您可以在 @NacosConfigListener.timeout() 属性中设置最大执行时间，以防止它阻塞其他侦听器：

@Configuration
public class Listeners {
    private Integer integerValue;
    private Double doubleValue;
    @NacosConfigListener(dataId = DATA_ID, timeout = 50)
    public void onInteger(Integer value) throws Exception {
        Thread.sleep(100); // timeout of execution
        this.integerValue = value;
    }
    @NacosConfigListener(dataId = DATA_ID, timeout = 200)
    public void onDouble(Double value) throws Exception {
        Thread.sleep(100); // normal execution
        this.doubleValue = value;
    }
    public Integer getIntegerValue() {
        return integerValue;
    }
    public Double getDoubleValue() {
        return doubleValue;
    }
}

Listeners Bean 的 integerValue 总是为null，不会改变。 因此，以下断言都将是 true：

@Autowired
private Listeners listeners;
@Test
public void testPublishConfig() throws NacosException {
    configService.publishConfig(DATA_ID, DEFAULT_GROUP, "9527");
    assertNull(listeners.getIntegerValue()); // asserts true
    assertEquals(Double.valueOf(9527), listeners.getDoubleValue());   // asserts true
}

• 请参看：Timeout Sample of @NacosConfigListener

1.3. 全局和自定义 Nacos 属性

globalProperties 是任何 @EnableNacos，@EnableNacosDiscovery 或 @EnableNacosConfig 中的必选属性，其类型为 @NacosProperties。

globalProperties 将初始化为其他注解或组件的 "全局 Nacos 属性"，例如：@NacosInjected。

换句话说，全局 Nacos 属性 定义全局和默认属性。它设置为具有最低优先级，并且也可以被覆盖。覆盖优先级如下表所示：

*.properties() 定义来自以下之一的自定义 Nacos 属性：

• @NacosInjected.properties()
• @NacosConfigListener.properties()
• @NacosPropertySource.properties()
• @NacosConfigurationProperties.properties()

@NacosInjected
private ConfigService configService;
@NacosInjected(properties = @NacosProperties(encode = "UTF-8"))
private ConfigService configService2;
@NacosInjected(properties = @NacosProperties(encode = "GBK"))
private ConfigService configService3;
@NacosInjected
private NamingService namingService;
@NacosInjected(properties = @NacosProperties(encode = "UTF-8"))
private NamingService namingService2;
@NacosInjected(properties = @NacosProperties(encode = "GBK"))
private NamingService namingService3;
@Test
public void testInjection() {
    Assert.assertEquals(configService, configService2);
    Assert.assertNotEquals(configService2, configService3);
    Assert.assertEquals(namingService, namingService2);
    Assert.assertNotEquals(namingService2, namingService3);
}

• 请参看：Dependency Injection Sample

3. 外部化配置

外部化配置是 Spring Boot 引入的概念，它允许应用程序接收外部属性源以控制运行时行为。 Nacos Server 在应用程序外部运行单独的进程以维护应用程序配置。 nacos-spring-context 提供了对象绑定，动态配置（自动刷新）等功能。

这里有 nacos-spring-context 和 Spring Stack 之间的简单比较：

• 请参看：Auto-Refreshed Sample of @NacosConfigurationProperties
• 请参看：Sample of @NacosPropertySources and @NacosPropertySource

4. 事件驱动

Nacos 事件驱动 基于标准的 Spring Event / Listener 机制。 Spring 的 ApplicationEvent 是所有 Nacos Spring 事件的抽象超类：

• 请参看：Event/Listener Sample

相关项目

• Nacos
• Nacos Spring
• Nacos Spring Boot
• Spring Cloud Alibaba