1. 程式人生 > >分散式系統Dubbo、註冊中心zookeeper、模板freemarker

分散式系統Dubbo、註冊中心zookeeper、模板freemarker

什麼是dubbo?

隨著網際網路的發展,網站應用的規模不斷擴大,常規的垂直應用架構已無法應對,分散式服務架構以及流動計算架構勢在必行,亟需一個治理系統確保架構有條不紊的演進。

  • 單一應用架構
    • 當網站流量很小時,只需一個應用,將所有功能都部署在一起,以減少部署節點和成本。
    • 此時,用於簡化增刪改查工作量的 資料訪問框架(ORM) 是關鍵。
  • 垂直應用架構
    • 當訪問量逐漸增大,單一應用增加機器帶來的加速度越來越小,將應用拆成互不相干的幾個應用,以提升效率。
    • 此時,用於加速前端頁面開發的 Web框架(MVC) 是關鍵。
  • 分散式服務架構
    • 當垂直應用越來越多,應用之間互動不可避免,將核心業務抽取出來,作為獨立的服務,逐漸形成穩定的服務中心,使前端應用能更快速的響應多變的市場需求。
    • 此時,用於提高業務複用及整合的 分散式服務框架(RPC) 是關鍵。
  • 流動計算架構
    • 當服務越來越多,容量的評估,小服務資源的浪費等問題逐漸顯現,此時需增加一個排程中心基於訪問壓力實時管理叢集容量,提高叢集利用率。
    • 此時,用於提高機器利用率的 資源排程和治理中心(SOA) 是關鍵。

Dubbo就是資源排程和治理中心的管理工具。

Dubbo的架構

節點角色說明:

Provider: 暴露服務的服務提供方。

Consumer: 呼叫遠端服務的服務消費方。

Registry: 服務註冊與發現的註冊中心。

Monitor: 統計服務的呼叫次調和呼叫時間的監控中心。

Container: 服務執行容器。

呼叫關係說明:

0. 服務容器負責啟動,載入,執行服務提供者。

1. 服務提供者在啟動時,向註冊中心註冊自己提供的服務。

2. 服務消費者在啟動時,向註冊中心訂閱自己所需的服務。

3. 註冊中心返回服務提供者地址列表給消費者,如果有變更,註冊中心將基於長連線推送變更資料給消費者。

4. 服務消費者,從提供者地址列表中,基於軟負載均衡演算法,選一臺提供者進行呼叫,如果呼叫失敗,再選另一臺呼叫。

5. 服務消費者和提供者,在記憶體中累計呼叫次數和呼叫時間,定時每分鐘傳送一次統計資料到監控中心。

使用方法

Dubbo採用全Spring配置方式,透明化接入應用,對應用沒有任何API侵入,只需用Spring載入Dubbo的配置即可,Dubbo基於Spring的Schema擴充套件進行載入。

單一工程中spring的配置

<bean id="xxxService" class="com.xxx.XxxServiceImpl" />

<bean id="xxxAction" class="com.xxx.XxxAction">

       <property name="xxxService" ref="xxxService" />

</bean>

遠端服務:

在本地服務的基礎上,只需做簡單配置,即可完成遠端化:

將上面的local.xml配置拆分成兩份,將服務定義部分放在服務提供方remote-provider.xml,將服務引用部分放在服務消費方remote-consumer.xml。

並在提供方增加暴露服務配置<dubbo:service>,在消費方增加引用服務配置<dubbo:reference>。

釋出服務:

<!-- 和本地服務一樣實現遠端服務 -->

<bean id="xxxService" class="com.xxx.XxxServiceImpl" />

<!-- 增加暴露遠端服務配置 -->

<dubbo:service interface="com.xxx.XxxService" ref="xxxService" />

呼叫服務:

<!-- 增加引用遠端服務配置 -->

<dubbo:reference id="xxxService" interface="com.xxx.XxxService" />

<!-- 和本地服務一樣使用遠端服務 -->

<bean id="xxxAction" class="com.xxx.XxxAction">

       <property name="xxxService" ref="xxxService" />

</bean>

dubbo相關的pom.xml配置

