1. 背景介紹

        隨著系統複雜性增加和靈活化性，配置化的需求，需要能夠動態改變程式執行軌跡，在不同的場景下程式執行不同軌跡，說直白點就是不用重啟服務就能夠動態改變程式中物件對應的屬性值，根據推送的不同屬性值來路由不同的處理邏輯，使的系統能夠靈活路由。

2. 框架設計說明

2.1 框架需要解決的問題

        在設計drm框架的時候，需要考慮以下幾個問題：

（1） 持久化問題：就是在Client重啟的時候，應該如何保證Client能夠重新接收到屬於持久化標記的推送資訊？去伺服器端拉取？還是其他？

（2） 特定機器和全部機器推送的問題：如何實現對單臺或者多臺單獨推送的問題？如何實現對所有的機器廣播的問題？

（3） 推送操作日誌記錄問題：記錄推送的歷史

（4） 定時推送的問題

（5） 簡化Client實現：使得使用方方便的接入使用

2.2 總體框架

        Drm整體設計框架是利用Zookeeper作為配置中心的思想，通過Zookeeper提供的watch機制來實現Client對推送資訊的監聽，通過動態建立ZK目錄層次結構來實現動態配置資訊的推送，對應的目錄結構設計如下：

/CTFIN/DRM/系統名/特定機器名/類名/屬性名/persist 

/CTFIN/DRM/系統名 /特定機器名/類名/屬性名/nopersist 

/CTFIN/DRM/系統名 /all/類名/屬性名/persist 

/CTFIN/DRM/系統名 /all/類名/屬性名/nopersist 

/CTFIN/DRM/系統名 /all/ip/應用程式對應的ip地址（這個節點是臨時節點）

        就是客戶端在啟動的時候都去判斷對應的zk路徑：/CTFIN/DRM/系統名/all/類名/屬性名 是否存在，如果不存在，則進行建立，並且還會拉取已經存在的路徑/CTFIN/DRM/系統名/all/類名/屬性名/persist 和/CTFIN/DRM/系統名/特定機器/類名/屬性名/persist 對應的屬性值進行屬性設定---》實現了持久化功能；

        後臺在推送值時候會根據推送標記是否持久化，進行節點路徑persist和nopersist的建立，客戶端監控節點/CTFIN/DRM/系統名/特定機器/類名/屬性名 對應的資料變化，一旦該表則會通知客戶端，客戶端接收到到通知則會進行詳細屬性值得變更。

          應用程式對應的ip地址也放在對應的路徑上，是因為這樣後臺就能獲得應用程式部署到哪些機器上了（方便推送），這個路徑的建立也是在客戶端應用程式啟動的時候進行建立。

        管理後臺通過推送（建立對應的ZK node節點）將要推送到Client的資訊推送的配置中心ZK，即是在Zk上建立對應的目錄結構，Client通過監聽ZK對應節點的Child和Data 變更資訊來實現Client對應的配置資訊動態修改，為了進一步簡化客戶端的操作，定義了一套註解（DrmClassResource，DrmFieldResource）用於標記哪個類對應的哪個屬性需要通過drm動態推送。

2.2.1 管理推送端

對應的主要類圖如下：

其中介面DrmConfRequestParamPersist是需要使用方自己實現對應的推送日誌持久化操作的。

2.2.2 DRM client客戶端

客戶端對應的主要類圖如下：

            類DrmResourceParserFactory是整個Drm Client的核心，其主要的功能如下：

                （1）對應的init方法中，其會遍歷整個Spring Context找到有註解@DrmClassResource的類，並對這樣的類進行校驗，校驗點有是否有屬性有@DrmFieldResource註解和對應的類是否實現了DrmResourceManager介面（不進行判斷了，可以實現這個介面也可以不實現）。

            （2）根據Drm推送的資訊ClassName + fieldname 找到對應的實體Bean，在使用反射將對應的drmValue設定到被@DrmFieldResource之前，會呼叫對應實體bean的beforeUpdate方法，然後再進行反射設定值，值設定完成之後還會呼叫實體bean的afterUpdate方法。

         類ZkChangeMonitor是Client啟動的時候自動註冊和載入對應的perisist對應的內容和註冊對應的監聽器。

3. 使用說明

3.1 DRM admin使用

步驟：

（1）增加maven依賴

    <dependency>

            <groupId>com.ctfin.framework</groupId>

            <artifactId>drm</artifactId>

            <version>1.0.0</version>

    </dependency>

（2）實現介面DrmConfRequestParamPersist完成對應的推送日誌記錄操作

（3）在配置檔案中增加zkclient地址配置：

        如properties檔案中增加zk.server.addr=192.168.1.202:2181

       如yaml檔案中增加zk.server.addr: 192.168.1.202:2181

（4）呼叫DrmService對應的push方法即可

（5）增加Component 掃描路徑：com.ctfin.framework.drm.server

3.2 DRM Client使用

步驟：

（1）增加maven依賴

    <dependency>

            <groupId>com.ctfin.framework</groupId>

            <artifactId>drm</artifactId>

            <version>1.0.0</version>

    </dependency>

（2）在配置檔案中增加如下屬性：

            applicationName應用程式的名稱

            zk.server.addr: zk對應的地址和埠

            如yaml檔案中對應的配置如下：

                    applicationName: kccf

                    zk.server.addr: 192.168.1.202:2181

（3）註解需要推送的類和屬性（注意註解和需要實現的介面DrmResourceManager—）介面可以實現也可以不實現，不做強制要求）

（4）增加Component 掃描的路徑：com.ctfin.framework.drm.client

4. 原始碼地址

https://github.com/lwjaiyjk/drm

轉載請說明出處