免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版

打開APP
userphoto
未登錄

開通VIP，暢享免費(fèi)電子書等14項超值服

開通VIP

首頁

好書

留言交流

下載APP

聯(lián)系客服
Dubbo源碼分析（四）：Dubbo之Registry

     dubbo的總體架構(gòu)如圖所示：

服務(wù)注冊
對于服務(wù)提供方，它需要發(fā)布服務(wù)，而且由于應(yīng)用系統(tǒng)的復(fù)雜性，服務(wù)的數(shù)量、類型也不斷膨脹；對于服務(wù)消費(fèi)方，它最關(guān)心如何獲取到它所需要的服務(wù)，而面對復(fù)雜的應(yīng)用系統(tǒng)，需要管理大量的服務(wù)調(diào)用。而且，對于服務(wù)提供方和服務(wù)消費(fèi)方來說，他們還有可能兼具這兩種角色，即既需要提供服務(wù)，有需要消費(fèi)服務(wù)。
通過將服務(wù)統(tǒng)一管理起來，可以有效地優(yōu)化內(nèi)部應(yīng)用對服務(wù)發(fā)布/使用的流程和管理。服務(wù)注冊中心可以通過特定協(xié)議來完成服務(wù)對外的統(tǒng)一。Dubbo提供的注冊中心有如下幾種類型可供選擇：

  • Multicast注冊中心
  • Zookeeper注冊中心
  • Redis注冊中心
  • Simple注冊中心

    服務(wù)首先暴露在服務(wù)端，然后調(diào)用Registry的register方法在注冊中心（它是一個服務(wù)協(xié)調(diào)中心，dubbo以外的獨(dú)立服務(wù)端，dubbo提供了客戶端實現(xiàn)）注冊服務(wù)，然后用戶通過配置文件中配置的service的url去subscribe(訂閱服務(wù))，Registry接收到訂閱消息后會往url對應(yīng)的的List<NotifyListener>中塞入當(dāng)前NotifyListener，反之從這個list中移除listener就是取消訂閱。registry會調(diào)用據(jù)consumer的訂閱情況調(diào)用notify方法推送服務(wù)列表給Consumer。這里我們以Zookeeper注冊中心來說明：

 ZookeeperRegistry.java的構(gòu)造函數(shù)，創(chuàng)建Zookeeper客戶端：

  1. public ZookeeperRegistry(URL url, ZookeeperTransporter zookeeperTransporter) {  
  2.         super(url);  
  3.         //如果provider的url是“0.0.0.0”或者在參數(shù)中帶anyHost=true則拋出異常注冊地址不存在  
  4.         if (url.isAnyHost()) {  
  5.             throw new IllegalStateException("registry address == null");  
  6.         }  
  7.         //服務(wù)分組（默認(rèn)“dubbo”）  
  8.         String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);  
  9.         //在group頭補(bǔ)齊“/”  
  10.         if (! group.startsWith(Constants.PATH_SEPARATOR)) {  
  11.             group = Constants.PATH_SEPARATOR + group;  
  12.         }  
  13.         //服務(wù)分組根地址  
  14.         this.root = group;  
  15.         //創(chuàng)建Zookeeper客戶端  
  16.         zkClient = zookeeperTransporter.connect(url);  
  17.         //添加狀態(tài)監(jiān)聽器  
  18.         zkClient.addStateListener(new StateListener() {  
  19.             public void stateChanged(int state) {  
  20.                 if (state == RECONNECTED) {  
  21.                     try {  
  22.                         recover();  
  23.                     } catch (Exception e) {  
  24.                         logger.error(e.getMessage(), e);  
  25.                     }  
  26.                 }  
  27.             }  
  28.         });  
  29.     }  

