大數(shù)據(jù)開(kāi)發(fā)中Zookeeper怎么實(shí)現(xiàn)簡(jiǎn)易配置中心

這篇文章給大家介紹大數(shù)據(jù)開(kāi)發(fā)中Zookeeper怎么實(shí)現(xiàn)簡(jiǎn)易配置中心，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

大數(shù)據(jù)開(kāi)發(fā)—Zookeeper實(shí)現(xiàn)簡(jiǎn)易配置中心

為什么使用Zookeeper

Zookeeper是一個(gè)分布式的，開(kāi)放源碼的分布式協(xié)調(diào)服務(wù)，常在Ha架構(gòu)，比如Hadoop、Hbase中使用，它是一個(gè)分布式應(yīng)用提供一致性服務(wù)的軟件，提供的功能有：配置維護(hù)，域名服務(wù)，分布式同步，注冊(cè)中心等，作為配置中心，需要的就是一個(gè)穩(wěn)定的全局一致的配置化中心，而Zk本身提供的原語(yǔ)正好可以滿足需求。

1.實(shí)現(xiàn)思路

1.創(chuàng)建要給Web項(xiàng)目，將數(shù)據(jù)庫(kù)連接池信息交給Zookeeper配置中心來(lái)管理，即把配置參數(shù)放到Zk的節(jié)點(diǎn)信息中.

2.在項(xiàng)目啟動(dòng)時(shí)候，從Zookeeper中拉取Mysql的信息參數(shù)、

3.當(dāng)Zk中的數(shù)據(jù)庫(kù)連接池信息修改后，自動(dòng)感知，正確釋放之前的連接池，創(chuàng)建新的連接池。

2.實(shí)現(xiàn)過(guò)程

2.1 啟動(dòng)springboot項(xiàng)目，并從zk中拉取配置

     /**
     * 1. 啟動(dòng) web 容器
     * 2. 初始化 zookeeper
     * 3. 配置數(shù)據(jù)庫(kù)連接池
     **/
    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 獲取數(shù)據(jù)庫(kù)連接池信息進(jìn)行訪問(wèn)mysql

序列化zk中的數(shù)據(jù)，將其轉(zhuǎn)為字符串，使用HiKari工具建立連接，操作數(shù)據(jù)庫(kù)

/**
     * 配置數(shù)據(jù)庫(kù)連接池
     *
     * 1. 從 zookeeper 中獲取配置信息
     * 2. 更新 hikari 配置
     * 3. 執(zhí)行測(cè)試 sql
     */
    private static void configHikariSource(){

        JDBCConfig myConfig = getJDBCConfig();

        updateHikariConfig(myConfig);

        try {

            executeTestSQL();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

2.3 監(jiān)聽(tīng)zk，改變節(jié)點(diǎn)數(shù)據(jù)，釋放并創(chuàng)建新的數(shù)據(jù)庫(kù)連接

//更新數(shù)據(jù)庫(kù)信息
    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);
    }

關(guān)于大數(shù)據(jù)開(kāi)發(fā)中Zookeeper怎么實(shí)現(xiàn)簡(jiǎn)易配置中心就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。