Dubbox簡介與入門實戰
前言
什麼是Dubbox?Dubbox是一個分散式服務框架,其前身是阿里巴巴開源專案Dubbo,被國內電商及網際網路專案中使用,後期阿里巴巴停止了Dubbo專案的維護(現Dubbo已捐獻給Apache基金會),因為阿里巴巴內部的HSF框架比Dubbo更高效,更貼合他們業務。噹噹網便在Dubbo基礎上進行優化,並繼續進行維護,為了與原有的Dubbo區別,故將其命名為Dubbox。
Dubbox作用
dubbox 致力於提供高效能和透明化的RPC遠端服務呼叫方案,以及SOA服務治理方案。簡單的說,dubbox就是個服務框架,如果沒有分散式的需求,其實是不需要用的,只有在分散式的時候,才有dubbox這樣的分散式服務框架的需求,並且本質上是個服務呼叫的東東,說白了就是個遠端服務呼叫的分散式框架。
那什麼是SOA服務?
SOA是Service-Oriented Architecture的首字母簡稱,它是一種支援面向服務的架構樣式。從服務、基於服務開發和服務的結果來看,面向服務是一種思考方式。其實SOA架構更多應用於網際網路專案開發。
為什麼網際網路專案會採用SOA架構呢?
隨著網際網路的發展,網站應用的規模不斷擴大,常規的垂直應用架構已無法應對,分散式服務架構以及流動計算架構勢在必行,迫切需一個治理系統確保架構有條不紊的演進。
- 單一應用架構:當網站流量很小時,只需一個應用,將所有功能都部署在一起,以減少部署節點和成本。此時,用於簡化增刪改查工作量的 資料訪問框架(ORM) 是關鍵。
- 垂直應用架構:當訪問量逐漸增大,單一應用增加機器帶來的加速度越來越小,將應用拆成互不相干的幾個應用,以提升效率。此時,用於加速前端頁面開發的 Web框架(MVC) 是關鍵。
- 分散式服務架構:當垂直應用越來越多,應用之間互動不可避免,將核心業務抽取出來,作為獨立的服務,逐漸形成穩定的服務中心,使前端應用能更快速的響應多變的市場需求。此時,用於提高業務複用及整合的 分散式服務框架(RPC) 是關鍵。
- 流動計算架構 :當服務越來越多,容量的評估,小服務資源的浪費等問題逐漸顯現,此時需增加一個排程中心基於訪問壓力實時管理叢集容量,提高叢集利用率。此時,用於提高機器利用率的 資源排程和治理中心(SOA) 是關鍵。
常用實現遠端通訊的方案
- Webservice:效率不高基於soap協議。專案中不推薦使用。
- 使用restful形式的服務:http+json。很多專案中應用。如果服務太多,服務之間呼叫關係混亂,需要治療服務。
- 使用dubbo/dubbox。使用rpc協議進行遠端呼叫,直接使用socket通訊。傳輸效率高,並且可以統計出系統之間的呼叫關係、呼叫次數。
Dubbox運作流程
節點角色說明:
- Provider:暴露服務的服務提供方。
- Consumer:呼叫遠端服務的服務消費方。
- Registry:服務註冊與發現的註冊中心。
- Monitor: 統計服務的呼叫次調和呼叫時間的監控中心。
- Container:服務執行容器。
呼叫關係說明:
- 0.服務容器負責啟動,載入,執行服務提供者。
- 1.服務提供者在啟動時,向註冊中心註冊自己提供的服務。
- 2.服務消費者在啟動時,向註冊中心訂閱自己所需的服務。
- 3.註冊中心返回服務提供者地址列表給消費者,如果有變更,註冊心將基於長連線推送變更資料給消費者。
- 4.服務消費者,從提供者地址列表中,基於軟負載均衡演算法,選一臺提供者進行呼叫,如果呼叫失敗,再選另一臺呼叫。
- 5.服務消費者和提供者,在記憶體中累計呼叫次數和呼叫時間,定時每分鐘傳送一次統計資料到監控中心。
簡單的說就是Dubbox就是把需要的服務提供方在註冊中心裡註冊,然後服務消費方在註冊中心裡查詢服務地址,找到後再去呼叫具體的服務。而每次消費記錄等資訊都在Dubbox中的Monitor中記錄儲存。
使用方法
Dubbo採用全Spring配置方式,透明化接入應用,對應用沒有任何API侵入,只需用Spring載入Dubbo的配置即可,Dubbo基於Spring的Schema擴充套件進行載入。
服務方demo:
<!--當有多個dubbo服務提供方的時候要顯示的配置埠,預設是20881-->
<dubbo:protocol name="dubbo" port="20881"></dubbo:protocol>
<!--這個為服務應用名字,在dubbox的監控中心可以看見,一般為專案的名字-->
<dubbo:application name="dubboxdemo-service" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:annotation package="com.ming.dubbox.service"/>
消費方demo:
<dubbo:application name="dubboxdemo-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<!--注意只要掃描到有dubbox的service註解都會被註冊到zookeeper中-->
<!--只要掃描到dubbox的reference註解都會去zookeeper中找-->
<dubbo:annotation package="com.ming.dubbox.controller"/>
注意使用dubbox要配合註冊中心使用,官方推薦使用zookeeper註冊中心。zookeeper簡介與安裝請看我另一篇博文Zookeeper簡介與安裝
入門實戰
目標:消費方獲取服務提供方提供的一個字串資訊。 服務反準備: 1.建立一個maven工程,專案結構如圖所示: 2.在pom中匯入Spring依賴和dubbox依賴,這裡只貼出需要的dubbox依賴:
<!-- dubbo相關 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.8.4</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<dependency>
<groupId>javassist</groupId>
<artifactId>javassist</artifactId>
<version>3.11.0.GA</version>
</dependency>
3.UserService類新增相應的服務方法:
public interface UserService {
String getUserName();
}
UserServiceImpl新增相應的實現:
//注意此Service一定要加上,並且要用阿里的註解
//com.alibaba.dubbo.config.annotation.Service
@Service
public class UserServiceImpl implements UserService {
@Override
public String getUserName() {
return "this is dubbox-service given Name";
}
}
4.在applicationContext-service.xml把服務註冊到zookeeper上
<?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:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<!--當有多個dubbo服務提供方的時候要顯示的配置埠,預設是20881-->
<dubbo:protocol name="dubbo" port="20881"></dubbo:protocol>
<dubbo:application name="dubboxdemo-service" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:annotation package="com.ming.dubbox.service"/>
</beans>
5.最後配置web.xml讓tomcat啟動去載入spring配置檔案:
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://java.sun.com/xml/ns/javaee"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
version="2.5">
<!-- 載入spring容器 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext*.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
</web-app>
消費方準備: 1.建立一個maven工程,專案結構如圖所示: 2.pom中匯入spring依賴,springmvc依賴和dubbox依賴,dubbox 需要的依賴,如服務方所示。 3.在UserService介面中新增相應的方法,注意此介面和服務提供方的介面要一致,一般在聚合工程中會把介面抽取來給消費方和服務提供方公用。
public interface UserService {
String getUserName();
}
4.在Controller中呼叫遠端服務:
@Controller
@RequestMapping("/user")
public class UserController {
//此註解正是dubbox呼叫遠端服務的關鍵註解
@Reference
private UserService userService;
@RequestMapping("/getName")
@ResponseBody
public String getName() {
return userService.getUserName();
}
}
5.配置springmvc.xml,新增zookeeper中心,讓@Reference註解生效去註冊中心尋找相應的服務地址:
<dubbo:application name="dubboxdemo-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<!--注意只要掃描到有dubbox的service註解都會被註冊到zookeeper中-->
<!--只要掃描到dubbox的reference註解都會去zookeeper中找-->
<dubbo:annotation package="com.ming.dubbox.controller"/>
6.最後配置web.xml讓DispatcherServlet和Spring配置檔案生效
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://java.sun.com/xml/ns/javaee"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
version="2.5">
<!-- 解決post亂碼 -->
<filter>
<filter-name>CharacterEncodingFilter</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>utf-8</param-value>
</init-param>
<init-param>
<param-name>forceEncoding</param-name>
<param-value>true</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>CharacterEncodingFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<servlet>
<servlet-name>springmvc</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<!-- 指定載入的配置檔案 ,通過引數contextConfigLocation載入-->
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:springmvc.xml</param-value>
</init-param>
</servlet>
<servlet-mapping>
<servlet-name>springmvc</servlet-name>
<url-pattern>*.do</url-pattern>
</servlet-mapping>
</web-app>
執行
注意啟動應用前要先啟動註冊中心zookeeper,然後先啟動服務方,後啟動消費方:
使用dubbo-admin監控服務:
至此一個簡單的Dubbox入門小案例就實現了!(≧∇≦)