zookeeper做集群的方法是什么

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

場景：提供一個分布式Restful 服務讓客戶端去調用，支持動態加減機器。

分析：

server端并不復雜，啟動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端 ：假設沒有zk的時候，你可能會這么做。服務啟動的時候把這些暴露的url地址放到一個static變量里面。然后輪詢去調用。 這樣就可以實現一個簡單的軟負載了。(PS:還有個方法：在前面加個nginx 做負載)

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

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

改良：

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

2.  添加一個session事件，當掛了后，重新注冊，看看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. 啟動的時候就監聽 /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做集群的方法是什么”的內容了，經過本文的學習后，相信大家對zookeeper做集群的方法是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！