dubbo入門

[TOC]

dubbo簡單教程

目錄

<pre>
簡介
環(huán)境準備
下載和導入github上dubbo代碼
使用maven打包dubbo工程
介紹dubbo框架
安裝zookeeper集群
監(jiān)控中心安裝
管理員控制臺安裝
運行provider
運行consumer
運行自己的Demo
</pre>

簡介

本例子不牽涉復雜的運行原理的解釋,只是教初學者怎樣使用dubbo框架,如果后續(xù)自己感興趣的話可以自行的研究其中的原理

環(huán)境準備

開發(fā)環(huán)境:eclispe
** 依賴插件:eclipse maven插件、eclipse github插件
** 備注:
如果不會安裝maven插件的話可以自行的百度。

下載和導入github上dubbo代碼</br>

1.下載github上dubbo代碼,github上dubbo地址:
https://github.com/alibaba/dubbo
2.獲得下載地址,見下圖

github.png

3.導入到eclipse中,步驟如下
import->Git->Projects from Git->Clone URI->在RUL中粘貼github在dubbo上的地址,目前為:https://github.com/alibaba/dubbo.git->點擊下一步->選擇import as general project,下一步->輸入Project name 點擊Finish
操作截圖如下
git_1.png

git_2.png

git_3.png

git_4.png

git_5.png

git_6.png

4.目前為止dubbo中的代碼已經(jīng)導入進去了,截圖如下
eclipse_1.png

但是不是我們經(jīng)??匆姷膍aven項目,只需要最后一步就操作完成了,步驟
import -> Maven -> Existing Maven Projects ->選擇未被選中的dubbo/pom.xml中的那個,點擊Finish
截圖如下
eclipse_2.png

eclipse_3.png

eclipse_4.png

到現(xiàn)在為止熟悉的界面回來了,導入代碼完成。

使用maven打包dubbo工程

1.先clean 和update Project一下工程。
2.使用maven clean install一下,Goals輸入?yún)?shù):clean install -Dmaven.test.skip,有兩個作用
一是:將缺失的jar包安裝到maven倉庫中,例如dubbo-xx.jar。
二是:打下各個工程的包,一會兒要用。
截圖如下


package_1.png

如果看到下邊截圖證明大功告成


package_2.png

截止目前為止前期準備工作已經(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)者服務端:這是使用剛才打包的dubbo-demo-provider-2.5.4-SNAPSHOT,這個是java程序直接用腳本啟動就行
5.消費者客戶端:這次使用剛才打包的dubbo-demo-consumer-2.5.4-SNAPSHOT,這個是java程序直接用腳本啟動就行
簡單的運行流程為先啟動注冊中心zookeeper集群,然后啟動管理中心者里邊有可視化的管理界面,然后啟動監(jiān)控組件這里邊也有可視化的監(jiān)控界面,再啟動生產(chǎn)者服務端,他會向注冊中心注冊自己的服務,同時在管理中心界面中可以看見,最后啟動消費者客戶端,會通過注冊中心查找合適的服務進行遠程調(diào)用消費。

