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

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

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

分析：

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

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

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

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

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

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

改良：

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

2.  添加一個(gè)session事件，當(dāng)掛了后，重新注冊(cè)，看看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 的思路，麻煩一點(diǎn)

1. 啟動(dòng)的時(shí)候就監(jiān)聽(tīng) /user chindren 事件，這個(gè)事件要用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. 如果中途添加/刪除機(jī)器，那么在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)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)zookeeper做集群的方法是什么這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！

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

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

廣告

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