<dependency>
				<groupId>com.alibaba</groupId>
				<artifactId>dubbo</artifactId>
				<version>${dubbo.version}</version>
			</dependency>
			<dependency>
				<groupId>org.apache.zookeeper</groupId>
				<artifactId>zookeeper</artifactId>
				<version>${zookeeper.version}</version>
			</dependency>
			<dependency>
				<groupId>com.github.sgroschupf</groupId>
				<artifactId>zkclient</artifactId>
				<version>${zkclient.version}</version>
			</dependency>
			<dependency>
				<groupId>org.freemarker</groupId>
				<artifactId>freemarker</artifactId>
				<version>${freemarker.version}</version>
			</dependency>

這其中配置了三個相關的jar包,分別是zookeeper、zkclient、freemarker,每個單列出來介紹。

zookeeper:

Zookeeper 分散式服務框架是Apache Hadoop 的一個子專案,它主要是用來解決分散式應用中經常遇到的一些資料管理問題,如:統一命名服務、狀態同步服務、叢集管理、分散式應用配置項的管理等

Zookeeper 作為一個分散式的服務框架,主要用來解決分散式叢集中應用系統的一致性問題,它能提供基於類似於檔案系統的目錄節點樹方式的資料儲存, Zookeeper 作用主要是用來維護和監控儲存的資料的狀態變化,通過監控這些資料狀態的變化,從而達到基於資料的叢集管理

簡單的說,zookeeper=檔案系統+通知機制。

 ZooKeeper是一個分散式的,開放原始碼的分散式應用程式協調服務,它包含一個簡單的原語集,分散式應用程式可以基於它實現同步服務,配置維護和 命名服務等。Zookeeper是hadoop的一個子專案,其發展歷程無需贅述。在分散式應用中,由於工程師不能很好地使用鎖機制,以及基於訊息的協調 機制不適合在某些應用中使用,因此需要有一種可靠的、可擴充套件的、分散式的、可配置的協調機制來統一系統的狀態

 ZkClient:

是由Datameer的工程師開發的開源客戶端,對Zookeeper的原生API進行了包裝,實現了超時重連、Watcher反覆註冊等功能。

freemarker:

FreeMarker是一個用Java語言編寫的模板引擎,它基於模板來生成文字輸出。FreeMarker與Web容器無關,即在Web執行時,它並不知道Servlet或HTTP。它不僅可以用作表現層的實現技術,而且還可以用於生成XML,JSP或Java 等,目前企業中:主要用Freemarker做靜態頁面或是頁面展示。

Freemarker的使用方法

第一步:例項化Freemarker的配置類

第二步:設定模板所在目錄

第三步:根據名稱獲取模板

第四步:定義資料模型

第五步:給模板設定資料模型,同時設定輸出的檔案

一個小demo

模板 (.ftl)

<!DOCTYPE HTML> 

<html> 

  <head> 

    <title>freeMarker</title> 

      <meta charset="utf-8"> 

  </head> 

  <body> 

    ${username} 

  </body> 

</html>

程式程式碼

@Test//模板資料輸出到html檔案-傳遞簡單字串

         public  void print02() throws Exception {

                  //1:例項化Freemarker的配置類

        Configuration conf = new Configuration();

        //2:設定模板所在目錄

        String dir = "F:\\dqwork\\freemarker\\ftl\\";

        conf.setDirectoryForTemplateLoading(new File(dir));

        //3:根據名稱獲取模板

        Template template = conf.getTemplate("xx.ftl");

        //4.定義資料模型

        Map<String,Object> root = new HashMap<String,Object>();

        root.put("username", "zhangsan");

        //5.給模板設定資料模型

        template.process(root, new PrintWriter(new File("F:\\dqwork\\freemarker\\html\\xx.html")));

         }

在執行dubbo構建的專案可能遇到的問題

當然在執行dubbo構建的分散式專案時,要先開啟zookeeper,專案才能正常的啟動,啟動的順序是先啟動提供者,再啟動消費者。如果出現專案啟動不起來,在專案啟動中卡住了並且程式碼沒問題的情況下,那就重啟一下zookeeper,可能是zookeeper出故障了。