Nacos 中配置 Map 類型，不香！
大家好，我是君哥。
最近在使用 Nacos 過程中遇到一個場景，配置的字符串可以解析成 Map 類型使用，有一個配置如下：
map:
test: key1:value1,key2:value2,key3:value3
后來有同事建議 Nacos 可以直接配置成 Map 類型，后臺使用 Java Map 類型獲取就可以。配置如下：
map:
test:
key1: value1
key2: value2
key3: value3
下面就來分享一下配置 Map 類型的過程中遇到的問題。
1.使用 Bean 方式獲取配置
1.1 使用方式
參考網上的一些案例，第一個方式是把讀取到的 Map 作為一個 Spring 的 Bean，一看代碼就明白了。
@Bean
@ConfigurationProperties(prefix = "map.test")
public Map<String, String> mapping() {
return new HashMap<>();
}
1.2 槽點
這樣確實可以把 Nacos 中讀取到的配置轉換成 Map 類型，但一個致命的槽點就是 mapping 這個 bean 不能自動刷新。這樣如果修改了 Nacos 中配置，要想讓配置生效，就必須重啟應用服務，這怎么能接受呢?
2.ConfigurationProperties
2.1 使用方式
直接使用 @Value 和 @NacosValue 是獲取不到值的。下面的這種方式，類的定義上加注解 @ConfigurationProperties，再定義一個變量，名稱跟 Nacos 中配置的后綴一樣，這樣是可以獲取到 Map 類型的配置的。
@Component
@RefreshScope
@ConfigurationProperties(prefix = "map")
public class NacosRefresh {
private Logger logger = LoggerFactory.getLogger(getClass());
public void setTest(Map<String, String> test) {
this.test = test;
}
private Map<String, String> test;
}
注意：上面的 setTest 方法是必須要的，不然 test 變量取不到值。
2.2 槽點
這樣確實可以把 Nacos 中讀取到的配置轉換成 Map 類型，但是跟第一種方式一樣，定義的 Map 類型變量不能自動刷新。
3.使用監聽
Nacos API 提供了監聽功能，可以監聽配置的變化，對變化進行處理，只要在監聽方法上增加 @NacosConfigListener 這個注解就可以生效。見下面代碼：
@Service
public class NacosListener {
private Logger logger = LoggerFactory.getLogger(getClass());
private Map<String, String> map = new HashMap<>();
@NacosConfigListener(dataId = "maptest.yaml",groupId = "DEFAULT_GROUP")
public void listener(String context){
logger.info("================listener context:{}", context);
if (StringUtils.isBlank(context)){
return;
}
Yaml yaml = new Yaml();
Map<String, Object> contextMap = yaml.load(context);
Map<String, Object> map = (Map<String, Object>)contextMap.get("map");
if (CollectionUtils.isEmpty(map)){
return;
}
Map<String, String> test = (Map<String, String>) map.get("test");
if (CollectionUtils.isEmpty(test)){
return;
}
map.clear();
map.putAll(test);
map.forEach((k,v) -> logger.info("Entry in map, key:{},value:{}", k, v));
}
}
這段代碼是從 Nacos 配置中解析出 Map 類型的配置，然后把配置 put 到本地變量 map。這個也可以完成我們的需求，但是有幾點需要注意。
3.1 服務重啟
如果服務重啟了，本地變量 map 拉不到值。因為上面監聽的邏輯并沒有走，即使在 Nacos 上重新發布一下，也不行。
上面的監聽方法，只有在 Nacos 配置發生變化并且發布后才會觸發，比如 map.test 配置改變如下：
map:
test:
key1: value1
key2: value2
key3: value3
key4: value4
3.2 并發問題
上面監聽的代碼里面，需要把本地變量 map 先 clear 然后再 putAll，如果這兩個方法調用中間發生了線程上下文切換，讀取線程可能會因為從 map 中取不到值而發生異常。
4.改進
上面講解了使用 Nacos 配置 Map 類型的坑，不過使用 Nacos 配置 Map 類型也有個好處，不用解析字符串，直接可以轉成 Map 類型。
4.1 使用字符串
完全不使用 Map 類型了，改成配置字符串，配置如下：
map:
test: key1:value1,key2:value2,key3:value3
解析代碼如下：
@NacosValue(value = "${map.test}", autoRefreshed = true)
private String mapTest;
public String get(String key){
String[] keys = mapTest.split(",");
for (String item : keys){
if (!item.contains(key)){
continue;
}
return item.split(":")[1];
}
return null;
}這種寫法的好處是不用監聽 Nacos，配置改變后 mapTest 變量自動刷新，缺點是每次調用 get 方法都需要解析 mapTest 這個字符串。
4.2 刷新本地 Map
把解析字符串的結果放到本地變量 map 上，考慮到 Nacos 中配置可能會發生變化，用定時線程池每 1 秒刷新一次，代碼如下：
private Map<String, String> map = new HashMap<>();
@NacosValue(value = "${map.test}", autoRefreshed = true)
private String mapTest;
@PostConstruct
public void refreshLocalMap(){
ScheduledThreadPoolExecutor scheduled = new ScheduledThreadPoolExecutor(1);
scheduled.scheduleAtFixedRate(() -> refresh(), 0, 1000, TimeUnit.MILLISECONDS);
}
public void refresh(){
String[] keys = mapTest.split(",");
for (String item : keys){
String[] kv = item.split(":");
map.put(kv[0], kv[1]);
}
}
這個寫法的好處是不用每次調用都解析字符串，而是由異步線程每秒鐘刷新。但是也有兩個問題：
- 需要一個定時線程池，會消耗 CPU 資源。
- refresh 方法是每秒執行一次，會有短暫的本地變量和 Nacos 配置不一致的問題。
5.總結
Nacos 中配置 Map 類型確實不香，主要原因是刷新不方便。但是對于配置不需要刷新的場景，還是很有好處的，尤其是 key 比較多的時候，比解析字符串方便很多，而且 Hash 的時間復雜度是 o(1) ，在數據結構中是最優秀的。
對于需要刷新的場景，無論使用哪種方案，都有優缺點，沒有最好的，只有最適合的，要根據系統的業務場景來做選擇。
