分散式系統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出故障了。