「造個輪子」——cicada 設計一個配置模組
前言
在前兩次的 cicada 版本中其實還不支援讀取配置檔案,比如對埠、路由的配置。
因此我按照自己的想法建立了一個 issue ,也收集到了一些很不錯的建議。
最終其實還是按照我之前的想法來做了這個配置管理。
同時將cicada
升級到了v1.0.2
。
目標
在做之前是要把需求想好,到底怎樣的一個配置管理是對開發人員來說比較友好的?
我認為有以下幾點:
- 可以自定義配置,並且支援不同的環境(開發、測試、生產)。
- 使用靈活。對使用者來說不要有太多的束縛。
理論上來說配置這個東西應當完全獨立出來,由一個配置中心來負責管理並且這樣可以與應用解耦。
不過這樣的實現和當前 cicada
的定義有些衝突,我想盡量小的依賴第三方元件並可以完全獨立執行。
因此基於這樣的情況便有了以下的實現。
使用
在看實現之前先看看基於目前的配置管理如何在業務中使用起來。
結合現在大家使用 SpringBoot
的習慣,cicada
預設會讀取 classpath
下的 application.properties
配置檔案。並且會預設讀取其中的應用埠以及初始路由地址。
同時也新增了一個 api。
public class MainStart { public static void main(String[] args) throws Exception { CicadaServer.start(MainStart.class,"/cicada-example") ; } } public class MainStart { public static void main(String[] args) throws Exception { CicadaServer.start(MainStart.class) ; } }
這樣在不傳預設地址的時候 cicada
會從 application.properties
中讀取。
考慮到後面可維護的情況,cicada
也支援配置各種不同的配置檔案。
使用也比較簡單,只需要繼承 cicada
提供的一個抽象類即可。
public class KafkaConfiguration extends AbstractCicadaConfiguration { public KafkaConfiguration() { super.setPropertiesName("kafka.properties"); } } public class RedisConfiguration extends AbstractCicadaConfiguration { public RedisConfiguration() { super.setPropertiesName("redis.properties"); } }
按照這樣的配置也會預設從 classpath
讀取這兩個配置檔案。
當然這裡有個前提:程式碼裡配置的檔名必須得和配置檔名稱相同。
那如何在業務中讀取這兩個配置檔案的內容呢?
這也簡單,程式碼一看就懂:
- 首先需要通過
ConfigurationHolder
獲取各自不同配置的管理物件(需要顯式指定類型別)。 - 通過
get()
方法直接獲取配置。 - 同時也支援獲取
application.properties
裡的配置。
同時為了支援在不同環境的使用,當配置了啟動引數將會優先讀取。
-Dapplication.properties=/xx/application.properties
-Dkafka.properties=/xx/kakfa.properties
-Dredis.properties=/xx/redis.properties
這樣算是基本實現了上述的配置要求。
實現
要實現以上的功能有幾個核心點:
- 載入所有配置檔案。
- 將不同的配置檔案用不同的物件進行管理。
- 提供簡易的介面使用。
由於 cicada
需要支援多個配置檔案,所有需要定義一個抽象類供所有的配置管理實現。
定義比較簡單,其中有兩個重要的成員變數:
- 檔名稱:用於初始化時通過名稱載入配置檔案。
-
Properties
其實就是一個 Map 結構的快取,用於存放所有的配置。當然對外提供的查詢是基於它的。
接著就是在初始化時需要找出所有繼承了 AbstractCicadaConfiguration
的類。
查詢出來之後自然是要進行遍歷同時反射建立物件。
由於之前已經呼叫了
super.setPropertiesName("redis.properties");
來賦值配置檔名稱,所以還需要在遍歷過程中將 Properties
進行賦值。
同時在這裡也體現出優先讀取的是 VM 啟動引數中的配置檔案。
String systemProperty = System.getProperty(conf.getPropertiesName());
需要額外提一點的是:在查詢所有使用者自定義的配置管理類時需要手動將 cicada
內建的ApplicationConfiguration
加入其中。
因為使用應用的包名通過反射是查詢不出該類的。
儲存自定義配置管理
為了方便使用者在使用時候可以隨意的讀取各個配置檔案,所以還需要將反射建立的物件儲存到一個內部快取中,核心程式碼就是上上圖中的這段程式碼:
// add configuration cache
ConfigurationHolder.addConfiguration(aClass.getName(), conf);
其中 ConfigurationHolder
的定義如下。
其實也是利用一個 Map 來存放這些物件。
這樣在使用時候只需要取出即可。
KafkaConfiguration configuration = (KafkaConfiguration) getConfiguration(KafkaConfiguration.class);
String brokerList = configuration.get("kafka.broker.list");
重構
本次升級同時還重構了部分程式碼,比如啟動類。
現在看上去要清爽和直接的多:
其中也有一點需要注意的地方。
大家如果檢視日誌的話會發現應用啟動之後會列印本次的耗時,自然就是在啟動時候記錄一個時間,初始化完畢之後記錄一個即可。
在之前的實現中由於都是在一個方法內,所以直接使用就行了。
但現在優化之後跨越了不同的方法和類,難道要把時間作為引數在各個方法之前傳遞嘛?
那未免太不優雅了。
所以 ThreadLocal
就有了發揮餘地。
在初始化的方法中我將當前時間寫入:
ThreadLocalHolder.setLocalTime(System.currentTimeMillis());
在最後記錄日誌的地方直接取出比較即可:
這樣使用起來就完全不需要管什麼引數傳遞了。
同時 ThreadLocalHolder
的定義:
這裡還是有一點需要注意,在這種長生命週期的容器中一定得要記得及時清除。
我這裡的時間在查詢一次之後就不用了,所以完全放心的在 getLocalTime()
方法中刪掉。
總結
這就是本次 v1.0.2
中的升級內容,包含了配置支援以及程式碼重構。其中有些內容我覺得對接觸少的同學來說還是挺有幫助的。
關於上兩次的版本介紹請檢視這裡:
還沒點關注的朋友可以點波關注:
也歡迎大家參與一起維護!。
同時後續關於 cicada
的更新會放慢一些。會介紹一些平時實戰相關的內容,比如 Kafka 之類的,請持續關注。
你的點贊與轉發是最大的支援。