ZookeeperRegistry的doRegister方法：

  1. protected void doRegister(URL url) {  
  2.         try {  
  3.             //連接注冊中心注冊  
  4.             zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));  
  5.         } catch (Throwable e) {  
  6.             throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);  
  7.         }  
  8.     }  


    Provider初始化時會調(diào)用doRegister方法向注冊中心發(fā)起注冊。那么客戶端又是怎么subscribe在注冊中心訂閱服務(wù)的呢？答案是服務(wù)消費(fèi)者在初始化ConsumerConfig時會調(diào)用RegistryProtocol的refer方法進(jìn)一步調(diào)用RegistryDirectory的subscribe方法最終調(diào)用ZookeeperRegistry的subscribe方法向注冊中心訂閱服務(wù)。

com.alibaba.dubbo.registry.support.FailBackRegistry的subscribe方法：

  1. @Override  
  2.     public void subscribe(URL url, NotifyListener listener) {  
  3.         super.subscribe(url, listener);  
  4.         removeFailedSubscribed(url, listener);  
  5.         try {  
  6.             // 向服務(wù)器端發(fā)送訂閱請求  
  7.             doSubscribe(url, listener);  
  8.         } catch (Exception e) {  
  9.             Throwable t = e;  
  10.   
  11.             List<URL> urls = getCacheUrls(url);  
  12.             if (urls != null && urls.size() > 0) {  
  13.                 notify(url, listener, urls);  
  14.                 logger.error("Failed to subscribe " + url + ", Using cached list: " + urls + " from cache file: " + getUrl().getParameter(Constants.FILE_KEY, System.getProperty("user.home") + "/dubbo-registry-" + url.getHost() + ".cache") + ", cause: " + t.getMessage(), t);  
  15.             } else {  
  16.                 // 如果開啟了啟動時檢測，則直接拋出異常  
  17.                 boolean check = getUrl().getParameter(Constants.CHECK_KEY, true)  
  18.                         && url.getParameter(Constants.CHECK_KEY, true);  
  19.                 boolean skipFailback = t instanceof SkipFailbackWrapperException;  
  20.                 if (check || skipFailback) {  
  21.                     if(skipFailback) {  
  22.                         t = t.getCause();  
  23.                     }  
  24.                     throw new IllegalStateException("Failed to subscribe " + url + ", cause: " + t.getMessage(), t);  
  25.                 } else {  
  26.                     logger.error("Failed to subscribe " + url + ", waiting for retry, cause: " + t.getMessage(), t);  
  27.                 }  
  28.             }  
  29.   
  30.             // 將失敗的訂閱請求記錄到失敗列表，定時重試  
  31.             addFailedSubscribed(url, listener);  
  32.         }  
  33.     }  

