要想了解Dubbo是什么,我們不防先了解它有什么用。
使用場景:比如我想開發一個網上商城項目,這個網上商城呢,比較復雜,分為pc端web管理后臺,微信端銷售公眾號,那么我們分成四個項目,pc端網站,微信端網站,還有一個后臺服務項目,接口服務項目。
對數據庫的操作的相關接口放到接口服務項目,這些接口的實現放在后臺服務項目,pc端網站和微信端網站都依賴接口服務項目,調用后臺數據庫數據。在這種場景下就是應該使用Dubbo這種分布式服務框架了。當然這只是Dubbo的一個最淺顯的功能。
有些猿友可能會問到了,為什么搞那么多各項目啊,不是自找麻煩麼。當你一個項目越來越復雜的時候,是必須要怎么干的,至于為什么,慢慢會有體會。
下面我們馬上介紹Dubbo:
### 一、Dubbo概念介紹(必須看!)
**1.1、Dubbo是什么?**
Dubbo是一個分布式服務框架,致力于提供高性能和透明化的RPC遠程服務調用方案,以及SOA服務治理方案。簡單的說,dubbo就是個服務框架,如果沒有分布式的需求,其實是不需要用的,只有在分布式的時候,才有dubbo這樣的分布式服務框架的需求,并且本質上是個服務調用的東東,說白了就是個遠程服務調用的分布式框架
其核心部分包含:
1》遠程通訊: 提供對多種基于長連接的NIO框架抽象封裝,包括多種線程模型,序列化,以及“請求-響應”模式的信息交換方式。
2》集群容錯: 提供基于接口方法的透明遠程過程調用,包括多協議支持,以及軟負載均衡,失敗容錯,地址路由,動態配置等集群支持。
3》自動發現: 基于注冊中心目錄服務,使服務消費方能動態的查找服務提供方,使地址透明,使服務提供方可以平滑增加或減少機器。
**1.2. Dubbo能做什么?**
1.透明化的遠程方法調用,就像調用本地方法一樣調用遠程方法,只需簡單配置,沒有任何API侵入。
2.軟負載均衡及容錯機制,可在內網替代F5等硬件負載均衡器,降低成本,減少單點。
3. 服務自動注冊與發現,不再需要寫死服務提供方地址,注冊中心基于接口名查詢服務提供者的IP地址,并且能夠平滑添加或刪除服務提供者。
**1.3. dubbo的架構**
dubbo架構圖如下所示:

節點角色說明:
Provider: 暴露服務的服務提供方。
Consumer: 調用遠程服務的服務消費方。
Registry: 服務注冊與發現的注冊中心。
Monitor: 統計服務的調用次調和調用時間的監控中心。
Container: 服務運行容器。
對于這些角色來說,其他都還好,Monitor可能猿友們前期使用會把它忽略,但是后期會發現它的作用十分明顯哦,如服務的調用量越來越大,服務的容量問題就暴露出來,這個服務需要多少機器支撐?什么時候該加機器?為了解決這個問題,第一步,要將服務現在每天的調用量,響應時間,都統計出來,作為容量規劃的參考指標。其次,要可以動態調整權重,在線上,將某臺機器的權重一直加大,并在加大的過程中記錄響應時間的變化,直到響應時間到達閥值,記錄此時的訪問量,再以此訪問量乘以機器數反推總容量。
調用關系說明:
0 服務容器負責啟動,加載,運行服務提供者。
1 服務提供者在啟動時,向注冊中心注冊自己提供的服務。
2 服務消費者在啟動時,向注冊中心訂閱自己所需的服務。
3 注冊中心返回服務提供者地址列表給消費者,如果有變更,注冊中心將基于長連接推送變更數據給消費者。
4 服務消費者,從提供者地址列表中,基于軟負載均衡算法,選一臺提供者進行調用,如果調用失敗,再選另一臺調用。
5 服務消費者和提供者,在內存中累計調用次數和調用時間,定時每分鐘發送一次統計數據到監控中心。
**1.4. dubbo使用方法**
Dubbo采用全Spring配置方式,透明化接入應用,對應用沒有任何API侵入,只需用Spring加載Dubbo的配置即可,Dubbo基于Spring的Schema擴展進行加載。如果不想使用Spring配置,而希望通過API的方式進行調用(不推薦)
Dubbo采用全Spring配置方式,透明化接入應用,對應用沒有任何API侵入,只需用Spring加載Dubbo的配置即可,Dubbo基于Spring的Schema擴展進行加載。
### 二、注冊中心、消費者、提供者搭建實例
只看理論不動手實踐好意思說自己是程序員麼?!!!必須搭建起來看看到底是什么樣的!
或許你在公司有人搭建好給你使用,但是如果你不自己搭建一次,那么很難去理解它的架構,而且一些配置文件你不知道是什么,那么你一旦遇到一些問題,自己很難去解決。因此,十分建議猿友自己動手實踐一下。
更好的查看目前發布的接口的消費者和提供者,因此一般都會配置dubbo-admin,方便監控。一般企業使用dubbo也會搭建一個dubbo-admin的,因此建議猿友們也嘗試去搭建一下,流程是比較簡單的。關于dubbo的搭建請看博文:[http://blog.csdn.net/u013142781/article/details/50396621](http://blog.csdn.net/u013142781/article/details/50396621),寫的也是非常的詳細。
**2.1、Zookeeper的搭建**
關于Zookeeper的介紹和搭建,博主寫了另外一篇博文,比較簡短,詳情請看:[http://blog.csdn.net/u013142781/article/details/50395650](http://blog.csdn.net/u013142781/article/details/50395650)
**2.2、配置提供者**
2.2.1、創建provider項目如下:



2.2.2、配置pom.xml,如下:
~~~
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.luo</groupId>
<artifactId>provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
<properties>
<spring.version>3.2.8.RELEASE</spring.version>
</properties>
<dependencies>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<!-- spring相關 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>${spring.version}</version>
</dependency>
</dependencies>
</project>
~~~
2.2.3、添加配置文件、接口和接口實現

src/main/java下添加包:com.luo.service,然后里面添加接口TestService.java:
~~~
package com.luo.service;
public interface TestService {
public String getName();
}
~~~
src/main/java下添加包:com.luo.service.impl,然后里面添加接口實現類TestServiceImpl.java:
~~~
package com.luo.service.impl;
import com.luo.service.TestService;
public class TestServiceImpl implements TestService {
public String getName() {
return "luoguohui";
}
}
~~~
src/main/resources下添加配置文件application.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 ">
<!-- 具體的實現bean -->
<bean id="testService" class="com.luo.service.impl.TestServiceImpl" />
<!-- 提供方應用信息,用于計算依賴關系 -->
<dubbo:application name="provider" />
<!-- 使用zookeeper注冊中心暴露服務地址 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<!-- 用dubbo協議在20880端口暴露服務 -->
<dubbo:protocol name="dubbo" port="29014" />
<!-- 聲明需要暴露的服務接口 -->
<dubbo:service interface="com.luo.service.TestService" ref="testService" />
</beans>
~~~
src/test/java下添加包com.luo.service,然后里面添加服務測試類TestServiceTest.java:
~~~
package com.luo.service;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class TestServiceTest {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[]{"application.xml"});
context.start();
System.out.println("提供者服務已注冊成功");
try {
System.in.read();//讓此程序一直跑,表示一直提供服務
} catch (IOException e) {
e.printStackTrace();
}
}
}
~~~
2.2.4、運行,注意順序,一定嚴格安照下面的順序
1、運行zookeeper


