Dubbo是是一個高性能，基于Java的RPC框架，由阿里巴巴開源。一個分布式的服務(wù)框架。可以實現(xiàn)SOA（面向服務(wù)的架構(gòu)）架構(gòu)。 Dubbo使用的公司：京東、當(dāng)當(dāng)、阿里巴巴、中國電信等等。

分布式服務(wù)架構(gòu)的由來

以下式架構(gòu)演變過程（以下案例純粹為了說明問題，跟業(yè)務(wù)本身無關(guān)）：

早期，電信只有座機的時候，系統(tǒng)只有一個打電話的功能和一個計費的功能。因為業(yè)務(wù)單一，所以只有一個系統(tǒng)。

• 單一業(yè)務(wù)的單體式架構(gòu)

后來，電信業(yè)務(wù)豐富起來了。新增了“短信”、“寬帶”、“手機流量”等業(yè)務(wù)功能。按照常規(guī)做法，也只會在原有的“打電話”單一業(yè)務(wù)系統(tǒng)的基礎(chǔ)上，多添加幾個業(yè)務(wù)功能模塊而已。所有的業(yè)務(wù)功能（““電話”、“短信”、“寬帶”、“手機流量””）都還是在一個項目內(nèi)部。如下圖：

• 多業(yè)務(wù)單體式架構(gòu)

多業(yè)務(wù)模式下的單體架構(gòu)，當(dāng)業(yè)務(wù)不斷擴張、系統(tǒng)內(nèi)部的業(yè)務(wù)功能模塊越來越多，會導(dǎo)致如下問題：

1、會導(dǎo)致業(yè)務(wù)功能模塊的耦合度太高、不利于擴展和維護，以及推廣。

2、再者程序中存在一個魔性的數(shù)字：65535（16bit最大值）限制，（因為調(diào)用方法的指令容量只有16bit，65535正好是16bit能容納的最大數(shù)字）。重復(fù)的方法數(shù)太多，會加速達到這個上限。（比如Android 應(yīng)用65535很容易就上限了）。

比如淘寶、天貓、阿里巴巴三個項目都需要用到支付，設(shè)想，將淘寶、天貓、阿里巴巴三個項目整合成一個項目的三個業(yè)務(wù)功能模塊，將會比較雜亂。所以，出現(xiàn)了淘寶、天貓、阿里巴巴三個獨立的項目，類似下圖：

• 垂直架構(gòu)

通過一步一步演變，架構(gòu)已經(jīng)成為如圖所示的垂直式架構(gòu)。但是大家都發(fā)現(xiàn)了其中的計費功能出現(xiàn)了4次。這樣肯定不利于項目的維護和統(tǒng)一配置。（并且上圖的計費只是眾多可能重復(fù)模塊中的一員）。所以不得不將多個項目都要使用的相同模塊獨立出來，共享給業(yè)務(wù)功能使用。這樣，就演變成如下圖架構(gòu)：

如圖所示，計費被單獨提煉出來成為一個獨立的app，共其他app共同使用。圖中“其他”模塊用來代替千千萬萬類似計費的模塊。

這樣一來，每一個方塊就是一個獨立的應(yīng)用。這樣解決了業(yè)務(wù)復(fù)雜度，將業(yè)務(wù)模塊化、獨立化，方便共享和擴展。這樣的架構(gòu)帶給我們需要解決的問題如下：

1、各個獨立app之間的通信問題怎么解決？

2、怎么做到統(tǒng)一調(diào)度、協(xié)調(diào)處理。

3、如果計費模塊是并發(fā)最大的模塊，但是其他模塊并發(fā)不是很大。則需要對計費進行負(fù)載均衡，怎么實現(xiàn)？

架構(gòu)演變過程

什么是RPC？

RPC（Remote Procedure Call Protocol）遠(yuǎn)程過程調(diào)用協(xié)議。服務(wù)器A調(diào)用服務(wù)器B上的方法的一種技術(shù)。Dubbo就是一個RPC框架，實現(xiàn)了遠(yuǎn)程過程調(diào)用。

Dubbo的原理圖

dubbo主要的三個要素：1、接口的遠(yuǎn)程調(diào)用2、負(fù)載均衡。3、服務(wù)自動注冊和發(fā)現(xiàn)

Dubbo的使用

