基於zookeeper實現統一配置管理

爲何要用統一配置？

咱們作項目時用到的配置好比數據庫配置等...咱們都是寫死在項目裏面，若是須要更改，那麼也是的修改配置文件而後再投產上去，那麼問題來了，若是作集羣的呢，有100臺機器，這時候作修改那就太不切實際了；那麼就須要用到統一配置管理啦。

解決思路

1.把公共配置抽取出來

2.對公共配置進行維護

3.修改公共配置後應用不須要從新部署

採用方案

1.公共配置抽取存放於zookeeper中並落地數據庫

2.對公共配置修改後發佈到zookeeper中並落地數據庫

3.對應用開啓配置實時監聽，zookeeper配置文件一旦被修改，應用可實時監聽到並獲取

下面基於zookeeper粗略實現了一個統一配置管理

須要用到的jar是zkclient配置文件Config

package com.cwh.zk.util;
 
import java.io.Serializable;
 
public class Config implements Serializable{
 
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	private String userNm;
	private String userPw;
	
	public Config() {
	}
	public Config(String userNm, String userPw) {
		this.userNm = userNm;
		this.userPw = userPw;
	}
	public String getUserNm() {
		return userNm;
	}
	public void setUserNm(String userNm) {
		this.userNm = userNm;
	}
	public String getUserPw() {
		return userPw;
	}
	public void setUserPw(String userPw) {
		this.userPw = userPw;
	}
	@Override
	public String toString() {
		return "Config [userNm=" + userNm + ", userPw=" + userPw + "]";
	}
	
}複製代碼

 配置管理中心ZkConfigMag 

package com.cwh.zk.util;
 
import org.I0Itec.zkclient.ZkClient;
 
public class ZkConfigMag {
 
	private Config config;
	/**
	 * 從數據庫加載配置
	 */
	public Config downLoadConfigFromDB(){
		//getDB
		config = new Config("nm", "pw");
		return config;
	}
	
	/**
	 * 配置文件上傳到數據庫
	 */
	public void upLoadConfigToDB(String nm, String pw){
		if(config==null)config = new Config();
		config.setUserNm(nm);
		config.setUserPw(pw);
		//updateDB
	}
	
	/**
	 * 配置文件同步到zookeeper
	 */
	public void syncConfigToZk(){
		ZkClient zk = new ZkClient("localhost:2181");
		if(!zk.exists("/zkConfig")){
			zk.createPersistent("/zkConfig",true);
		}
		zk.writeData("/zkConfig", config);
		zk.close();
	}
}
複製代碼

應用監聽實現ZkGetConfigClient 

package com.cwh.zk.util;
 
import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;
 
public class ZkGetConfigClient {
 
	private Config config;
 
	public Config getConfig() {
		ZkClient zk = new ZkClient("localhost:2181");
		config = (Config)zk.readData("/zkConfig");
		System.out.println("加載到配置："+config.toString());
		
		//監聽配置文件修改
		zk.subscribeDataChanges("/zkConfig", new IZkDataListener(){
			@Override
			public void handleDataChange(String arg0, Object arg1)
					throws Exception {
				config = (Config) arg1;
				System.out.println("監聽到配置文件被修改："+config.toString());
			}
 
			@Override
			public void handleDataDeleted(String arg0) throws Exception {
				config = null;
				System.out.println("監聽到配置文件被刪除");
			}
			
		});
		return config;
	}
	public static void main(String[] args) {
		ZkGetConfigClient client = new ZkGetConfigClient();
		client.getConfig();
		System.out.println(client.config.toString());
		for(int i = 0;i<10;i++){
			System.out.println(client.config.toString());
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
	}
 
	
}複製代碼

 測試，啓動配置管理中心 

package com.cwh.zkConfig.test;
 
import com.cwh.zk.util.Config;
import com.cwh.zk.util.ZkConfigMag;
 
public class ZkConfigTest {
 
	public static void main(String[] args) {
		ZkConfigMag mag = new ZkConfigMag();
		Config config = mag.downLoadConfigFromDB();
		System.out.println("....加載數據庫配置...."+config.toString());
		mag.syncConfigToZk();
		System.out.println("....同步配置文件到zookeeper....");
		
		//歇會，這樣看比較清晰
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		mag.upLoadConfigToDB("cwhcc", "passwordcc");
		System.out.println("....修改配置文件...."+config.toString());
		mag.syncConfigToZk();
		System.out.println("....同步配置文件到zookeeper....");
		
		
	}
	
}
複製代碼

測試結果： 

配置管理中心打印

讀者福利

給你們推薦一個架構技術交流羣：714827309 ，裏面會分享一些資深架構師錄製的視頻錄像：有Spring，MyBatis，Netty源碼分析 ，高併發、高性能、分佈式、微服務架構的原理，JVM性能優化這些成爲架構師必備的知識體系。還能領取免費的學習資源，相信對於已經工做 和遇到技術瓶頸的碼友，在這個羣裏會有你須要的內容。 點擊連接加入羣聊【JAVA高級架構技術交流】：jq.qq.com/?_wv=1027&a…