三种手段:通过Apollo和nacos的能力进行国际化动态配置实现热更新

简介: 本文主要介绍了 通过Apollo和nacos的能力进行国际化热更新的实战,有三个方案,代码实现过程中遇到的一些问题,做了一些解决和说明。

通过Apollo和nacos的能力进行国际化热更新

1.apollo的自动刷新

Apollo(阿波罗)是一款可靠的分布式配置管理中心,有了它,我们可以用来做很多事情:配置的热更新,配置监听,灰度发布,微服务的多环境配置隔离等。项目中引入apollo-client,就可以做到已上功能。

maven依赖:

<dependency>
    <groupId>com.ctrip.framework.apollo</groupId>
    <artifactId>apollo-client</artifactId>
    <version>1.8.0</version>
</dependency>

通过注解@ApolloConfigChangeListener定义监听逻辑,可以指定监听的namespace,可以指定感兴趣的key。就像是事件机制一样,当一个事件感兴趣的事件过来的时候,我们可以监听并处理一些特殊的操作。

定义一个配置类并且注入到spring容器中就生效了。

public class ApolloListenerConfig {
    @ApolloConfigChangeListener({"test-i18n_zh_CN"})
    public void propertiesChanged(ConfigChangeEvent changeEvent) {
        log.info("changeEvent namespace {}", changeEvent.getNamespace());
        Set<String> set = changeEvent.changedKeys();
        set.forEach(key -> {
            ConfigChange change = changeEvent.getChange(key);
            String newValue = change.getNewValue();
            if (change.getChangeType() == PropertyChangeType.DELETED) {
                properties.remove(key);
            } else if (change.getChangeType() == PropertyChangeType.MODIFIED) {
                properties.setProperty(key, newValue);
            } else {
                properties.put(key, newValue);
            }
        });
    }
}
返回值: changeEvent namespace test-i18n_zh_CN,测试成功,后续我们会使用这个监听机制来实现本地国际化配置的刷新。其中对于每一个key都可以有增删改的事件,以方便我们进行特殊的处理。

2.借助apollo实现语言配置的界面化

接下来就是借助apollo的配置界面来实现我们的语言配置的界面化。我们会在项目对应的apollo配置中新增一个新的namespace:test-i18n_zh_CN,它会对应我们本地的国际化配置文件test-i18n_zh_CN.properties

image-20230214170837520

在项目中resource目录下创建test-i18n_zh_CN.properties,其中内容为:

welcome=你好,世界!

我们可以随意的使用apollo的配置界面进行配置的增删改,并且还可以进行回滚,历史审计,环境隔离,从而保障配置的动态远程配置,隔离性,可审计。

image-20230214171656555

至此,主要是把apollo的一些界面操作做了一些铺垫,我们在界面的操作,客户端会准实时的感知到,并且基于上文提到的监听,我们能按需进行一些操作。

上一篇文章《从源码看Spring的i18n·优雅的国际化实战》,我们对spring的I18n的组件MessageSource进行了源码剖析,并对比了他的三个实现。接下来,我们谈谈怎么如何结合apollo的能力做到语言配置的动态刷新。

3.Apollo&i18n的动态刷新

3.1 纯编码内存·方案

《从源码看Spring的i18n·优雅的国际化实战》一文也提到过StaticMessageSource可以通过编码的形式来自定义配置源。从这一点出发,我们可以借助apollo去维护内存中的配置信息。

首先,自定义MineApolloStaticMessageSource,定义语言配置的初始化。

@Component
@Slf4j
public class MineApolloStaticMessageSource extends  StaticMessageSource implements InitializingBean {
​
    private List<String> namespaces= Arrays.asList("test-i18n_zh_CN","test-i18n_en_UK");
    @Override
    public void afterPropertiesSet() throws Exception {
        for (String namespace : namespaces) {
            final Config config = ConfigService.getConfig(namespace);
            final Set<String> keys = config.getPropertyNames();
            for (String key : keys) {
                final String value = config.getProperty(key, "");
                if (StringUtils.isNotBlank(value)){
                    final String[] locate = namespace.split("_");
                    addMessage(key,new Locale(locate[1],locate[2]),value);
                }
            }
        }
​
    }
}

然后,定义监听配置更新,刷新内存中的国际化配置。