1、說明

Dubbo框架需要有注冊中心，本案例中使用Redis作為Dubbo的注冊中心。除了Redis外，Zookeeper等也可以作為Dubbo的注冊中心。

2、環(huán)境要求

JDK 1.6以上。

3、添加依賴

<dependencies> <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo --> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.5</version> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>1.8.4.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>4.3.11.RELEASE</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>4.3.11.RELEASE</version> </dependency> </dependencies>

4、定義Dubbo服務(wù)接口

其實就是創(chuàng)建一個獨立的module（并且在pom.xml導(dǎo)入以上依賴），在module中創(chuàng)建一些接口和方法（也叫服務(wù)）。比如在dubbo_service_interface中創(chuàng)建一個接口IDubboService，代碼如下:

package com.javen.dubbo.service;import java.util.List;/*** Dubbo的服務(wù)* @author yangjw*/public interface IDubboService { List<String> getData(String data);}

5、定義服務(wù)提供者（接口具體實現(xiàn)者）

創(chuàng)建另外一個module，命名dubbo_provider1（并且在pom.xml導(dǎo)入以上依賴）。將dubbo_service_interface作為依賴添加進來。

1、在其中創(chuàng)建類DubboService，并且繼承IDubboService接口。代碼如下：

package com.javen.dubbo.provider;import com.javen.dubbo.service.IDubboService;import org.springframework.stereotype.Component;import java.util.ArrayList;import java.util.List;/*** 服務(wù)提供者* @author yangjw*/@Component("dubboService")public class DubboService implements IDubboService{ public List<String> getData(String data) { ArrayList<String> list = new ArrayList<String>(); list.add("這是Dubbo中Provider返回的數(shù)據(jù)：" + data); return list; }}

2、配置spring-dubbo.xml,代碼如下：

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <context:annotation-config/> <context:component-scan base-package="com.javen.dubbo.provider"/> <!--配置dubbo服務(wù)的唯一名稱 --> <dubbo:application name="dubbo_provider1"/> <!--將服務(wù)注冊到redis中，并且配置協(xié)議和端口為20880--> <dubbo:registry address="redis://192.168.72.188:6379"/> <dubbo:protocol name="dubbo" port="20880"/> <!--配置服務(wù)接口，ref關(guān)聯(lián)到服務(wù)實現(xiàn)類--> <dubbo:service interface="com.javen.dubbo.service.IDubboService" ref="dubboService"/></beans>

3、啟動Provider,代碼如下：

package com.javen.dubbo.provider;import org.springframework.context.support.ClassPathXmlApplicationContext;import java.io.IOException;public class StartProvider { public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] {"spring-dubbo.xml"}); System.out.println("服務(wù)1啟動~~~"); context.start(); //線程阻塞：保證服務(wù)一直存在，如果線程結(jié)束，服務(wù)終止 System.in.read(); // press any key to exit }}

6、定義服務(wù)消費者（接口的具體調(diào)用者）

再創(chuàng)建一個module，命名dubbo_consumer（并且在pom.xml導(dǎo)入以上依賴）。將dubbo_service_interface作為依賴添加進來。

1、配置spring-dubbo.xml,代碼如下：

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <dubbo:application name="demo-consumer"/> <dubbo:registry address="redis://192.168.72.188:6379"/> <dubbo:reference id="demoService" interface="com.javen.dubbo.service.IDubboService"/></beans>

2、測試

package com.test;import com.javen.dubbo.service.IDubboService;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import javax.annotation.Resource;import java.util.List;@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration("classpath:spring-dubbo.xml")public class DubboTest { @Resource(name = "demoService") private IDubboService dubboService; @Test public void testDubbo(){ List<String> haha = dubboService.getData("haha"); System.out.println(haha.get(0)); }}

Dubbo、MyCat、主從配置讀寫分離、redis分布式、JTA分布式事務(wù)的關(guān)系。

dubbo默認(rèn)每次只訪問一個服務(wù)器，需要主從配合完成數(shù)據(jù)同步。

<!--replicate可以實現(xiàn)所有服務(wù)器同步寫，但是只讀取單臺服務(wù)器。默認(rèn)是failover，讀寫都是單臺服務(wù)器--> <dubbo:registry cluster="replicate" address="redis://192.168.72.188:6379"/>