这篇文章给大家介绍大数据开发中Zookeeper怎么实现简易配置中心，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
创新互联公司专注于企业成都营销网站建设、网站重做改版、蔡家坡网站定制设计、自适应品牌网站建设、html5、成都做商城网站、集团公司官网建设、外贸网站建设、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为蔡家坡等各大城市提供网站开发制作服务。
Zookeeper是一个分布式的，开放源码的分布式协调服务，常在Ha架构，比如Hadoop、Hbase中使用，它是一个分布式应用提供一致性服务的软件，提供的功能有：配置维护，域名服务，分布式同步，注册中心等，作为配置中心，需要的就是一个稳定的全局一致的配置化中心，而Zk本身提供的原语正好可以满足需求。
1.创建要给Web项目，将数据库连接池信息交给Zookeeper配置中心来管理，即把配置参数放到Zk的节点信息中.
2.在项目启动时候，从Zookeeper中拉取MySQL的信息参数、
3.当Zk中的数据库连接池信息修改后，自动感知，正确释放之前的连接池，创建新的连接池。
2.1 启动springboot项目，并从zk中拉取配置
/**
* 1. 启动 web 容器
* 2. 初始化 zookeeper
* 3. 配置数据库连接池
**/
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
initZk();
configHikariSource();
}
//初始化zk
private static void initZk() {
zkClient = new ZkClient("centos:8521");
zkClient.setZkSerializer(new ZkStrSerializer());
zkClient.subscribeDataChanges("/jdbc", new IZkDataListener() {
public void handleDataChange(String path, Object data) {
System.out.println(path + " data is changed, new data " + data);
hikariDataSource.close();
configHikariSource();
}
public void handleDataDeleted(String path) {
System.out.println(path + " is deleted!!");
hikariDataSource.close();
}
});
}
2.2 获取数据库连接池信息进行访问mysql
序列化zk中的数据，将其转为字符串，使用HiKari工具建立连接，操作数据库
/**
* 配置数据库连接池
*
* 1. 从 zookeeper 中获取配置信息
* 2. 更新 hikari 配置
* 3. 执行测试 sql
*/
private static void configHikariSource(){
JDBCConfig myConfig = getJDBCConfig();
updateHikariConfig(myConfig);
try {
executeTestSQL();
} catch (SQLException e) {
e.printStackTrace();
}
}
2.3 监听zk，改变节点数据，释放并创建新的数据库连接
//更新数据库信息
private static void updateHikariConfig(JDBCConfig myConfig) {
HikariConfig config = new HikariConfig();
config.setJdbcUrl(myConfig.getUrl());
config.setUsername(myConfig.getUsername());
config.setPassword(myConfig.getPassword());
config.addDataSourceProperty( "driverClassName" , myConfig.getDriver());
config.addDataSourceProperty( "cachePrepStmts" , "true" );
config.addDataSourceProperty( "prepStmtCacheSize" , "250" );
config.addDataSourceProperty( "prepStmtCacheSqlLimit" , "2048" );
hikariDataSource = new HikariDataSource(config);
}
关于大数据开发中Zookeeper怎么实现简易配置中心就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。