dubbo源碼分析系列

① 有介紹redis bbo nocas的書籍推薦

推薦的關於redis、bbo、nocas的書：
1.Redis設計與實現：Redis技術專家撰寫，深入了解Redis技術內幕的之作。從源碼角度解析Redis的架構設計、實現原理和工作機制，為高效使用 Redis 提供原理性指導；
2.深入理解Apache Dubbo與實戰：主要側重於詳細解讀Dubbo框架工作原理和底層機制，並結合少量核心源碼進行講解。在原理的基礎上，展示一些動手擴展Dubbo特性的實戰場；
3.Nacos架構&原理：Nacos 開源之前在阿里內部已經發展了十年，沉澱了很多優秀的能力，如其易用性、穩定性、實時性以及大規模的特性；也有很多歷史負擔，在開源的時候我們取其精華進行開源，為了提升代碼的健壯性和擴展性，進行了充分的分層和模塊化設計。

② bbo是如何啟動的

已知，在項目啟動過程中，我們會將bbo的配置文件寫到spring的配置文件里，如下xml文件：

<bbo:application name="anyname_provider" />
<!-- 使用zookeeper注冊中心暴露服務地址 -->
<bbo:registry address="zookeeper://127.0.0.1:2181" />
<!-- 用bbo協議在20880埠暴露服務 -->
<bbo:protocol name="bbo" port="20880" />
<!-- 聲明需要暴露的服務介面 -->
<bbo:service interface="com.shxz130.provider.Provider"
ref="demoService" />

從官方文檔中，我們能看到如下：

啟動過程.png

也就是說spring啟動過程中，隨著Spring在初始化過程中，碰到bbo命名的標簽，如（<bbo:service>,<bbo:registry>）等標簽，會由DubboNamespaceHandler類處理，具體原理見鏈接Spring自定義標簽

DubboBeanDefinitionParser代碼如下：

public class DubboNamespaceHandler extends NamespaceHandlerSupport { static {
Version.checkDuplicate(DubboNamespaceHandler.class);
} public void init() {
registerBeanDefinitionParser("application", new DubboBeanDefinitionParser(ApplicationConfig.class, true));
registerBeanDefinitionParser("mole", new DubboBeanDefinitionParser(MoleConfig.class, true));
registerBeanDefinitionParser("registry", new DubboBeanDefinitionParser(RegistryConfig.class, true));
registerBeanDefinitionParser("monitor", new DubboBeanDefinitionParser(MonitorConfig.class, true));
registerBeanDefinitionParser("provider", new DubboBeanDefinitionParser(ProviderConfig.class, true));
registerBeanDefinitionParser("consumer", new DubboBeanDefinitionParser(ConsumerConfig.class, true));
registerBeanDefinitionParser("protocol", new DubboBeanDefinitionParser(ProtocolConfig.class, true));
registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
registerBeanDefinitionParser("reference", new DubboBeanDefinitionParser(ReferenceBean.class, false));
registerBeanDefinitionParser("annotation", new ());
}
}

遇到不同的標簽，會由不同的Parser處理，這里重點看服務發布，這行代碼：

registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));

也就是說，當Spring容器處理完<bbo:service>標簽後，會在Spring容器中生成一個ServiceBean ，服務的發布也會在ServiceBean中完成。不妨看一下ServiceBean的定義：

public class ServiceBean<T> extends ServiceConfig<T> implements InitializingBean, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, BeanNameAware {
}

該Bean實現了很多介面，關於InitializingBean，DisposableBean，ApplicationContextAware，BeanNameAware,這些介面的使用介紹如下鏈接：

• InitializingBean&DisposableBean

• BeanNameAware& ApplicationContextAware

而在Spring初始化完成Bean的組裝，會調用InitializingBean的afterPropertiesSet方法，在Spring容器載入完成，會接收到事件ContextRefreshedEvent，調用ApplicationListener的onApplicationEvent方法。