不要關閉黑框,讓它打開著,zookeeper 2、運行dubbo-admin,這里博主之前已經把它的war包放到tomcat的webapps下了,因此只需要運行tomcat(記得運行tomcat之前一定要把其啟動端口改成8090,原因請看博文[http://blog.csdn.net/u013142781/article/details/50396621](http://blog.csdn.net/u013142781/article/details/50396621)),好啟動tomcat:


然后訪問localhost:8090/dubbo-admin-2.5.4-SNAPSHOT,結果如下(用戶名/密碼:root/root),說明啟動dubbo-admin成功了

3、運行TestServiceTest,Run As –>Java Application,會看到控制臺如下:

保持這個provider一直啟動著。 同時在duubo-admin上搜索:com.luo.service.TestService,會看到如下結果:


ok,提供者完成!
**2.3、配置消費者**
2.3.1、創建maven項目,流程跟provider一樣,這里我起的項目名為consumer,配置pom.xml文件,如下:
~~~
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.luo</groupId>
<artifactId>consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<properties>
<spring.version>3.2.8.RELEASE</spring.version>
</properties>
<dependencies>
<!-- 添加provider的jar包 -->
<dependency>
<groupId>com.luo</groupId>
<artifactId>provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- 添加dubbo依賴 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- 添加zk客戶端依賴 -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<!-- spring相關 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>${spring.version}</version>
</dependency>
</dependencies>
</project>
~~~
其實就是在provider的基礎上添加了如下依賴(provider的依賴):
~~~
<!-- 添加provider的jar包 -->
<dependency>
<groupId>com.luo</groupId>
<artifactId>provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
~~~
2.3.2、添加如下兩個文件

application.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="consumer" />
<!-- 使用multicast廣播注冊中心暴露發現服務地址 -->
<dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />
<!-- 生成遠程服務代理,可以和本地bean一樣使用demoService -->
<dubbo:reference id="testService" interface="com.luo.service.TestService" />
</beans>
~~~
ConsumerServiceTest.java的內容如下:
~~~
package com.luo.service;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class ConsumerServiceTest {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "application.xml" });
context.start();
TestService testService = (TestService) context.getBean("testService");
System.out.println(testService.getName());
try {
System.in.read();
} catch (IOException e) {
e.printStackTrace();
}
}
}
~~~
2.3.3、運行 在保持zookeeper、dubbo-admin和provider運行著的基礎上,運行ConsumerServiceTest.java,Run As –> Java Application,會看到控制臺如下:

控制臺內容luoguohui就是提供者打印出來的 另外也會看到dubbo-admin中com.luo.service.TestService有消費者了:

ok,完成!
### 3、源碼下載
[http://download.csdn.net/detail/u013142781/9377617](http://download.csdn.net/detail/u013142781/9377617)
- 前言
- Maven入門(含實例教程)
- Spirng+SpringMVC+Maven+Mybatis+MySQL項目搭建
- Dubbo分布式服務框架入門(附工程)
- mybaits入門(含實例教程和源碼)
- Zookeeper注冊中心的搭建
- Maven+Mybatis+Spring+SpringMVC實現分頁查詢(附源碼)
- Spring中@Transactional事務回滾(含實例詳細講解,附源碼)
- RabbitMQ消息隊列入門篇(環境配置+Java實例+基礎概念)
- Spring+EhCache緩存實例(詳細講解+源碼下載)
- Redis+Spring緩存實例(windows環境,附實例源碼及詳解)
- VMware Ubuntu安裝詳細過程
- VMware Tools (ubuntu系統)安裝詳細過程與使用
- 程序員一年工作經驗之談
- Shiro安全框架入門篇(登錄驗證實例詳解與源碼)
- Spring Security安全框架入門篇