dubbo載入配置文件

A. 調用bbo服務時事務配置在哪

bbo實現了分布式遠程調用框架，多運行節點既能提高可靠性，又能提升負載能力。bbo配置主要有注冊中心（推薦zookeeper或redis）、提供者provider、消費者consumer，注冊中心是第三方實現，所以主要配置好服務提供者和消費者就可以了。實際上服務介面和實現都是需要我們自己設計和實現的，bbo做的事情就是將服務實現發布到注冊中心，然後消費者從注冊中心訂閱服務介面，之後對介面的調用就由bbo調度提供者去執行並返回結果。以下配置都有源碼，見右側「免費資源」。

提供者provider的配置：提供者是獨立運行的節點，可以多實例運行，將服務注冊到注冊中心
必須要有application name，注冊中心配置zookeeper，協議bbo，超時6秒失敗不重試，提供者載入repository和service層bean，然後發布介面service。
<bbo:application name="ite-provider" />
<bbo:registry address="zookeeper://127.0.0.1:2181"/>
<bbo:protocol name="bbo" port="20880" />
<bbo:provider timeout="6000" retries="0"/>

<import resource="classpath:cache.xml"/>
<import resource="classpath:ite-repository.xml"/>
<import resource="classpath:ite-service.xml"/>
<import resource="classpath:ite-provider.xml"/>
ite-provider.xml，ref引用的bean是ite-service.xml已經定義好的介面實現，bbo:service就是把介面實現發布到注冊中心
<bbo:service ref="codeListService" interface="com.itecheast.ite.domain.service.CodeListService" />
<bbo:service ref="idService" interface="com.itecheast.ite.domain.service.IdService" />
<bbo:service ref="passwordService" interface="com.itecheast.ite.domain.service.PasswordService" />
<bbo:service ref="rolePermissionService" interface="com.itecheast.ite.domain.service.RolePermissionService" />
provider是可以獨立運行的，bbo.jar裡面有assembly目錄，運行mvn assembly:directory就可以生成能直接運行的provider目錄

assembly.xml內容，可以切換dir或tar.gz兩種格式
<assembly>
<id>assembly</id>
<formats>
<!-- <format>tar.gz</format> -->
<format>dir</format>
</formats>
<includeBaseDirectory>true</includeBaseDirectory>
<fileSets>
<fileSet>
<directory>src/main/assembly/bin</directory>
<outputDirectory>bin</outputDirectory>
<fileMode>0755</fileMode>
</fileSet>
<fileSet>
<directory>src/main/assembly/conf</directory>
<outputDirectory>conf</outputDirectory>
<fileMode>0644</fileMode>
</fileSet>
<fileSet>
<directory>src/test/resources</directory>
<outputDirectory>conf</outputDirectory>
<fileMode>0644</fileMode>
</fileSet>
</fileSets>
<dependencySets>
<dependencySet>
<outputDirectory>lib</outputDirectory>
</dependencySet>
</dependencySets>
</assembly>
bbo.properties，運行start.bat或start.sh時，將從屬性文件讀取bbo配置信息，provider節點可以多處復制並運行。
bbo.container=log4j,spring
bbo.application.name=ite-provider
bbo.registry.address=zookeeper://127.0.0.1:2181
bbo.monitor.protocol=registry
bbo.protocol.name=bbo
bbo.protocol.port=20880
bbo.spring.config=provider.xml
bbo.log4j.file=logs/ite-provider.log
bbo.log4j.level=WARN
消費者consumer的配置，使用bbo:reference訂閱注冊中心裡的服務即可，然後就可以@Autowired注入服務介面了。
<bbo:application name="ite-consumer" />
<bbo:registry address="zookeeper://127.0.0.1:2181"/>

<bbo:reference id="codeListService" interface="com.itecheast.ite.domain.service.CodeListService" />
<bbo:reference id="idService" interface="com.itecheast.ite.domain.service.IdService" />
<bbo:reference id="passwordService" interface="com.itecheast.ite.domain.service.PasswordService" />
<bbo:reference id="rolePermissionService" interface="com.itecheast.ite.domain.service.RolePermissionService" />
如果前端項目是一個消費者，就可以在web.xml里直接載入consumer.xml訂閱服務了。
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:consumer.xml,classpath:cache.xml,classpath:shiro.xml,classpath:front.xml</param-value>
</context-param>