在afterPropertiesSet中，和onApplicationEvent中，會調用export()，在export()中，會暴露bbo服務，具體區別在於是否配置了delay屬性，是否延遲暴露，如果delay不為null，或者不為-1時，會在afterPropertiesSet中調用export()暴露bbo服務，如果為null,或者為-1時，會在Spring容器初始化完成，接收到ContextRefreshedEvent事件，調用onApplicationEvent，暴露bbo服務。

部分ServiceBean的代碼如下：

• public class ServiceBean<T> extends ServiceConfig<T> implements InitializingBean, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, BeanNameAware { //Spring容器初始化完成，調用


• public void onApplicationEvent(ContextRefreshedEvent event) { if (isDelay() && !isExported() && !isUnexported()) { if (logger.isInfoEnabled()) {


• logger.info("The service ready on spring started. service: " + getInterface());


• } //暴露服務


• export();


• }


• } //判斷是否延遲發布


• private boolean isDelay() {


• Integer delay = getDelay();


• ProviderConfig provider = getProvider(); if (delay == null && provider != null) {


• delay = provider.getDelay();


• } return supportedApplicationListener && (delay == null || delay == -1);


• } //當bean初始化完成調用


• public void afterPropertiesSet() throws Exception { //......此處省略10000行代碼


• if (!isDelay()) { //暴露服務


• export();


• }


• }


• }



在export()，暴露服務過程中，如果發現有delay屬性，則延遲delay時間，暴露服務，如果沒有，則直接暴露服務。

• public synchronized void export() { //忽略若干行代碼


• if (delay != null && delay > 0) { //當delay不為null，且大於0時，延遲delay時間，暴露服務


• delayExportExecutor.schele(new Runnable() { public void run() { //暴露服務


• doExport();


• }


• }, delay, TimeUnit.MILLISECONDS);


• } else { //直接暴露服務


• doExport();


• }


• }



而在doExport()中，驗證參數，按照不同的Protocol，比如(bbo,injvm)暴露服務，在不同的zookeeper集群節點上注冊自己的服務。

• protected synchronized void doExport() { //忽略10000行代碼


• doExportUrls(); //忽略10000行代碼


• } private void doExportUrls() {


• List<URL> registryURLs = loadRegistries(true); for (ProtocolConfig protocolConfig : protocols) { //按照不同的Protocal暴露服務


• doExportUrlsFor1Protocol(protocolConfig, registryURLs);


• }


• }





作者：一滴水的堅持
鏈接：https://www.jianshu.com/p/7f3871492c71
來源：簡書
簡書著作權歸作者所有，任何形式的轉載都請聯系作者獲得授權並註明出處。

③ bbo怎樣調用其他模塊的pojo

Nodejs 通過 tether 調用 Java Dubbo 服務。請求類的某個參數對象 EsCondition 有 fieldName, op, value 三個欄位，value 的參數值正確解析， fieldName, op 的參數值解析為 null 。 深入到 Dubbo 源碼進行單步調試定位到，發現欄位 field

④ 求深度解剖bbo源碼的視頻

你可以在CSDN中找到你想要的 框架和資料庫估計你自己能拿下吧 關鍵是核心代碼 在CSDN里你可以找到

⑤ idea bbo.xsd怎麼安裝到本地

