[TOC]
dubbo簡單教程
目錄
<pre>
簡介
環(huán)境準(zhǔn)備
下載和導(dǎo)入github上dubbo代碼
使用maven打包dubbo工程
介紹dubbo框架
安裝zookeeper集群
監(jiān)控中心安裝
管理員控制臺安裝
運行provider
運行consumer
運行自己的Demo
</pre>
簡介
本例子不牽涉復(fù)雜的運行原理的解釋沛豌,只是教初學(xué)者怎樣使用dubbo框架陪白,如果后續(xù)自己感興趣的話可以自行的研究其中的原理
環(huán)境準(zhǔn)備
開發(fā)環(huán)境:eclispe
** 依賴插件:eclipse maven插件倔喂、eclipse github插件
** 備注:如果不會安裝maven插件的話可以自行的百度警没。
下載和導(dǎo)入github上dubbo代碼</br>
1.下載github上dubbo代碼粘姜,github上dubbo地址:
https://github.com/alibaba/dubbo
2.獲得下載地址,見下圖
3.導(dǎo)入到eclipse中,步驟如下
import->Git->Projects from Git->Clone URI->在RUL中粘貼github在dubbo上的地址,目前為:https://github.com/alibaba/dubbo.git->點擊下一步->選擇import as general project,下一步->輸入Project name 點擊Finish
操作截圖如下
4.目前為止dubbo中的代碼已經(jīng)導(dǎo)入進(jìn)去了湃窍,截圖如下
但是不是我們經(jīng)常看見的maven項目匪傍,只需要最后一步就操作完成了您市,步驟
import -> Maven -> Existing Maven Projects ->選擇未被選中的dubbo/pom.xml中的那個,點擊Finish
截圖如下
到現(xiàn)在為止熟悉的界面回來了役衡,導(dǎo)入代碼完成茵休。
使用maven打包dubbo工程
1.先clean 和update Project一下工程。
2.使用maven clean install一下手蝎,Goals輸入?yún)?shù):clean install -Dmaven.test.skip,有兩個作用
一是:將缺失的jar包安裝到maven倉庫中榕莺,例如dubbo-xx.jar。
二是:打下各個工程的包棵介,一會兒要用钉鸯。
截圖如下
如果看到下邊截圖證明大功告成
截止目前為止前期準(zhǔn)備工作已經(jīng)完成
介紹dubbo框架最簡單的dubbo框架需要三部分
1.注冊中心:這次使用zookeeper集群
2.管理中心:這次使用的是剛才打包的dubbo-admin-2.5.4-SNAPSHOT,這個是web程序使用tomcat啟動
3.監(jiān)控組件:這次使用剛才打包的dubbo-monitor-simple-2.5.4-SNAPSHOT是監(jiān)控程序,這個是java程序直接用腳本啟動就行
4.生產(chǎn)者服務(wù)端:這是使用剛才打包的dubbo-demo-provider-2.5.4-SNAPSHOT鞍时,這個是java程序直接用腳本啟動就行
5.消費者客戶端:這次使用剛才打包的dubbo-demo-consumer-2.5.4-SNAPSHOT亏拉,這個是java程序直接用腳本啟動就行
簡單的運行流程為先啟動注冊中心zookeeper集群扣蜻,然后啟動管理中心者里邊有可視化的管理界面逆巍,然后啟動監(jiān)控組件這里邊也有可視化的監(jiān)控界面,再啟動生產(chǎn)者服務(wù)端莽使,他會向注冊中心注冊自己的服務(wù)锐极,同時在管理中心界面中可以看見,最后啟動消費者客戶端芳肌,會通過注冊中心查找合適的服務(wù)進(jìn)行遠(yuǎn)程調(diào)用消費灵再。
安裝zookeeper集群
- 去官網(wǎng)下載zookeeper壓縮包,下載解壓<pre>http://www.apache.org/dyn/closer.cgi/zookeeper/</pre>解壓到3個目錄(模擬3臺zk server):<pre>
zookeeper-1
zookeeper-2
zookeeper-3
</pre> - 創(chuàng)建每個目錄下conf/zoo.cfg配置文件
zookeeper-1/conf/zoo.cfg 內(nèi)容如下:
<pre>
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/home/hadoop/tmp/zk1/data //填寫自己的路徑
dataLogDir=/home/hadoop/tmp/zk1/log //填寫自己的路徑
clientPort=2181
server.1=localhost:2287:3387
server.2=localhost:2288:3388
server.3=localhost:2289:3389
</pre>zookeeper-2/conf/zoo.cfg 內(nèi)容如下:<pre>
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/home/hadoop/tmp/zk2/data //填寫自己的路徑
dataLogDir=/home/hadoop/tmp/zk2/log //填寫自己的路徑
clientPort=2182
server.1=localhost:2287:3387
server.2=localhost:2288:3388
server.3=localhost:2289:3389
</pre>zookeeper-3/conf/zoo.cfg 內(nèi)容如下:
<pre>
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/home/hadoop/tmp/zk3/data
dataLogDir=/home/hadoop/tmp/zk3/log
clientPort=2183
server.1=localhost:2287:3387
server.2=localhost:2288:3388
server.3=localhost:2289:3389
</pre>注:因為是在一臺機(jī)器上模擬集群,所以端口不能重復(fù)亿笤,這里用21812183翎迁,22872289,以及3387~3389相互錯開净薛。另外每個zk的instance汪榔,都需要設(shè)置獨立的數(shù)據(jù)存儲目錄、日志存儲目錄肃拜,所以dataDir痴腌、dataLogDir這二個節(jié)點對應(yīng)的目錄雌团,需要手動先創(chuàng)建好。
另外還有一個灰常關(guān)鍵的設(shè)置士聪,在每個zk server配置文件的dataDir所對應(yīng)的目錄下锦援,必須創(chuàng)建一個名為myid的文件,其中的內(nèi)容必須與zoo.cfg中server.x 中的x相同剥悟,即:
<pre>
/home/hadoop/tmp/zk1/data/myid 中的內(nèi)容為1灵寺,對應(yīng)server.1中的1
/home/hadoop/tmp/zk2/data/myid 中的內(nèi)容為2,對應(yīng)server.2中的2
/home/hadoop/tmp/zk3/data/myid 中的內(nèi)容為3区岗,對應(yīng)server.3中的3
</pre>生產(chǎn)環(huán)境中替久,分布式集群部署的步驟與上面基本相同,只不過因為各zk server分布在不同的機(jī)器躏尉,上述配置文件中的localhost換成各服務(wù)器的真實Ip即可蚯根。分布在不同的機(jī)器后,不存在端口沖突問題胀糜,可以讓每個服務(wù)器的zk均采用相同的端口颅拦,這樣管理起來比較方便。 - 啟動驗證
<pre>
zookeeper-1/bin/zkServer.sh start
zookeeper-2/bin/zkServer.sh start
zookeeper-3/bin/zkServer.sh start
</pre>啟用成功后教藻,輸入 jps 看下進(jìn)程
<pre>
20351 ZooKeeperMain
20791 QuorumPeerMain
20822 QuorumPeerMain
20865 QuorumPeerMain
</pre>應(yīng)該至少能看到以上幾個進(jìn)程距帅。可以啟動客戶端測試下:
<pre>
bin/zkCli.sh -server localhost:2181
</pre>(注:如果是遠(yuǎn)程連接括堤,把localhost換成指定的IP即可)成功后碌秸,應(yīng)該會進(jìn)到提示符下,類似下面這樣:
<pre>
[zk: localhost:2181(CONNECTED) 0]
</pre>
監(jiān)控中心安裝
進(jìn)入dubbo-simple/dubbo-monitor-simple/target目錄悄窃,可以看到dubbo-monitor-simple-2.5.4-SNAPSHOT-assembly.tar.gz文件讥电。
<pre>
tar -zxvf dubbo-monitor-simple-2.4.10-assembly.tar.gz
</pre>
解壓后進(jìn)入目錄,vim conf/dubbo.properties修改注冊中心的配置轧抗,注釋掉廣播地址恩敌,改為zookeeper作為注冊中心,
<pre>
注釋dubbo.registry.address=multicast://224.5.6.7:1234
放開dubbo.registry.address=zookeeper://127.0.0.1:2181
</pre>
其他參數(shù)如有需要可自行修改横媚。(注意:如果是本機(jī)測試纠炮,將monitor和admin都要裝到一臺機(jī)器上時,可以將dubbo.jetty.port=8083)執(zhí)行
<pre>sh bin/start.sh</pre>
可啟動monitor,訪問地址:http://127.0.0.1:8083(默認(rèn)為:8080灯蝴,8083修改后的值)截圖如下
<pre>
</pre>
管理員控制臺安裝
進(jìn)入源碼編譯目錄恢口,進(jìn)入到dubbo-admin/target,可以看到dubbo-admin-2.5.4-SNAPSHOT這個文件夾穷躁。這是web項目耕肩,需要運行在web容器下,我這里是運行到tomcat下。這個默認(rèn)使用zookeeper作為注冊中心的看疗,不過配置的本機(jī)地址沙峻,如果需要修改為其他ip,只需修改WEB-INF/dubbo.properties下的配置地址即可两芳。
<pre>
dubbo.registry.address=zookeeper://127.0.0.1:2181
</pre>啟動tomcat即可,(根據(jù)自己的tomcat配置來訪問)訪問地址:
<pre>
http://127.0.0.1:8080/dubbo-admin-2.5.4-SNAPSHOT
</pre>
默認(rèn)賬號密碼為root摔寨,可以去服務(wù)治理里邊看相關(guān)的服務(wù),進(jìn)入之后的截圖如下
<pre>
運行provider
進(jìn)入dubbo-demo/dubbo-demo-provider/target
<pre>
tar -zxvf dubbo-demo-provider-2.5.4-SNAPSHOT-assembly.tar.gz
</pre>
修改注冊中心的配置地址為zookeeper,如下:
<pre>
注釋dubbo.registry.address=multicast://224.5.6.7:1234
放開dubbo.registry.address=zookeeper://127.0.0.1:2181
</pre>執(zhí)行
<pre>
sh bin/start.sh
</pre>來啟動provider服務(wù)怖辆∈歉矗可以查看管理員控制臺看到新啟動的服務(wù)
<pre>
</pre>
運行consumer
進(jìn)入dubbo-demo/dubbo-demo-consumer/target
<pre>
tar -zxvf dubbo-demo-consumer-2.5.4-SNAPSHOT-assembly.tar.gz
</pre>修改注冊中心的配置地址為zookeeper,如下
<pre>
注釋dubbo.registry.address=multicast://224.5.6.7:1234
放開dubbo.registry.address=zookeeper://127.0.0.1:2181
</pre>執(zhí)行
<pre>
sh bin/start.sh
</pre>來啟動consumer服務(wù),可以查看管理員控制臺看到新啟動的服務(wù)竖螃。
<pre>
</pre>
運行自己的DEMO
下載樣例文件:
<pre>
https://github.com/wudixiaowei/learn-dubbo.git
</pre>
運行服務(wù)端
運行l(wèi)earn-dubbo-demo-provider項目中的Main.java類的服務(wù)端淑廊,運行結(jié)果為
<pre>
System.in.read 開始
</pre>管理員控制臺界面總會出現(xiàn)org.learn.dubbo.demo.api.ShwoNameService服務(wù)
接下來大概講解相關(guān)代碼
接口服務(wù)
ShowNameService.java
<pre>
package org.learn.dubbo.demo.api;
public interface ShowNameService {
String showName(String name);
}
</pre>
服務(wù)端實現(xiàn)類
ShowNameServiceImpl.java
<pre>
package org.learn.dubbo.demo.provider;
public class ShowNameServiceImpl implements org.learn.dubbo.demo.api.ShowNameService {
static int i = 0;
public String showName(String name) {
System.out.println("服務(wù)端執(zhí)行了 " + i );
i++;
return "名稱為 " + name;
}
}
</pre>
聲明接口ShowNameService和實現(xiàn)類ShowNameServiceImpl.java
provider.xml資源文件方式配置服務(wù)
<pre>
dubbo.properties
dubbo.container=log4j,spring
dubbo.application.name=learn-dubbo-demo-provider //暴露服務(wù)名稱
dubbo.application.owner=
dubbo.registry.address=zookeeper://127.0.0.1:2181 //注冊中心地址
dubbo.monitor.protocol=registry //協(xié)議
dubbo.protocol.name=dubbo //協(xié)議方式,這里用的是dubbo
dubbo.protocol.port=20882 //暴露端口
dubbo.service.loadbalance=random //負(fù)載方式這里是隨機(jī)
dubbo.log4j.file=logs/dubbo-demo-provider.log //日志記錄位置
dubbo.log4j.level=WARN
</pre>
運行消費端
運行l(wèi)earn-dubbo-demo-consumer項目中的Consumer.java類的服務(wù)端特咆,運行結(jié)果為
<pre>
名稱為 張三
</pre>
管理員控制臺界面總會出現(xiàn)earn-dubbo-demo-consumerx 消費者
接下來簡單講解下消費端相關(guān)代碼
消費端實現(xiàn)類
Consumer.java
<pre>
package org.learn.dubbo.demo.consumer;
import org.learn.dubbo.demo.api.ShowNameService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Consumer {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:consumer.xml");
context.start();
ShowNameService demoService = (ShowNameService)context.getBean("showNameService"); // 獲取遠(yuǎn)程服務(wù)代理
while(true){
String hello = demoService.showName("張三"); // 執(zhí)行遠(yuǎn)程方法
System.out.println(hello);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
</pre>
聲明遠(yuǎn)程接口
consumer.xml
<pre>
<?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">
<!-- 生成遠(yuǎn)程服務(wù)代理季惩,可以和本地bean一樣使用demoService -->
<dubbo:reference id="showNameService" interface="org.learn.dubbo.demo.api.ShowNameService" />
</beans>
</pre>
資源文件方式配置消費端服務(wù)
dubbo.properties
<pre>
dubbo.container=log4j,spring
dubbo.application.name=learn-dubbo-demo-consumer //消費端名稱
dubbo.application.owner=
dubbo.registry.address=zookeeper://127.0.0.1:2181 //注冊的服務(wù)
dubbo.monitor.protocol=registry
dubbo.log4j.file=logs/dubbo-demo-consumer.log
dubbo.log4j.level=WARN
</pre>到此為止我們已經(jīng)能夠運行起來一個簡單的dubbo框架了,后續(xù)的dubbo組件的相關(guān)功能可以在此基礎(chǔ)上進(jìn)行學(xué)習(xí)了腻格,接下來的學(xué)習(xí)文檔可以參考阿里官方的文檔画拾,上邊講解的非常詳細(xì)