Dubbo分布式服務框架入門（附工程）

jopen 8年前發布 | 45K 次閱讀 JEE框架

要想了解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，寫的也是非常的詳細。

2.1、Zookeeper的搭建

關于Zookeeper的介紹和搭建，博主寫了另外一篇博文，比較簡短，詳情請看：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），好啟動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://blog.csdn.net//u013142781/article/details/50387583

 本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
 轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！