@ApolloConfigChangeListener({"test-i18n_zh_CN","test-i18n_en_UK"})
public void propertiesChanged(ConfigChangeEvent changeEvent) {
    try {
        final String namespace = changeEvent.getNamespace();
​
        Set<String> set = changeEvent.changedKeys();
        set.forEach(key -> {
            ConfigChange change = changeEvent.getChange(key);
            String newValue = change.getNewValue();
            final String[] locate = namespace.split("_");
            if (change.getChangeType() == PropertyChangeType.DELETED) {
                messageSource.addMessage(key,new Locale(locate[1],locate[2]),"");
            }else {
                messageSource.addMessage(key,new Locale(locate[1],locate[2]),newValue);
            }
​
            log.info(" namespace {} key {} newValue {}",namespace,key,newValue);
        });
    } catch (Exception e) {
        log.warn("", e);
    }
}

apollo配置界面中我们定义了俩个namespace,分别是"test-i18n_zh_CN","test-i18n_en_UK",并且用于测试已经添加了一些key。

image-20230215142624724

项目启动之后,我们做个简单的测试。

Locale zhLocale=new Locale("zh","CN");
Locale enLocale=new Locale("en","UK");
final String zhMessage = apolloStaticMessageSource.getMessage(code, null, zhLocale);
​
final String enMessage = apolloStaticMessageSource.getMessage(code, null, enLocale);
log.info("位于中国,消息为 {}",zhMessage);
log.info("in UK,message {}",enMessage);

查看日志,可以看到俩条输出:

位于中国,消息为 你好,世界!!

in UK,message hello world!

3.2 结合静态配置文件·方案

MessageResource还有一个实现ReloadableResourceBundleMessageSource,通过监听本地文件从而能够在指定时间内刷新国际语言的配置。在这里我们也来实现一下这个方案。

首先,先创建ReloadableResourceBundleMessageSource实例,并注入到spring容器中,我们可以定义语言配置的存储目录,缓存的刷新检查间隔,设置语言编码等。

@Bean
public ReloadableResourceBundleMessageSource i18nMessageSource() {
    ReloadableResourceBundleMessageSource messageSource = new ReloadableResourceBundleMessageSource();
    messageSource.setBasename("classpath:i18n/message");
    messageSource.setCacheSeconds(120);
    messageSource.setUseCodeAsDefaultMessage(true);
    messageSource.setDefaultEncoding("utf-8");
    log.info("*** i18n message source loaded ***");
    return messageSource;
}

在resource目录下,有俩个配置文件,

" test-i18n_zh_CN.properties"

"test-i18n_en_UK.properties"

apollo配置界面中我们定义了俩个namespace,分别是"test-i18n_zh_CN","test-i18n_en_UK",和上文图片一致。

最大的不同是对于监听事件的处理需要定制化,基于ReloadableResourceBundleMessageSource的刷新静态文件机制来实现国际化语言配置的刷新。

@ApolloConfigChangeListener({"test-i18n_zh_CN","test-i18n_en_UK"})
public void propertiesChanged2(ConfigChangeEvent changeEvent) {
    try {
        String resourceName = changeEvent.getNamespace() + ".properties";
        log.info("resourceName:{}", resourceName);
        final File file = new File(getClass().getProtectionDomain().getCodeSource().getLocation().getPath() + "/" + resourceName);
        Properties properties = new Properties();
        properties.load(new InputStreamReader(new FileInputStream(file), Charset.forName("UTF-8")));
​
        Set<String> set = changeEvent.changedKeys();
        set.forEach(key -> {
            ConfigChange change = changeEvent.getChange(key);
            String newValue = change.getNewValue();
            if (change.getChangeType() == PropertyChangeType.DELETED) {
                properties.remove(key);
            } else if (change.getChangeType() == PropertyChangeType.MODIFIED) {
                properties.setProperty(key, newValue);
            } else {
                properties.put(key, newValue);
            }
        });
​
        OutputStreamWriter writer = new OutputStreamWriter(new FileOutputStream(file), StandardCharsets.UTF_8);
        properties.store(writer, "properties reload");
    } catch (Exception e) {
        log.warn("properties reload error", e);
    }
}

项目启动之后,我们做个简单的测试。