com.alibaba.dubbo.registry.zookeeper.Zookeeper的doSubscribe方法：

  1. protected void doSubscribe(final URL url, final NotifyListener listener) {  
  2.         try {  
  3.             //如果provider的service的接口配置的是“*”  
  4.             if (Constants.ANY_VALUE.equals(url.getServiceInterface())) {  
  5.                 //獲取服務(wù)分組根路徑  
  6.                 String root = toRootPath();  
  7.                 //獲取服務(wù)的NotifyListener  
  8.                 ConcurrentMap<NotifyListener, ChildListener> listeners = zkListeners.get(url);  
  9.                 if (listeners == null) {  
  10.                     //如果沒有則創(chuàng)建一個  
  11.                     zkListeners.putIfAbsent(url, new ConcurrentHashMap<NotifyListener, ChildListener>());  
  12.                     listeners = zkListeners.get(url);  
  13.                 }  
  14.                 ChildListener zkListener = listeners.get(listener);  
  15.                 //如果沒有子監(jiān)聽器則創(chuàng)建一個  
  16.                 if (zkListener == null) {  
  17.                     listeners.putIfAbsent(listener, new ChildListener() {  
  18.                         public void childChanged(String parentPath, List<String> currentChilds) {  
  19.                             for (String child : currentChilds) {  
  20.                                 child = URL.decode(child);  
  21.                                 if (! anyServices.contains(child)) {  
  22.                                     anyServices.add(child);  
  23.                                     subscribe(url.setPath(child).addParameters(Constants.INTERFACE_KEY, child,   
  24.                                             Constants.CHECK_KEY, String.valueOf(false)), listener);  
  25.                                 }  
  26.                             }  
  27.                         }  
  28.                     });  
  29.                     zkListener = listeners.get(listener);  
  30.                 }  
  31.                 //向服務(wù)器訂閱服務(wù)，注冊中心會調(diào)用NotifyListener的notify函數(shù)返回服務(wù)列表  
  32.                 zkClient.create(root, false);  
  33.                 //獲取服務(wù)地址列表  
  34.                 List<String> services = zkClient.addChildListener(root, zkListener);  
  35.                 if (services != null && services.size() > 0) {  
  36.                     //如果存在服務(wù)  
  37.                     for (String service : services) {  
  38.                         service = URL.decode(service);  
  39.                         anyServices.add(service);  
  40.                         //如果serviceInterface是“*”則從分組根路徑遍歷service并訂閱所有服務(wù)  
  41.                         subscribe(url.setPath(service).addParameters(Constants.INTERFACE_KEY, service,   
  42.                                 Constants.CHECK_KEY, String.valueOf(false)), listener);  
  43.                     }  
  44.                 }  
  45.             } else {  
  46.                 //如果serviceInterface不是“*”則創(chuàng)建Zookeeper客戶端索取服務(wù)列表，并通知（notify）消費(fèi)者（consumer）這些服務(wù)可以用了  
  47.                 List<URL> urls = new ArrayList<URL>();  
  48.                 //獲取類似于http：//xxx.xxx.xxx.xxx/context/com.service.xxxService/consumer的地址  
  49.                 for (String path : toCategoriesPath(url)) {  
  50.                     //獲取例如com.service.xxxService對應(yīng)的NotifyListener map  
  51.                     ConcurrentMap<NotifyListener, ChildListener> listeners = zkListeners.get(url);  
  52.                     if (listeners == null) {  
  53.                         zkListeners.putIfAbsent(url, new ConcurrentHashMap<NotifyListener, ChildListener>());  
  54.                         listeners = zkListeners.get(url);  
  55.                     }  
  56.                     //獲取ChildListener  
  57.                     ChildListener zkListener = listeners.get(listener);  
  58.                     if (zkListener == null) {  
  59.                         listeners.putIfAbsent(listener, new ChildListener() {  
  60.                             public void childChanged(String parentPath, List<String> currentChilds) {  
  61.                                 ZookeeperRegistry.this.notify(url, listener, toUrlsWithEmpty(url, parentPath, currentChilds));  
  62.                             }  
  63.                         });  
  64.                         zkListener = listeners.get(listener);  
  65.                     }  
  66.                     //創(chuàng)建Zookeeper客戶端  
  67.                     zkClient.create(path, false);  
  68.                     List<String> children = zkClient.addChildListener(path, zkListener);  
  69.                     if (children != null) {  
  70.                         urls.addAll(toUrlsWithEmpty(url, path, children));  
  71.                     }  
  72.                 }  
  73.                 //提醒消費(fèi)者  
  74.                 notify(url, listener, urls);  
  75.             }  
  76.         } catch (Throwable e) {  
  77.             throw new RpcException("Failed to subscribe " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);  
  78.         }  
  79.     }  

    至此，Dubbo的源碼解析結(jié)束，以后還會對一些細(xì)節(jié)進(jìn)行補(bǔ)充。特別在此建議看官使用apache的開源項目Zookeeper作注冊中心，來完成分布式服務(wù)的協(xié)調(diào)調(diào)用。





本站僅提供存儲服務(wù)，所有內(nèi)容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請點(diǎn)擊舉報。
打開APP，閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
dubbo組成原理
Dubbo源碼分析：小白入門篇
『高級篇』docker之調(diào)整微服務(wù)適應(yīng)mesos（25）
Dubbo 一篇文章就夠了：從入門到實戰(zhàn)
Dubbo+Zookeeper
白話分布式系統(tǒng)
更多類似文章 >>
生活服務(wù)
分享 收藏 導(dǎo)長圖 關(guān)注 下載文章
綁定賬號成功
后續(xù)可登錄賬號暢享VIP特權(quán)！
如果VIP功能使用有故障，
可點(diǎn)擊這里聯(lián)系客服！

聯(lián)系客服