Dubbo安裝、與Zookeeper、Spring內建

第一：介紹Dubbo背景

大規模服務化之前，應用可能隻是通過RMI或Hessian等工具，簡單的暴露和引用遠端服務，通過配置服務的URL位址進行調用，通過F5等硬體進行負載均衡。

(1) 當服務越來越多時，服務URL配置管理變得非常困難，F5硬體負載均衡器的單點壓力也越來越大。

此時需要一個服務注冊中心，動态的注冊和發現服務，使服務的位置透明。

并通過在消費方擷取服務提供方位址清單，實作軟負載均衡和Failover，降低對F5硬體負載均衡器的依賴，也能減少部分成本。

(2) 當進一步發展，服務間依賴關系變得錯蹤複雜，甚至分不清哪個應用要在哪個應用之前啟動，架構師都不能完整的描述應用的架構關系。

這時，需要自動畫出應用間的依賴關系圖，以幫助架構師理清理關系。

(3) 接着，服務的調用量越來越大，服務的容量問題就暴露出來，這個服務需要多少機器支撐？什麼時候該加機器？

為了解決這些問題，第一步，要将服務現在每天的調用量，響應時間，都統計出來，作為容量規劃的參考名額。

其次，要可以動态調整權重，線上上，将某台機器的權重一直加大，并在加大的過程中記錄響應時間的變化，直到響應時間到達閥值，記錄此時的通路量，再以此通路量乘以機器數反推總容量。

第二：Dubbo的簡介

Dubbo是一個分布式服務架構,解決了上面的所面對的問題，Dubbo的架構如圖所示：

Dubbo安裝、與Zookeeper、Spring內建

節點角色說明：

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

Consumer: 調用遠端服務的服務消費方。

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

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

Container: 服務運作容器。

調用關系說明：

0. 服務容器負責啟動，加載，運作服務提供者。

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

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

3. 注冊中心傳回服務提供者位址清單給消費者，如果有變更，注冊中心将基于長連接配接推送變更資料給消費者。

4. 服務消費者，從提供者位址清單中，基于軟負載均衡算法，選一台提供者進行調用，如果調用失敗，再選另一台調用。

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

Dubbo提供了很多協定，Dubbo協定、RMI協定、Hessian協定，我們檢視Dubbo源代碼，有各種協定的實作，如圖所示：

Dubbo安裝、與Zookeeper、Spring內建

我們之前沒用Dubbo之前時，大部分都使用Hessian來使用我們服務的暴露和調用，利用HessianProxyFactory調用遠端接口。

上面是參考了Dubbo官方網介紹，接下來我們來介紹SpringMVC、Dubbo、Zookeeper整合使用。

第一步：在Linux上安裝Zookeeper

1、首先，安裝Zookeeper。

下載下傳：zookeeper-3.4.6.tar.gz

官網位址：http://www.apache.org/dist/zookeeper/

個人收藏位址：http://download.csdn.net/detail/da_zhuang/8991771

2、建立zookeeper檔案目錄

mkdir zookeeper

拷貝zookeeper-3.4.6.tar.gz到指定檔案夾

3、解壓zookeeper-3.4.6.tar.gz

tar zxvf zookeeper-3.4.6.tar.gz

4、重點：

zookeeper-3.4.6/conf 下有一個檔案zoo_sample.cfg的這個檔案裡面配置了監聽用戶端連接配接的端口等一些資訊，Zookeeper 在啟動時會找zoo.cfg這個檔案作為預設配置檔案,so我們複制一個名稱為zoo.cfg的檔案#cd zookeeper-3.4.6\conf

#cp zoo_sample.cfg zoo.cfg

1.tickTime：CS通信心跳數

Zookeeper 伺服器之間或用戶端與伺服器之間維持心跳的時間間隔，也就是每個 tickTime 時間就會發送一個心跳。tickTime以毫秒為機關。

tickTime=2000

2.initLimit：LF初始通信時限

叢集中的follower伺服器(F)與leader伺服器(L)之間初始連接配接時能容忍的最多心跳數（tickTime的數量）。

initLimit=5

3.syncLimit：LF同步通信時限

