註冊中心

一般具有以下功能：

• 註冊服務

• 訂閱服務

• 失敗重新註冊和訂閱

• 本地快取服務資訊列表

大體過程如下：

• 1.服務提供者暴露服務後向註冊中心註冊，如果多個註冊中心的話，需要分別註冊到多個註冊中心；註冊資訊包含自己主機名，埠號，服務名，其他額外引數等。本地一般用map快取已經註冊的服務，當然也可以用檔案儲存到本地，當網路抖動等原因重新恢復連線Zookeeper的時候，需要從快取取出來重新註冊。

• 2.服務消費者引用服務提供者的時候要向zookeeper發出訂閱請求，訂閱服務提供者。服務消費者一般會快取服務提供者訊息，這樣每次發起RPC請求的時候就不用連線zookeeper，增加效能。當服務提供者發出變動的時候，能做出相應調整，更新本地快取。

實現例子

首先需要有註冊中心介面，負責註冊訂閱以及查詢

public interface Registry {
    void register(URL url) throws Exception;
    void subscribe(URL url, NotifyListener listener) throws Exception;
    List<URL> lookup(URL url) throws Exception;
}

目錄服務，負責查詢本地快取的服務提供者資訊

public interface Directory<T> {
    List<Invoker<T>> list(Invocation invocation);
}
 

註冊節點監聽器，負責註冊中心有變動時候做出響應

public interface StateListener {
    void onChanged(StateEvent stateEvent) throws Exception;

}

zookeeper狀態監聽器，負責zookeeper重連時候自動恢復註冊和訂閱

public interface StateListener {
    void onChanged(StateEvent stateEvent) throws Exception;

}

zookeeper客戶端

public interface ZkClient
 
 {
    void create(URL url) throws Exception;
    List<String> getChildNode(String path) throws Exception;
    List<String> addNodeListener(final URL url, final ChildListener listener) throws Exception;
    void addStateListener(StateListener stateListener);
}

原始碼