大數據開發中Zookeeper怎么實現簡易配置中心

這篇文章給大家介紹大數據開發中Zookeeper怎么實現簡易配置中心，內容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

大數據開發—Zookeeper實現簡易配置中心

為什么使用Zookeeper

Zookeeper是一個分布式的，開放源碼的分布式協調服務，常在Ha架構，比如Hadoop、Hbase中使用，它是一個分布式應用提供一致性服務的軟件，提供的功能有：配置維護，域名服務，分布式同步，注冊中心等，作為配置中心，需要的就是一個穩定的全局一致的配置化中心，而Zk本身提供的原語正好可以滿足需求。

1.實現思路

1.創建要給Web項目，將數據庫連接池信息交給Zookeeper配置中心來管理，即把配置參數放到Zk的節點信息中.

2.在項目啟動時候，從Zookeeper中拉取Mysql的信息參數、

3.當Zk中的數據庫連接池信息修改后，自動感知，正確釋放之前的連接池，創建新的連接池。

2.實現過程

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怎么實現簡易配置中心就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。