标签：down 时间 exce port 客户 修改 文件共享 prot input
最近频繁的系统上线，每次打包都要把配置文件替换为正式环境的配置文件，虽然说就是复制粘贴的事，架不住文件杂乱，而且多。
期初的想法是有没有办法将配置文件与系统隔离开来，这样在更新时候，就只需要更新代码部分，配置文件不用去管了。查了不少资料，没找到什么好的实现方式，别人比较好的发布框架都是自己写的，也用了，干脆自己研究研究能不能使用zk做一个配置文件的管理中心，顺带实现动态加载配置文件而不需要重启系统（正式环境这种情况使用的应该很少，不过本地倒是用起来顺手很多）。
1，在虚拟机上安装zk(需先安装jdk)：下载tar文件，解压，修改 cp zoo_sample.cfg zoo.cfg,
进入到bin目录下，sh zkServer.sh start
进入zk客户端 sh zkCli.sh -server localhost:2181
创建文件 create /fileName value
2.java端引入zk客户端
1).maven
<!-- ZooKeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.6</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.9.0</version> </dependency> <!-- Zookeeper -->
2).zookeeper.properties
zk.servers=192.168.3.252:2181
zk.config.root.path=/conf
3.我们在使用配置文件的时候，都是使用spring来托管，在项目启动的时候就加载到项目中去，zk有三种监听方式，为能够同时监听主目录及子目录的实时变化，选用TreeCacheListener。zk能够直接从服务端获取对应目录下的数据，并能够实时监听对应节点的变化以及变化之后的值，这里首先在项目启动加载配置文件的时候，用服务端的数据去覆盖项目中的数据，这样保证服务端有配置时以服务端为准，没有时则以项目中配置运行，然后实时监听对应节点，只要有服务端配置被修改，则覆盖项目中的原有配置，并刷新容器，使用最新的配置。
核心代码：继承spring PropertyPlaceholderConfigurer 重写processProperties方法加载配置文件
@Override protected void processProperties(ConfigurableListableBeanFactory beanFactory, Properties props) throws BeansException { InputStream in = ZooKeeperService.class.getClassLoader().getResourceAsStream("zookeeper.properties"); Properties pro = new Properties(); try{ pro.load(in); }catch(Exception e){ logger.debug("zookeeper.properties读取错误！"+e.getMessage()); } this.zookeeperServers = pro.getProperty("zk.servers"); PATH = pro.getProperty("zk.config.root.path"); RetryPolicy retryPolicy = new ExponentialBackoffRetry(BASE_SLEEP_TIMEMS, MAX_RETRIES); this.client = CuratorFrameworkFactory.builder().connectString(this.zookeeperServers).retryPolicy(retryPolicy).build(); client.start(); @SuppressWarnings("resource") TreeCache cache = new TreeCache(this.client, PATH); try { cache.start(); TreeCacheListener listener = new TreeCacheListener() { @Override public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception { if(null != event && null != event.getData()){ logger.debug(event.getData().getPath().toString()+":" +new String(event.getData().getData())); String[] arr = event.getData().getPath().toString().split("/"); String key = arr[arr.length-1]; String value = new String(event.getData().getData()); proMap.putAll(updateConf(key,value)); } } }; cache.getListenable().addListener(listener); } catch (Exception e) { logger.debug(e.getMessage()); } try {
//加载顺序问题，因为是一个监听的过程，所以没办法顺序执行，测试时这里直接使用了延时来保证先获取到服务端的数据然后在加载参数，没有想到其他好的方法解决，在尝试使用CountDownLatch来解决，后续修改
Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } props.putAll(proMap); super.processProperties(beanFactory, props); }
基本实现如此。待完善。
标签：down 时间 exce port 客户 修改 文件共享 prot input
原文地址：http://www.cnblogs.com/zimu-org/p/6798155.html