實際上本地調試開發時，可以不必啟用分布式配置，只需要更改web.xml即可，所有的服務都已經是配置好了的。
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:ite-repository.xml,classpath:ite-service.xml,classpath:cache.xml,classpath:shiro.xml,classpath:front.xml</param-value>
</context-param>
zookeeper的配置很簡單，
wget http://tool.xlongwei.com/softwares/zookeeper-3.4.6.tar.gz
tar -zxvf zookeeper-3.4.6.tar.gz
cd zookeeper-3.4.6/conf
cp zoo_sample.cfg zoo.cfg
vi zoo.cfg #配置zookeeper參數
單機配置（集群配置待研究）

tickTime=2000
initLimit=10
syncLimit=5
dataDir=/home/bbo/zookeeper-3.3.3/data
clientPort=2181
運行或停止zookeeper
sh zkServer.sh start | stop

B. Dubbo簡介

Dubbo是Alibaba開源的分布式服務框架，它按照分層的方式來架構，使用這種方式可以使各層解耦。

Dubbo在調用遠程的服務的時候再本地有一個介面，就想調用本地方法一樣去調用，底層實現好參數傳輸和遠程服務運行結果傳回之後的返回。

Dubbo的特點：

（1）它主要使用高效的網路框架和序列化框架，讓分布式服務之間調用效率更高。

（2）採用注冊中心管理眾多的服務介面地址，當你想調用服務的時候只需要跟注冊中心詢問即可，不像使用WebService一樣每個服務都得記錄好介面調用方式。

（3）監控中心時實現服務方和調用方之間運行狀態的監控，還能控制服務的優先順序、許可權、權重、上下線等，讓整個龐大的分布式服務系統的維護和治理比較方便。

（4）高可用，如果有服務掛了，注冊中心就會從服務列表去掉該節點，客戶端會像注冊中心請求另一台可用的服務節點重新調用。同時注冊中心也能實現高可用（ZooKeeper）。

（5）負載均衡，採用軟負載均衡演算法實現對多個相同服務的節點的請求負載均衡。

Dubbo需要四大基本組件：Rigistry,Monitor,Provider,Consumer。

1、監控中心的配置文件-bbo.properties文件

（1）容器，監控中心是在jetty和spring環境下運行，依賴於注冊中心，日誌系統是log4j

    bbo.container = log4j,spring,registry,jetty

（2）監控服務的名稱，監控系統對整個Dubbo服務系統來說也是一個服務

    bbo.application.name = simple-monitor

（3）服務的所有者，這是Dubbbo的服務的功能，可以指定服務的負責人

    bbo.application.owner = coselding

（4）注冊中心的地址，配置後監控中心就能通過注冊中心獲取當前可用的服務列表及其狀態，在頁面向你匯報Dubbo中的服務運行情況。

    bbo.registr.address = multicast://{ip}:{port} //廣播

    bbo.registr.address = zookeeper://{ip}:{port} //zookeper

    bbo.registr.address = redis://{ip}:{port} //redis

    bbo.registr.address = bbo://{ip}:{port} //bbo

（5）bbo協議埠號

    bbo.protocol.port = 7070

（6）jetty工作埠號

    bbo.jetty.port = 8082

（7）工作目錄，用於存放監控中心的數據

    bbo.jetty.directory = ${user.home}/monitor

（8）監控中心報表存放目錄

    bbo.charts.directory=${bbo.jetty.directory}/charts

（9）監控中心數據資料目錄

    bbo.statistics.directory=${user.home}/monitor/statistics

（10）監控中心日誌文件路徑

    bbo.log4j.file=logs/bbo-monitor-simple.log

（11）監控中心日誌記錄級別

    bbo.log4j.level=WARN

2、Dubbo提供負載均衡方式

（1）Random，隨機，按權重配置隨機概率，調用量越大分布越均勻，默認方式。

