這篇文章主要講解了“zookeeper做集群的方法是什么”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“zookeeper做集群的方法是什么”吧！

創(chuàng)新互聯(lián)公司"三網(wǎng)合一"的企業(yè)建站思路。企業(yè)可建設(shè)擁有電腦版、微信版、手機版的企業(yè)網(wǎng)站。實現(xiàn)跨屏營銷，產(chǎn)品發(fā)布一步更新，電腦網(wǎng)絡(luò)+移動網(wǎng)絡(luò)一網(wǎng)打盡，滿足企業(yè)的營銷需求！創(chuàng)新互聯(lián)公司具備承接各種類型的網(wǎng)站建設(shè)、做網(wǎng)站項目的能力。經(jīng)過十年的努力的開拓，為不同行業(yè)的企事業(yè)單位提供了優(yōu)質(zhì)的服務(wù)，并獲得了客戶的一致好評。

場景：提供一個分布式Restful 服務(wù)讓客戶端去調(diào)用，支持動態(tài)加減機器。

分析：

server端并不復(fù)雜，啟動webserver后，暴露http://url:8088/rs/xx 出去即可，那么會有如下幾個：

server1: http://192.168.50.11:8088/rs/xx 

server2: http://192.168.50.12:8088/rs/xx 

client端 ：假設(shè)沒有zk的時候，你可能會這么做。服務(wù)啟動的時候把這些暴露的url地址放到一個static變量里面。然后輪詢?nèi)フ{(diào)用。 這樣就可以實現(xiàn)一個簡單的軟負(fù)載了。(PS:還有個方法：在前面加個nginx 做負(fù)載)

但是遇見這種情況了，某臺機器掛了，你怎么辦？ 或者在線上的時候加一臺服務(wù)器，那么你需要修改client代碼，加上url地址。重新部署。

很顯然，這種做法太不好了，要停服務(wù)。那么看看有了注冊中心后如何干。

改良：

1. server端不變，啟動的時候把所有服務(wù)全部注冊到zookeeper上面，比如User的，在/user下面創(chuàng)建臨時節(jié)點。

2.  添加一個session事件，當(dāng)掛了后，重新注冊，看看curator的源碼：

if ( newState == ConnectionState.RECONNECTED )
            {
                try
                {
                    log.debug("Re-registering due to reconnection");
                    reRegisterServices();
                }
                catch ( Exception e )
                {
                    log.error("Could not re-register instances after reconnection", e);
                }
            }

再看看 client 的思路，麻煩一點

1. 啟動的時候就監(jiān)聽 /user chindren 事件，這個事件要用StartMode.BUILD_INITIAL_CACHE

意思是，第一次就取值。 然后放到cache里面。 我們看看curator的源碼ServiceCacheImpl：

@Override
    public void start() throws Exception
    {
        Preconditions.checkState(state.compareAndSet(State.LATENT, State.STARTED), "Cannot be started more than once");

        cache.start(true);
        for ( ChildData childData : cache.getCurrentData() )
        {
            addInstance(childData, true);
        }
        discovery.cacheOpened(this);
    }

2. 如果中途添加/刪除機器，那么在cache 里面 add/remove即可，看看curator的源碼：

public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception
    {
        boolean         notifyListeners = false;
        switch ( event.getType() )
        {
            case CHILD_ADDED:
            case CHILD_UPDATED:
            {
                addInstance(event.getData(), false);
                notifyListeners = true;
                break;
            }

            case CHILD_REMOVED:
            {
                instances.remove(instanceIdFromData(event.getData()));
                notifyListeners = true;
                break;
            }
        }

        if ( notifyListeners )
        {
            listenerContainer.forEach
            (
                new Function<ServiceCacheListener, Void>()
                {
                    @Override
                    public Void apply(ServiceCacheListener listener)
                    {
                        listener.cacheChanged();
                        return null;
                    }
                }
            );
        }
    }

感謝各位的閱讀，以上就是“zookeeper做集群的方法是什么”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對zookeeper做集群的方法是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！

新聞標(biāo)題：zookeeper做集群的方法是什么
當(dāng)前URL：http://chinadenli.net/article8/gppcip.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、云服務(wù)器、定制網(wǎng)站、小程序開發(fā)、ChatGPT、微信公眾號

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)