dubbo角色與呼叫執行過程

dubbo節點角色說明:
provider: 暴露服務的服務提供方
consumer: 呼叫遠端服務的服務消費方
registry: 服務註冊於發現的註冊中心
monitor： 統計服務的呼叫次數和呼叫時間的監控中心
container：服務執行容器

dubbo呼叫關係說明：
1、服務容器負責啟動,載入，執行服務提供者
2、服務提供者在啟動時,向註冊中心註冊自己提供的服務
3、服務消費者在啟動時,向註冊中心訂閱自己所需的服務
4、註冊中心返回服務提供者地址列表給消費者,如果有變更,註冊中心將基於長連線推送變更資料給消費者
5、服務消費者,從提供者地址列表中,基於軟負載均衡演算法,選一臺提供者進行呼叫,如果的呼叫失敗,則選擇另一臺呼叫
6、服務消費者和提供者,在記憶體中累計呼叫次數和呼叫時間,定時每分鐘傳送一次統計資料到監控中心

註冊中心：
zookeeper(建議使用2.3.3以上版本)
dubbo未對zookeeper服務端做任何侵入修改,只需安裝原生的zookeeper伺服器即可.所有註冊中心邏輯適配都在呼叫zookeeper客戶端時完成

zookeeper註冊中心安裝
 


筆者環境:
a)虛擬機器centos
IP地址:[192.168.1.107]

b)zookeeper
zk版本: [zookeeper-3.4.6]

1、修改/etc/hosts檔案新增host"192.168.1.107 zk-provider" 如下

[[email protected] local]# vim /etc/hosts
[[email protected] local]# cat /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
 
192.168.1.107 zk-provider

2、解壓zookeeper-3.4.6到/usr/local/

[[email protected] zookeeper-3.4.6]# pwd
/usr/local/zookeeper-3.4.6

3、在/usr/local/zookeeper-3.4.6目錄下建立目錄:

[[email protected] zookeeper-3.4.6]# mkdir logs
[[email protected] zookeeper-3.4.6]# mkdir data

4、將/usr/local/zookeeper-3.4.6/conf目錄下的zoo_sample.cfg複製一份,命名為zoo.cfg
 

[[email protected] conf]# pwd
/usr/local/zookeeper-3.4.6/conf
[[email protected] conf]# cp zoo_sample.cfg zoo.cfg

5、修改zoo.cfg檔案內容如下:

[[email protected] conf]# cat zoo.cfg
tickTime=2000
#initLimit這個配置項是用來配置zookeeper介面客戶端
initLimit=10
syncLimit=5
dataDir=/usr/local/zookeeper-3.4.6/data
dtaLogDir=/usr/local/zookeeper-3.4.6/logs
clientPort=2181
server.1=zk-provider:2888:3888

說明:server.1=zk-provider:2888:3888等同於server.1=192.168.1.107:2888:3888

6、在/usr/local/zookeeper-3.4.6/data下建立myid檔案,輸入當前服務機器所對應的編號

[[email protected] data]# pwd
/usr/local/zookeeper-3.4.6/data
[[email protected] data]# ls
myid
[[email protected] data]# cat myid
1
[[email protected] data]#

7、將zookeeper配置到環境變數

[[email protected] data]# vim /etc/profile

　　在檔案末尾增加

# zookeeper env
export ZOOKEEPER_HOME=/usr/local/zookeeper-3.4.6
export PATH=$ZOOKEEPER_HOME/bin:$PATH

儲存退出,使配置生效

[[email protected] data]# source /etc/profile

8、在防火牆開啟要用到得到埠2181、2888、3888

[[email protected] data]# vim /etc/sysconfig/iptables

　　在COMMIT之前增加如下:

-A INPUT -m state --state NEW -m tcp -p tcp --dport 2181 -j ACCEPT
-A INPUT -m state --state NEW -m tcp -p tcp --dport 2888 -j ACCEPT
-A INPUT -m state --state NEW -m tcp -p tcp --dport 3888 -j ACCEPT

重啟防火牆

[[email protected] data]# service iptables restart
[[email protected] data]# service iptables status

9、啟動zookeeper

[[email protected] zookeeper-3.4.6]# /usr/local/zookeeper-3.4.6/bin/zkServer.sh start
JMX enabled by default
Using config: /usr/local/zookeeper-3.4.6/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
#　檢視狀態
[[email protected] zookeeper-3.4.6]# zkServer.sh status
JMX enabled by default
Using config: /usr/local/zookeeper-3.4.6/bin/../conf/zoo.cfg
Mode: standalone
# 檢視輸出的服務資訊
[[email protected] zookeeper-3.4.6]# tail -500f /usr/local/zookeeper-3.4.6/bin/zookeeper.out

10、配置zookeeper隨機啟動

[[email protected] zookeeper-3.4.6]# vim /etc/rc.local
# 增加如下命令
/usr/local/zookeeper-3.4.6/bin/zkServer.sh start

dubbo服務釋出與呼叫
1、服務釋出

<?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="ws-server-user" />

    <!-- 使用zookeeper註冊中心暴露服務地址 -->
    <dubbo:registry protocol="zookeeper" address="192.168.1.107:2181" />

    <!-- 用dubbo協議在20880埠暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <bean id="userFacade" class="com.ws.server.UserFacadeImpl" />
    <!-- 使用者服務介面 -->
    <dubbo:service interface="com.ws.facade.UserFacade" ref="userFacade" />

</beans>  

2、服務呼叫

<?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="ws-client-invoke-user" />

    <!-- 使用zookeeper註冊中心暴露服務地址 -->
    <!-- 註冊中心地址 -->
    <dubbo:registry protocol="zookeeper" address="192.168.1.107:2181" />
    
    <!-- 使用者服務介面 -->
    <dubbo:reference interface="com.ws.facade.UserFacade" id="userFacadeClient" check="false"/>

</beans>  

例項demo: http://files.cnblogs.com/files/dennisit/dubbo-ws.zip

轉載請註明出處:[http://www.cnblogs.com/dennisit/p/4542901.html]