叢集中的follower伺服器與leader伺服器之間請求和應答之間能容忍的最多心跳數（tickTime的數量）。

syncLimit=2

4.dataDir：資料檔案目錄

Zookeeper儲存資料的目錄，預設情況下，Zookeeper将寫資料的日志檔案也儲存在這個目錄裡。

dataDir=/home/michael/opt/zookeeper/data

5.dataLogDir：日志檔案目錄

Zookeeper儲存日志檔案的目錄。

dataLogDir=/home/michael/opt/zookeeper/log

6.clientPort：用戶端連接配接端口

用戶端連接配接 Zookeeper 伺服器的端口，Zookeeper 會監聽這個端口，接受用戶端的通路請求。

clientPort=2333

7.伺服器名稱與位址：叢集資訊（伺服器編号，伺服器位址，LF通信端口，選舉端口）

這個配置項的書寫格式比較特殊，規則如下：

server.N=YYY:A:B

其中N表示伺服器編号，YYY表示伺服器的IP位址，A為LF通信端口，表示該伺服器與叢集中的leader交換的資訊的端口。B為選舉端口，表示選舉新 leader時伺服器間互相通信的端口（當leader挂掉時，其餘伺服器會互相通信，選擇出新的leader）。一般來說，叢集中每個伺服器的A端口都是一樣，每個伺服器的B端口也是一樣。但是當所采用的為僞叢集時，IP位址都一樣，隻能時A端口和B端口不一樣。

下面是一個非僞叢集的例子：

server.0=233.34.9.144:2008:6008
server.1=233.34.9.145:2008:6008
server.2=233.34.9.146:2008:6008
server.3=233.34.9.147:2008:6008

下面是一個僞叢集的例子：

server.0=127.0.0.1:2008:6008
server.1=127.0.0.1:2007:6007
server.2=127.0.0.1:2006:6006
server.3=127.0.0.1:2005:6005

常用指令：

1. 啟動ZK服務: sh bin/zkServer.sh start
2. 檢視ZK服務狀态: sh bin/zkServer.sh status
3. 停止ZK服務: sh bin/zkServer.sh stop
4. 重新開機ZK服務: sh bin/zkServer.sh restart

更多指令：http://blog.csdn.net/xiaolang85/article/details/13021339

啟動Zookeeper：bin/zkServer.sh start

Zookeeper的安裝和配置完成。

第二步：配置dubbo-admin的管理頁面，友善我們管理頁面

Dubbo安裝：

官網下載下傳dubbo檔案。

個人收藏下載下傳位址：http://download.csdn.net/detail/da_zhuang/8991663

可直接解壓運作，前提當然是jdk環境變量...

webapps/ROOT/WEB-INF下，dubbo.properties檔案中。

其中address為zookeeper的注冊中心位址。

Dubbo安裝、與Zookeeper、Spring內建

啟動tomcat

bin/startup.sh

通路：http://x.x.x.x:8080/顯示登入頁面使用者名和密碼均為root，說明部署成功。

ps:若通路不成功，但可以ping通，關閉防火牆吧。service iptables stop

Dubbo安裝、與Zookeeper、Spring內建

SpringMVC與Dubbo的整合

本版本dubbo需要使用jdk1.7

環境使myeclipse maven 先說服務注冊：在api接口項目中增加一個接口。因圖已截好，dubboService首字母什麼的請不要在意這些細節。

Dubbo安裝、與Zookeeper、Spring內建

package com.kangzz.dubbo.service;

public interface dubboService {

public String hello(String name);

} 導出jar包：file->export->java->jar file->選擇項目->finish 将api項目導出jar包，導入服務項目中。代碼開始：

Dubbo安裝、與Zookeeper、Spring內建

package com.kangzz.dubbo.service.impl;

import org.springframework.stereotype.Service;

import com.kangzz.dubbo.service.dubboService;

@Service

public class DubboServiceImpl implements dubboService{

public String hello(String name) {

return "hello-"+name;

}

} pom引入jar包

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

紅色字型部分為解決dubbo jar包與Spring3.1的版本沖突。多說不說，配置檔案開始。applicationContext.xml