（2）RounRobin，輪詢，按權重設置輪詢比例，如果存在比較慢的機器容易在這台機器上請求阻塞較多。

（3）LeastActive，最少活躍調用數，不支持權重，只能根據自動識別的活躍數分配，不能靈活調配。

（4）ConsistenHash，一致性hash，對相同參數的請求路由到一個服務提供者上，如果有類似灰度發布需求可採用。

3、Dubbo過濾器

Dubbo初始化過程載入ClassPath下的META-INF/bbo/internal/，META-INF/bbo/，META-INF/services/三個路徑下的com.alibaba.bbo.rpc.Filter文件。文件內容：

    Name = FullClassName,這些類必須實現Filter介面。

自定義Filter類：

配置文件在配置過濾器，consumer.xml中：

Dubbo對過濾器的載入過程：

    先載入三個路徑下的com.alibaba.bbo.rpc.Filter文件裡面的鍵值對，key為過濾器名稱，value為過濾器的類的全限定名(這個類必須實現Dubbo中的Filter介面)。

    自定義的類中@Active註解是過濾器設定的全局基本屬性。

    Spring在載入consumer.xml文件時，通過 <bbo:consumer filter="xxx" id = "xxx" retrries = "0">這個配置指定消費者端要載入的過濾器，通過filter屬性指定過濾器名稱。

@Activate註解-自動激活，group屬性是表示匹配了對應的角色才被載入，value表示表明過濾條件，不寫則表示所有條件都會被載入，寫了則只有bbo URL中包含該參數名且參數值不為空才被載入，這個參數會以bbo協議的一個參數K-V對傳到Provider。

4、Dubbo的Provider配置

5、Dubbo的Consumer配置

1、Dubbo是什麼？

Dubbo是阿里巴巴開源的基於Java的高性能RPC分布式框架。

2、為什麼使用Dubbo？

很多公司都在使用，經過很多線上的考驗，內部使用了Netty，Zookeeper，保證了高性能可用性。

使用Dubbo可以將核心業務抽取出來，作為獨立的服務，逐漸形成穩定的服務中心，可以提高業務復用靈活性擴展，使前端應用能快速的響應對邊的市場需求。分布式架構可以承受更大規模的並發流量。

Dubbo的服務治理圖：

3、Dubbo和Spring Cloud的區別

兩個沒有關聯，但是非要說區別，有如下幾點：

（1）通信方式不同，Dubbo使用RPC通信，Spring Cloud使用HTTP Restful方式

（2）組成部分不同

4、Dubbo支持的協議

bbo://  （推薦）；rmi:// ；hessian:// ；http:// ；webservice:// ；thrift:// ；memcached:// ；redis:// ；rest:// 。

5、Dubbo需要容器嗎？

不需要，如果硬要容器的話，會增加復雜性，同時也浪費資源。

6、Dubbo內置的服務容器

Spring Container；Jetty Container；Log4j Container。

7、Dubbo中節點角色

Register，Monitor，Provider，Consumer，Container(服務運行的容器)。

8、Dubbo的服務注冊和發現的流程圖

9、Dubbo的注冊中心

默認使用Zookeper作為注冊中心，還有Redis，Multicast，bbo注冊中心。

10、Dubbo的配置方式

Spring配置方式和Java API配置方式

11、Dubbo的核心配置

（1）bbo:service 服務配置

（2）bbo:referece 引用配置

（3）bbo:protocol 協議配置

（4）bbo:application 應用配置

（5）bbo:registry 注冊中心配置

（6）bbo:monitor 監控中心配置

（7）bbo:provider 提供方配置

（8）bbo:consumer 消費方配置

（9）bbo:method 方法配置

（10）bbo:argument 參數配置

12、在Provider 節點上可以配置Consumer端的屬性有哪些？

（1）timeout：方法調用超時

（2）retries：失敗重試次數，默認是2次

（3）loadbalance：負載均衡演算法，默認隨機

（4）actives消費者端，最大並發調用控制

13、Dubbo啟動時如果依賴的服務不可用會怎樣

Dubbo預設會在啟動時檢查依賴的服務是否可用，不可用時會拋出異常，阻止Spring初始化完成。默認check ="true"。