安裝zookeeper集群

  1. 去官網(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>
  2. 創(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>注:因為是在一臺機器上模擬集群,所以端口不能重復,這里用21812183,22872289,以及3387~3389相互錯開。另外每個zk的instance,都需要設置獨立的數(shù)據(jù)存儲目錄、日志存儲目錄,所以dataDir、dataLogDir這二個節(jié)點對應的目錄,需要手動先創(chuàng)建好。
    另外還有一個灰常關(guān)鍵的設置,在每個zk server配置文件的dataDir所對應的目錄下,必須創(chuàng)建一個名為myid的文件,其中的內(nèi)容必須與zoo.cfg中server.x 中的x相同,即:
    <pre>
    /home/hadoop/tmp/zk1/data/myid 中的內(nèi)容為1,對應server.1中的1
    /home/hadoop/tmp/zk2/data/myid 中的內(nèi)容為2,對應server.2中的2
    /home/hadoop/tmp/zk3/data/myid 中的內(nèi)容為3,對應server.3中的3
    </pre>生產(chǎn)環(huán)境中,分布式集群部署的步驟與上面基本相同,只不過因為各zk server分布在不同的機器,上述配置文件中的localhost換成各服務器的真實Ip即可。分布在不同的機器后,不存在端口沖突問題,可以讓每個服務器的zk均采用相同的端口,這樣管理起來比較方便。
  3. 啟動驗證
    <pre>
    zookeeper-1/bin/zkServer.sh start
    zookeeper-2/bin/zkServer.sh start
    zookeeper-3/bin/zkServer.sh start
    </pre>啟用成功后,輸入 jps 看下進程
    <pre>
    20351 ZooKeeperMain
    20791 QuorumPeerMain
    20822 QuorumPeerMain
    20865 QuorumPeerMain
    </pre>應該至少能看到以上幾個進程??梢詥涌蛻舳藴y試下:
    <pre>
    bin/zkCli.sh -server localhost:2181
    </pre>(注:如果是遠程連接,把localhost換成指定的IP即可)成功后,應該會進到提示符下,類似下面這樣:
    <pre>
    [zk: localhost:2181(CONNECTED) 0]
    </pre>

監(jiā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>
解壓后進入目錄,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ù)如有需要可自行修改。(注意:如果是本機測試,將monitor和admin都要裝到一臺機器上時,可以將dubbo.jetty.port=8083)執(zhí)行
<pre>sh bin/start.sh</pre>
可啟動monitor,訪問地址:http://127.0.0.1:8083(默認為:8080,8083修改后的值)截圖如下
<pre>


monitor_1.png

</pre>

管理員控制臺安裝

進入源碼編譯目錄,進入到dubbo-admin/target,可以看到dubbo-admin-2.5.4-SNAPSHOT這個文件夾。這是web項目,需要運行在web容器下,我這里是運行到tomcat下。這個默認使用zookeeper作為注冊中心的,不過配置的本機地址,如果需要修改為其他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>
默認賬號密碼為root,可以去服務治理里邊看相關(guān)的服務,進入之后的截圖如下
<pre>

admin_1.png
</pre>

運行provider

進入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服務??梢圆榭垂芾韱T控制臺看到新啟動的服務
<pre>


admin_2.png

</pre>

運行consumer

進入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服務,可以查看管理員控制臺看到新啟動的服務。
<pre>


admin_3.png

</pre>

運行自己的DEMO

下載樣例文件:
<pre>
https://github.com/wudixiaowei/learn-dubbo.git
</pre>

運行服務端

運行l(wèi)earn-dubbo-demo-provider項目中的Main.java類的服務端,運行結(jié)果為
<pre>
System.in.read 開始
</pre>管理員控制臺界面總會出現(xiàn)org.learn.dubbo.demo.api.ShwoNameService服務


admin_4.png

接下來大概講解相關(guān)代碼
接口服務
ShowNameService.java
<pre>
package org.learn.dubbo.demo.api;
public interface ShowNameService {
String showName(String name);
}
</pre>
服務端實現(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("服務端執(zhí)行了 " + i );
i++;
return "名稱為 " + name;
}
}
</pre>
聲明接口ShowNameService和實現(xiàn)類ShowNameServiceImpl.java
provider.xml資源文件方式配置服務
<pre>
dubbo.properties
dubbo.container=log4j,spring
dubbo.application.name=learn-dubbo-demo-provider //暴露服務名稱
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 //負載方式這里是隨機
dubbo.log4j.file=logs/dubbo-demo-provider.log //日志記錄位置
dubbo.log4j.level=WARN
</pre>

運行消費端

運行l(wèi)earn-dubbo-demo-consumer項目中的Consumer.java類的服務端,運行結(jié)果為
<pre>
名稱為 張三
</pre>
管理員控制臺界面總會出現(xiàn)earn-dubbo-demo-consumerx 消費者


admin_5.png

接下來簡單講解下消費端相關(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"); // 獲取遠程服務代理
while(true){
String hello = demoService.showName("張三"); // 執(zhí)行遠程方法
System.out.println(hello);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
</pre>
聲明遠程接口
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">

<!-- 生成遠程服務代理,可以和本地bean一樣使用demoService -->
<dubbo:reference id="showNameService" interface="org.learn.dubbo.demo.api.ShowNameService"  />

</beans>
</pre>

資源文件方式配置消費端服務
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 //注冊的服務
dubbo.monitor.protocol=registry
dubbo.log4j.file=logs/dubbo-demo-consumer.log
dubbo.log4j.level=WARN
</pre>到此為止我們已經(jīng)能夠運行起來一個簡單的dubbo框架了,后續(xù)的dubbo組件的相關(guān)功能可以在此基礎上進行學習了,接下來的學習文檔可以參考阿里官方的文檔,上邊講解的非常詳細

官方文檔:http://dubbo.io/User+Guide-zh.htm

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關(guān)閱讀更多精彩內(nèi)容

  • Dubbo是什么 Dubbo是Alibaba開源的分布式服務框架,它最大的特點是按照分層的方式來架構(gòu),使用這種方式...
    Coselding閱讀 17,447評論 3 196
  • Dubbo簡介 Dubbo是阿里巴巴開源的一個分布式服務框架,致力于提供高性能和透明化的RPC遠程服務調(diào)用方案,以...
    北海三少閱讀 2,138評論 1 5
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務發(fā)現(xiàn),斷路器,智...
    卡卡羅2017閱讀 136,568評論 19 139
  • 前言 說起來這應該是博主的第一篇博客,平時博主一直都有記錄筆記的習慣,都是以記錄核心知識點的形式進行記錄。工作幾年...
    李健同學閱讀 8,451評論 12 113
  • 實現(xiàn)功能 存在2個系統(tǒng),A系統(tǒng)和B系統(tǒng),A系統(tǒng)調(diào)用B系統(tǒng)的接口獲取數(shù)據(jù). 安裝zookeeper 解壓zookee...
    小愚笨閱讀 10,757評論 4 5

友情鏈接更多精彩內(nèi)容