Dubbo安裝、與Zookeeper、Spring內建

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd

<dubbo:application name="dubbo_provider"></dubbo:application>

<dubbo:protocol name="dubbo" port="20881" />

<dubbo:registry address="zookeeper://192.168.8.129:2181" check="false" subscribe="false" register=""/>

<dubbo:service inter ref="dubboService" />

說明：

dubbo:registry 标簽一些屬性的說明：

1）register是否向此注冊中心注冊服務，如果設為false，将隻訂閱，不注冊。

2）check注冊中心不存在時，是否報錯。

3）subscribe是否向此注冊中心訂閱服務，如果設為false，将隻注冊，不訂閱。

4）timeout注冊中心請求逾時時間(毫秒)。

5）address可以Zookeeper叢集配置，位址可以多個以逗号隔開等。

dubbo:service标簽的一些屬性說明：

1）interface服務接口的路徑

2）ref引用對應的實作類的Bean的ID

3）registry向指定注冊中心注冊，在多個注冊中心時使用，值為<dubbo:registry>的id屬性，多個注冊中心ID用逗号分隔，如果不想将該服務注冊到任何registry，可将值設為N/A

4）register 預設true ，該協定的服務是否注冊到注冊中心。

服務端就配置好了，添加到tomcat，啟動項目就能看到如下界面了：

Dubbo安裝、與Zookeeper、Spring內建

下面是消費者了。同樣，第一步是jar包引入。自定義api jar包及dubbo需要的jar包需要導入。

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

Dubbo安裝、與Zookeeper、Spring內建

@Controller

@RequestMapping("/dubbo")

public class DubboAction {

@Autowired

private dubboService dubboService;

@RequestMapping(value = "/hello.action")

public String index(Model model){

String name=dubboService.hello("zz");

System.out.println("xx=="+name);

return "";

}

} applicationContext.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:aop="http://www.springframework.org/schema/aop"

xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

xmlns:tx="http://www.springframework.org/schema/tx"

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://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd

http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd

http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd

http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd

http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">

<description>Spring公共配置檔案</description>

<value>jdbc/mysql</value>

</property>

</bean>

</property>

<props>

<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>

</props>

</property>

<list>

<value>com.kangzz.*.entity</value>

<value>com.kangzz.*.*.entity</value>

</list>

</property>

<list>

<value>classpath:/com/kangzzentity**/entity/*.hbm.xml</value>

</list>

</property>

</bean>

<context:component-scan base-package="com.kangzz"></context:component-scan>

<dubbo:application name="dubbo_consumer"></dubbo:application>

<dubbo:registry address="zookeeper://192.168.8.129:2181" check="false"></dubbo:registry>

<dubbo:reference inter id="dubboService"></dubbo:reference>

</beans> 配置消費者tomcat

Tomcat1端口配置設定表(tomcat1全部采用預設配置)

端口	端口号
關閉指令端口	8005
http端口	8080
https端口	8443
Ajp端口	8009

Tomcat2端口配置設定表

端口	端口号
關閉指令端口	8006
http端口	8081
https端口	8444
Ajp端口	8010

tomcat啟動。

檢視消費者資訊

Dubbo安裝、與Zookeeper、Spring內建

浏覽器通路http://localhost:8081/PersonalProjectCus/dubbo/hello.action

Dubbo安裝、與Zookeeper、Spring內建

Dubbo安裝、與Zookeeper、Spring內建

繼續閱讀

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的簡單使用

neo4j之cypher使用文檔

Ambari介紹和架構原理

GitHub連夜封殺！這份阿裡 10W 字内部 Java 字面試手冊到底有多強？

spark/scala關于【資源檔案】加載方法概述外部檔案加載方案測試資源檔案打包入jar包中小結

NOSQL安全攻擊

mybatis_入門程式Mybatis入門

AOP程式設計_Android優雅權限架構(1)概念基礎，2021金三銀四前言正文大綱正文

測試面試題整理

Effective Java 8:通用程式設計

OOM三種類型

工廠模式-三種類型

【遞歸】高效率求2的n次幂

win10本地scala和spark安裝安裝scala安裝spark

scala (3) Function 和 Method