可以的 DUBBO配置規則詳解 研究DUBBO也已經大半年了，對它的大部分源碼進行了分析，以及對它的內部機制有了比較深入的了解，以及各個模塊的實現。DUBBO包含很多內容，如果想了解DUBBO第一步就是啟動它，從而可以很好的使用它，那麼如何更好的使用呢？就需要知道DUBBO的各個配置項，以及它可以通過哪些途徑進行配置。個人對配置的理解，就好比時對動物的馴服，如何很好的馴服一頭猛獸，那就需要知道它各種因子，從而調整，已達到自己期望的結果。這篇不對DUBBO有哪些配置項可以配置，但是通過這篇文章，你應該能夠知道DUBBO可以進行哪些配置。本文會通過分析DUBBO載入配置源碼的分析，來使得大家對DUBBO的配置一塊有更加深入的了解。從而達到「馴服」DUBBO，以使得它成為你們自己的DUBBO。 DUBBO在配置這一塊做的確實很完美，提供很很多參數，以及提供了多種渠道。下面進入正題，看看DUBBO怎麼載入配置的。在講這些之前，先給大家介紹一下在DUBBO源碼層面定義了哪些類來存儲各個模塊的配置項，從而了解DUBBO可以對哪些模塊進行配置。 哪些東西可以配置 由於大部分項目都會使用Spring，而且DUBBO也提供了通過Spring來進行配置，那麼先從這里進行著手。DUBBO載入Spring的集成時在bbo-config下面的bbo-config-spring模塊下面，其中有一個類DubboNamespaceHandler，它實現了Spring提供的介面NamespaceHandlerSupport。那麼Spring怎麼發現整個實現類的呢？在該模塊的META-INF文件夾下有兩個文件： spring.handlers和spring.schemas，這兩個文件裡面制定了bbo的namespace的XSD文件的位置以及bbo的namespace由DubboNamespaceHandler來處理解析。說了這么多廢話，只是想說明Spring是怎麼解析<bbo:.../>配置的。 知道了DUBBO和Spring關於配置一塊時怎麼整合的之後，那麼你應該就不會詫異Spring怎麼那麼聰明，能夠解析bbo的namespace。接下來看看DubboNamespaceHandler類裡面有什麼東西。

⑥ android 可以使用bbo嗎

可以的

DUBBO配置規則詳解
研究DUBBO也已經大半年了，對它的大部分源碼進行了分析，以及對它的內部機制有了比較深入的了解，以及各個模塊的實現。DUBBO包含很多內容，如果想了解DUBBO第一步就是啟動它，從而可以很好的使用它，那麼如何更好的使用呢？就需要知道DUBBO的各個配置項，以及它可以通過哪些途徑進行配置。個人對配置的理解，就好比時對動物的馴服，如何很好的馴服一頭猛獸，那就需要知道它各種因子，從而調整，已達到自己期望的結果。這篇不對DUBBO有哪些配置項可以配置，但是通過這篇文章，你應該能夠知道DUBBO可以進行哪些配置。本文會通過分析DUBBO載入配置源碼的分析，來使得大家對DUBBO的配置一塊有更加深入的了解。從而達到「馴服」DUBBO，以使得它成為你們自己的DUBBO。
DUBBO在配置這一塊做的確實很完美，提供很很多參數，以及提供了多種渠道。下面進入正題，看看DUBBO怎麼載入配置的。在講這些之前，先給大家介紹一下在DUBBO源碼層面定義了哪些類來存儲各個模塊的配置項，從而了解DUBBO可以對哪些模塊進行配置。
哪些東西可以配置
由於大部分項目都會使用Spring，而且DUBBO也提供了通過Spring來進行配置，那麼先從這里進行著手。DUBBO載入Spring的集成時在bbo-config下面的bbo-config-spring模塊下面，其中有一個類DubboNamespaceHandler，它實現了Spring提供的介面NamespaceHandlerSupport。那麼Spring怎麼發現整個實現類的呢？在該模塊的META-INF文件夾下有兩個文件： spring.handlers和spring.schemas，這兩個文件裡面制定了bbo的namespace的XSD文件的位置以及bbo的namespace由DubboNamespaceHandler來處理解析。說了這么多廢話，只是想說明Spring是怎麼解析<bbo:.../>配置的。
知道了DUBBO和Spring關於配置一塊時怎麼整合的之後，那麼你應該就不會詫異Spring怎麼那麼聰明，能夠解析bbo的namespace。接下來看看DubboNamespaceHandler類裡面有什麼東西。

⑦ 如何更好地學習bbo源代碼