Locale zhLocale=new Locale("zh","CN");
Locale enLocale=new Locale("en","UK");
final String zhMessage = apolloStaticMessageSource.getMessage(code, null, zhLocale);
​
final String enMessage = apolloStaticMessageSource.getMessage(code, null, enLocale);
log.info("位于中国,消息为 {}",zhMessage);
log.info("in UK,message {}",enMessage);

修改apollo的配置,可以发现message和apollo一致,动态配置生效。查看日志,可以看到俩条输出:

位于中国,消息为 three.body in UK,message Dark Forest Rule

同时,我们也用到了ReloadableResourceBundleMessageSource定时缓存刷新机制,在apollo更新之后,120秒之后,才会感知新的配置,读取新的message。

3.3 优化点·初始刷新静态文件

在测试的过程中,发现这种方式下存在一个小问题,就是apollo不触发刷新,本地的静态语言配置和apollo是不一致的,就算我们服务发布上线了,也只有本地文件中的默认值,这样就出问题了。所以我们需要在项目启动时去初始更新apollo中的配置到本地文件:

@Override
public void afterPropertiesSet() throws Exception {
    for (String namespace : namespaces) {
        final Config config = ConfigService.getConfig(namespace);
        final Set<String> keys = config.getPropertyNames();
        Properties properties = new Properties();
        String resourceName = namespace + ".properties";
        log.info("resourceName:{}", resourceName);
        final File file = new File(getClass().getProtectionDomain().getCodeSource().getLocation().getPath() + "/" + resourceName);
        for (String key : keys) {
            final String value = config.getProperty(key, "");
            if (StringUtils.isNotBlank(value)){
                properties.setProperty(key,value);
            }
        }
        OutputStreamWriter writer = new OutputStreamWriter(new FileOutputStream(file), StandardCharsets.UTF_8);
        properties.store(writer, "properties reload");
    }
​
}

经过测试,在项目启动之后,本地文件的内容会被apollo刷新,同时定时缓存刷新机制也ok,这样子就可以基于以上的方案进行国际化动态配置了。

4.基于Nacos的热更新

基于ReloadableResourceBundleMessageSource+nacos同样可以做到上文的效果,原理都是想通的,我们借助nacos的配置界面配置多个语言配置,其实本质来说,他们就映射本地语言配置的properties。

image-20230215183919868

然后就是改造ReloadableResourceBundleMessageSource的方法,改造读取properties的方法,只需要将从本地文件读取变成改成从nacos中读取即可。

final Properties props = newProperties();
final String dataId = filename + NacosConstants.PROPERTIES_SUFFIX;
logger.info("Loading properties for " + dataId);
final String config = nacosConfigManager.getConfigService().getConfig(dataId, nacosGroup, 3000);

还有就是改造refreshProperties刷新的流程,我们通过nacos的监听机制,获取到刷新事件之后,就可以直接刷新本地缓存中的properties,本质上和上文一样,更新的是缓存中的properties。

ConfigService configService = nacosConfigManager.getConfigService();
configService.addListener("fileName.properties", "group", new Listener() {
    @Override
    public Executor getExecutor() {
        return executor;
    }
​
    @Override
    public void receiveConfigInfo(String configInfo) {
        //刷新缓存的properties,省略
    }
});

已上,就是基于nacos的刷新方案。此方案省略了本地的静态文件,依赖于nacos的配置拉取。

其实,apollo也可以这样子的思路去实现。就只论配置中心来说,相比于nacos,apollo的环境隔离性,审计能力,权限控制更胜一筹。nacos想要有这些细粒度的功能就得上付费版的MSE套件了。

国际化方案的实现有很多,还需要前端的配合,比如Vue也有国际化方案,正在用于生产环境的方案需要好好推敲,适合自己业务的方案才是好的方案。