14、Dubbo序列化框架

推薦使用Hessian序列化，還有Dubbo，FastJson，Java自帶序列化。

15、Dubbo的通信框架

默認使用Netty框架，另外也提供了Mina，Grizzly。

16、Dubbo集群容錯方案

（1）Failover Cluster，失敗自動切換，自動重試其他伺服器。

（2）Failfast Cluster，快速失敗，立即報錯，只發起一次調用。

（3）Failsafe Cluster，失敗安全，出現異常時，直接忽略。

（4）Failback Cluster，失敗自動恢復，記錄失敗請求，定時重發。

（5）Forking Cluster，並行調用多個伺服器，只要一個返回成功即可。

（6）Broadcast Cluster，廣播逐個調用所有提供者，任意一個報錯則報錯。

17、Dubbo的負載均衡策略

（1）Random LoadBalance，隨機，按權重設置隨機概率，默認。

（2）RoundRobin LoadBalace，輪詢，按公約後的權重設置輪訓比例。

（3）LeastActive LoadBalace，最少活躍調用數，相同活躍數的隨機。

（4）ConsistenHash LoadBalance，一致性hash，相同參數的請求總是發到用一個伺服器。

18、指定某一個服務

可以配置環境點對點直連，繞過注冊中心，將以服務介面為單位，忽略注冊中心的提供者列表。

<bbo:reference interface="com.weidian.bbo.IMyDemo" version="1.0" id="myDemo" url="bbo://127.0.0.1:20880/"></bbo:reference>

19、Dubbo多協議

Dubbo允許配置多協議，在不同伺服器上支持不同協議，或者同一服務支持多種協議。

20、當一個服務有多種實現時怎麼做？

當一個介面有多種是現實，可以用group屬性來分組，服務提供方和消費方都指定同一個group即可。

21、兼容舊版本

使用版本號過度，多個不同版本的服務注冊到注冊中心，版本號不同的服務相互間不引用。

22、Dubbo可以緩存嗎？

Dubbo提供聲明式緩存，用於加速熱門數據的訪問速度，以減少用戶加緩存的工作量。

23、Dubbo服務之間的調用時阻塞的嗎？

默認是同步等待結果阻塞的，支持非同步調用。Dubbo是基於NIO的非阻塞實現並行調用的，客戶端不需要啟動多線程即可完成並行調用多個遠程服務，相對多線程開銷較小，非同步調用會返回一個Future對象。

24、Dubbo不支持分布式事務

25、Dubbo必須依賴的包

Dubbo必須依賴JDK，其他為可選。

26、Dubbo使用過程中的問題

Dubbo的設計目的是為了滿足高並發小數據量的rpc請求，在大數據量下性能表現不是很好，建議使用rmi或http協議。

27、Dubbo的管理控制台的作用

路由規則，動態配置，服務降級，訪問控制，權重調整，負載均衡。

28、Spring boot整合Dubbo

（1）添加依賴

        <!-- https://mvnrepository.com/artifact/com.alibaba.boot/bbo-spring-boot-project -->

        <dependency>

            <groupId>com.alibaba.boot</groupId>

            <artifactId>bbo-spring-boot-starter</artifactId>

            <version>0.1.0</version>

        </dependency>

        <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->

        <dependency>

            <groupId>com.101tec</groupId>

            <artifactId>zkclient</artifactId>

            <version>0.10</version>

        </dependency>

（2）配置bbo

    ## Dubbo 服務提供者配置

    spring.bbo.application.name=provider

    spring.bbo.registry.address=zookeeper://127.0.0.1:2181

    spring.bbo.protocol.name=bbo

    spring.bbo.protocol.port=20880

    spring.bbo.scan=org.spring.springboot.bbo

    ## Dubbo 服務消費者配置

    spring.bbo.application.name=consumer

    spring.bbo.registry.address=zookeeper://127.0.0.1:2181

    spring.bbo.scan=org.spring.springboot.bbo

C. 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
來源：簡書
簡書著作權歸作者所有，任何形式的轉載都請聯系作者獲得授權並註明出處。