1、Dubbo與Spring的整合 Dubbo在使用上可以做到非常簡單，不管是Provider還是Consumer都可以通過Spring的配置文件進行配置，配置完之後，就可以像使用 spring bean一樣進行服務暴露和調用了，完全看不到bbo api的存在。這是因為bbo使用了spring提供的可擴展Schema自定義配置支持。在spring配置文件中，可以像、這樣進行配置。 META-INF下的spring.handlers文件中指定了bbo的xml解析類：DubboNamespaceHandler。像前面的被解 析成ServiceConfig，被解析成ReferenceConfig等等。 2、jdk spi擴展 由於Dubbo是開源框架，必須要提供很多的可擴展點。Dubbo是通過擴展jdk spi機制來實現可擴展的。具體來說，就是在META-INF目錄下，放置文件名為介面全稱，文件中為key、value鍵值對，value為具體實現類 的全類名，key為標志值。由於bbo使用了url匯流排的設計，即很多參數通過URL對象來傳遞，在實際中，具體要用到哪個值，可以通過url中的參 數值來指定。 Dubbo對spi的擴展是通過ExtensionLoader來實現的，查看ExtensionLoader的源碼，可以看到Dubbo對jdk spi做了三個方面的擴展：
（1）jdk spi僅僅通過介面類名獲取所有實現，而ExtensionLoader則通過介面類名和key值獲取一個實現；
（2）Adaptive實現，就是生成一個代理類，這樣就可以根據實際調用時的一些參數動態決定要調用的類了。
（3）自動包裝實現，這種實現的類一般是自動激活的，常用於包裝類，比如Protocol的兩個實現類：ProtocolFilterWrapper、ProtocolListenerWrapper。 3、url匯流排設計 Dubbo為了使得各層解耦，採用了url匯流排的設計。我們通常的設計會把層與層之間的交互參數做成Model，這樣層與層之間溝通成本比較大，擴展起來也比較麻煩。因此，Dubbo把各層之間的通信都採用url的形式。比如，注冊中心啟動時，參數的url為： registry://0.0.0.0:9090?codec=registry&transporter=netty 這就表示當前是注冊中心，綁定到所有ip，埠是9090，解析器類型是registry，使用的底層網路通信框架是netty。
二、Dubbo啟動過程
Dubbo分為注冊中心、服務提供者(provider)、服務消費者(consumer)三個部分。 1、注冊中心啟動過程 注冊中心的啟動過程，主要看兩個類：RegistrySynchronizer、RegistryReceiver，兩個類的初始化方法都是start。 RegistrySynchronizer的start方法：
（1）把所有配置信息load到內存；
（2）把當前注冊中心信息保存到資料庫；
（3）啟動5個定時器。 5個定時器的功能是： （1）AutoRedirectTask，自動重定向定時器。默認1小時運行1次。如果當前注冊中心的連接數高於平均值的1.2倍，則將多出來的連接數重定向到其他注冊中心上，以達到注冊中心集群的連接數均衡。 （2）DirtyCheckTask，臟數據檢查定時器。作用是：分別檢查緩存provider、資料庫provider、緩存consumer、資料庫 consumer的數據，清除臟數據；清理不存活的provider和consumer數據；對於緩存中的存在的provider或consumer而數 據庫不存在，重新注冊和訂閱。 （3）ChangedClearTask，changes變更表的定時清理任務。作用是讀取changes表，清除過期數據。 （4）AlivedCheckTask，注冊中心存活狀態定時檢查，會定時更新registries表的expire欄位，用以判斷注冊中心的存活狀態。如果有新的注冊中心，發送同步消息，將當前所有注冊中心的地址通知到所有客戶端。 （5）ChangedCheckTask，變更檢查定時器。檢查changes表的變更，檢查類型包括：參數覆蓋變更、路由變更、服務消費者變更、權重變更、負載均衡變更。

⑧ bbo框架怎麼進行單元測試

現在還是SSH框架，有點過時了吧！如果你的開發平台是MyEclipse，可以裝一個Junit插件，運用插件進行單元測試。步驟：1、通過源代碼整理代碼邏輯，畫出流程圖；2、設計單元測試用例；3、依據用例編寫單元測試代碼；4、執行單元測試代碼；5、分析...