目录
相关文章
|
4月前
|
NoSQL Java Nacos
SpringCloud集成Seata并使用Nacos做注册中心与配置中心
SpringCloud集成Seata并使用Nacos做注册中心与配置中心
112 3
|
3天前
|
SQL 关系型数据库 数据库连接
"Nacos 2.1.0版本数据库配置写入难题破解攻略:一步步教你排查连接、权限和配置问题,重启服务轻松解决!"
【10月更文挑战第23天】在使用Nacos 2.1.0版本时,可能会遇到无法将配置信息写入数据库的问题。本文将引导你逐步解决这一问题,包括检查数据库连接、用户权限、Nacos配置文件,并提供示例代码和详细步骤。通过这些方法,你可以有效解决配置写入失败的问题。
10 0
|
2月前
|
负载均衡 Java Nacos
SpringCloud基础2——Nacos配置、Feign、Gateway
nacos配置管理、Feign远程调用、Gateway服务网关
SpringCloud基础2——Nacos配置、Feign、Gateway
|
3月前
|
安全 Nacos 数据安全/隐私保护
升级指南:从Nacos 1.3.0 到 2.3.0,并兼容 Seata 的鉴权配置
本文详细介绍了如何在微服务环境下从 Nacos 1.3.0 升级到 2.3.0,并确保 Seata 各版本的兼容性。作者小米分享了升级过程中的关键步骤,包括备份配置、更新鉴权信息及验证测试等,并解答了常见问题。通过这些步骤,可以帮助读者顺利完成升级并提高系统的安全性与一致性。
106 8
升级指南:从Nacos 1.3.0 到 2.3.0,并兼容 Seata 的鉴权配置
|
3月前
|
运维 Java Nacos
Spring Cloud应用框架:Nacos作为服务注册中心和配置中心
Spring Cloud应用框架:Nacos作为服务注册中心和配置中心
|
3月前
|
应用服务中间件 Nacos 数据库
Nacos 1.2.1 集群搭建(三) Nginx 配置 集群
Nacos 1.2.1 集群搭建(三) Nginx 配置 集群
61 1
|
3月前
|
SQL 关系型数据库 MySQL
Nacos 1.2.1 集群搭建(二)MySQL、cluster 配置
Nacos 1.2.1 集群搭建(二)MySQL、cluster 配置
72 1
|
3月前
|
缓存 Cloud Native Java
【紧急救援】Nacos配置上线后失效?手把手教你如何轻松搞定命名空间修改难题!
【8月更文挑战第15天】Nacos是关键的云原生服务管理平台,用于动态服务发现与配置管理。但在使用其管理微服务配置时,可能会遇到命名空间内的配置更新后不生效的问题。本文探讨此问题并提供解决方案。首先需确认Nacos服务器运行正常及客户端正确连接。接着检查客户端缓存配置,可通过禁用缓存或缩短缓存间隔来即时更新配置。例如,在Spring Cloud Alibaba Nacos配置中心中启用自动刷新功能,并设置每5秒拉取新配置。同时,对于新增配置项,需重启客户端应用。还需检查Nacos服务器日志排除异常,并考虑升级Nacos版本解决兼容性问题。通过这些步骤,通常可有效解决配置不生效的难题。
155 0
|
3月前
|
安全 Nacos 数据库
【技术安全大揭秘】Nacos暴露公网后被非法访问?!6大安全加固秘籍,手把手教你如何保护数据库免遭恶意篡改,打造坚不可摧的微服务注册与配置中心!从限制公网访问到启用访问控制,全方位解析如何构建安全防护体系,让您从此告别数据安全风险!
【8月更文挑战第15天】Nacos是一款广受好评的微服务注册与配置中心,但其公网暴露可能引发数据库被非法访问甚至篡改的安全隐患。本文剖析此问题并提供解决方案,包括限制公网访问、启用HTTPS、加强数据库安全、配置访问控制及监控等,帮助开发者确保服务安全稳定运行。
251 0
|
3月前
|
安全 Nacos 数据安全/隐私保护
【技术干货】破解Nacos安全隐患:连接用户名与密码明文传输!掌握HTTPS、JWT与OAuth2.0加密秘籍,打造坚不可摧的微服务注册与配置中心!从原理到实践,全方位解析如何构建安全防护体系,让您从此告别数据泄露风险!
【8月更文挑战第15天】Nacos是一款广受好评的微服务注册与配置中心,但其连接用户名和密码的明文传输成为安全隐患。本文探讨加密策略提升安全性。首先介绍明文传输风险,随后对比三种加密方案:HTTPS简化数据保护;JWT令牌减少凭证传输,适配分布式环境;OAuth2.0增强安全,支持多授权模式。每种方案各有千秋,开发者需根据具体需求选择最佳实践,确保服务安全稳定运行。
247 0