SpringBoot+Dubbo+Zookeeper項目搭建

Dubbo是一個分布式服務(wù)框架奢讨，致力于提供高性能和透明化的RPC遠程服務(wù)調(diào)用方案靠闭，以及SOA服務(wù)治理方案斗埂。Dubbo主要分為5個部分（如下圖所示）：遠程運行服務(wù)容器（container）、遠程服務(wù)提供方（provider）叠洗、注冊中心（register）甘改、遠程服務(wù)消費者（consumer）、監(jiān)控中心（monitor）灭抑。


image.png

Dubbo主要有以下幾個主要功能：
1.透明化的遠程調(diào)用方法十艾，調(diào)用遠程服務(wù)就像調(diào)用本地的服務(wù)一樣。
2.服務(wù)自動注冊與發(fā)現(xiàn)腾节。
3.軟負載均衡與容錯機制忘嫉，consumer根據(jù)從注冊中心獲取的服務(wù)列表荤牍，根據(jù)軟負載均衡算法選擇一個服務(wù)提供者（provider），如果調(diào)用失敗則重新選擇一個服務(wù)提供者榄融。

Duboo運行的幾個步驟：
1.初始化服務(wù)：將服務(wù)裝載到容器中参淫，然后進行服務(wù)注冊救湖。
2.暴露服務(wù)：分為直接暴露服務(wù)和向注冊中心暴露服務(wù)愧杯。
3.服務(wù)應(yīng)用：既然暴露服務(wù)分為兩種，那么服務(wù)的引用也必然分為兩種鞋既，一種是直接引用服務(wù)力九，另一種是從服務(wù)中心引用服務(wù)。

SpringBoot +Dubbo+zookeeper搭建demo邑闺。
首先搭建zookeeper注冊中心跌前，從apache官網(wǎng)：（https://zookeeper.apache.org/）直接下載zookeeper安裝包（解壓包），直接解壓后進入zookeeper-3.4.12\conf下陡舅，將zoo_sample.cfg文件名修改為zoo.cfg抵乓。并修改這個文件，注釋掉#dataDir=/tmp/zookeeper靶衍，并添加如下語句：dataDir=D:/program/zookeeper-3.4.12/data
dataDirLog=D:/program/zookeeper-3.4.12/log

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
#dataDir=/tmp/zookeeper

#這是我添加的 start
dataDir=D:/program/zookeeper-3.4.12/data  
dataDirLog=D:/program/zookeeper-3.4.12/log  
#這是我添加的 end

# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1

接著進入zookeeper-3.4.12\bin目錄下灾炭，直接點擊zkServer.cmd文件，如果不閃退出現(xiàn)如下界面那就是安裝zookeeper成功了颅眶，


image.png

搭建SpringBoot+Dubbo項目蜈出，首先搭建provider項目，項目的整體框架如下所示：

image.png

首先來看pom.xml文件涛酗，依賴了dubbo铡原、zookeeper還有Web等。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>Spring.boot</groupId>
    <artifactId>productor</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>productor</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        
        <!-- <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency> -->
        
      <!--  <dependency>
           <groupId>com.alibaba.boot</groupId>
           <artifactId>dubbo-spring-boot-starter</artifactId>
           <version>2.6.4</version>
       </dependency> -->

      <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.8.4</version>
      </dependency>
      <!-- <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>2.7.1</version>
      </dependency> -->
      <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.7</version>
      </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

再來看ProductorApplicatiopn啟動類的代碼商叹，加入了@ImportResource("dubbo/dubbo.xml")燕刻，去引入dubbo.xml文件，具體代碼如下所示：

package Spring.boot.productor;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("dubbo/dubbo.xml")
public class ProductorApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProductorApplication.class, args);
    }
}

dubbo.xml文件配置剖笙，代碼中有詳細注解卵洗，具體如下所示：

<?xml version="1.0" encoding="UTF-8"?>
<!-- 添加 DUBBO SCHEMA -->
<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">

    <!-- 應(yīng)用名 -->
    <dubbo:application name="dubbo-provider"/>
    <!-- 連接到哪個本地注冊中心 -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
    <!-- 用dubbo協(xié)議在20880端口暴露服務(wù) -->
    <dubbo:protocol name="dubbo" port="28080"/>
    <bean id="iProviderService" class="Spring.boot.productor.server.impl.IProviderServiceImpl" />
    <!-- 聲明需要暴露的服務(wù)接口 -->
    <dubbo:service version="1.0.0" interface="Spring.boot.productor.server.IProviderService" ref="iProviderService"/>
</beans>

application.properties配置如下所示，只是修改了了tomcat啟動的端口枯途，

server.port = 8086

需要暴露的服務(wù)接口IProviderService忌怎，就定義了一個sayHello方法，具體代碼如下所示：

package Spring.boot.productor.server;

public interface IProviderService {
    public String sayHello(String msg);
}

IProviderService的實現(xiàn)了IProviderServiceImpl代碼如下所示：

package Spring.boot.productor.server.impl;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import Spring.boot.productor.server.IProviderService;

public class IProviderServiceImpl implements IProviderService {
    private static final Logger LOGGER = LoggerFactory.getLogger(IProviderServiceImpl.class);
    @Override
    public String sayHello(String msg) {
        String result = "hello" + msg;
        LOGGER.info("***************" + result + "*************");
        return result;
    }
}

到此你的provider服務(wù)提供者已經(jīng)完成了酪夷，進入zookeeper-3.4.12\bin目錄下榴啸，點擊zkServer.cmd啟動zookeeper，接著啟動SpringBoot provider項目晚岭，進入zookeeper-3.4.12\bin目錄下鸥印，點擊zkCli.cmd，輸入ls /dubbo出現(xiàn)下圖紅色筆標志的標志，則證明你provider注冊成功库说。


既然服務(wù)提供者啟動成功那么接下來就是創(chuàng)建服務(wù)消費者了狂鞋，服務(wù)消費者項目整體框架如下所獲：


image.png

首先來看pom.xml文件配置，其實與provide提供者的pom.xml是差不多的潜的。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>Spring.boot</groupId>
    <artifactId>consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>consumer</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
              <version>2.8.4</version>
      </dependency>
      <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.7</version>
      </dependency>
        <dependency>
            <groupId>Spring.boot</groupId>
            <artifactId>productor</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

接下來來看看ConsumerApplication啟動類骚揍，也加入@ImportResource("dubbo/dubbo.xml")來引入dubbo.xml文件，具體代碼如下所示：

package Spring.boot.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("dubbo/dubbo.xml")
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

接下來創(chuàng)建一個ConsumerController來驗證是否調(diào)用了provider提供的服務(wù)了啰挪，具體代碼如下所示：

package Spring.boot.consumer.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import Spring.boot.productor.server.IProviderService;

@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    @Autowired
    IProviderService iProviderService;
    @GetMapping("/msg")
    public void testDubbo() {
        String msg = "yangnima";
        iProviderService.sayHello(msg);
    }
}

dubbo.xml文件如下所示:

<?xml version="1.0" encoding="UTF-8"?>
<!-- 添加 DUBBO SCHEMA -->
<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">

    <!-- 應(yīng)用名 -->
    <dubbo:application name="dubbo-consumer"/>
    <!-- 連接到哪個本地注冊中心 -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
    <!-- 用dubbo協(xié)議在20880端口暴露服務(wù) -->
    <dubbo:protocol name="dubbo" port="28080"/>
   <!--  <bean id="iProviderService" class="Spring.boot.productor.server.impl.IProviderServiceImpl" /> -->
    <!-- 聲明需要暴露的服務(wù)接口 -->
   <!--  <dubbo:service version="1.0.0" interface="Spring.boot.productor.server.IProviderService" ref="iProviderService"/> -->
    <dubbo:reference version="1.0.0" id="iProviderService" interface="Spring.boot.productor.server.IProviderService"/>
</beans>

appliction.propertites文件配置如下所示：

server.port=8088

Debug模式啟動consumer項目即舌，在瀏覽器中http://127.0.0.1:8088/consumer/msg块请，調(diào)試項目得到如下所示的信息姐扮，證明consumer調(diào)用了provider的服務(wù)组橄，

image.png

且在服務(wù)提供項目中控制臺輸出如下信息：

***************helloyangnima*************

至此已完成SpringBoot + Dubbo + Zookeeper項目的搭建。

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末锰什，一起剝皮案震驚了整個濱河市下硕，隨后出現(xiàn)的幾起案子，更是在濱河造成了極大的恐慌汁胆，老刑警劉巖梭姓，帶你破解...
    沈念sama閱讀 211,743評論 6贊 492
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件，死亡現(xiàn)場離奇詭異沦泌，居然都是意外死亡糊昙，警方通過查閱死者的電腦和手機，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,296評論 3贊 385
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門谢谦，熙熙樓的掌柜王于貴愁眉苦臉地迎上來释牺，“玉大人，你說我怎么就攤上這事回挽∶涣” “怎么了？”我有些...
    開封第一講書人閱讀 157,285評論 0贊 348
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵千劈，是天一觀的道長祭刚。 經(jīng)常有香客問我，道長墙牌，這世上最難降的妖魔是什么涡驮？ 我笑而不...
    開封第一講書人閱讀 56,485評論 1贊 283
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任，我火速辦了婚禮喜滨，結(jié)果婚禮上捉捅，老公的妹妹穿的比我還像新娘。我一直安慰自己虽风，他們只是感情好棒口，可當我...
    茶點故事閱讀 65,581評論 6贊 386
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布寄月。 她就那樣靜靜地躺著，像睡著了一般无牵。 火紅的嫁衣襯著肌膚如雪漾肮。 梳的紋絲不亂的頭發(fā)上，一...
    開封第一講書人閱讀 49,821評論 1贊 290
  • 城市分裂傳說
    那天茎毁，我揣著相機與錄音克懊，去河邊找鬼。 笑死充岛，一個胖子當著我的面吹牛保檐，可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播崔梗，決...
    沈念sama閱讀 38,960評論 3贊 408
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼，長吁一口氣：“原來是場噩夢啊……” “哼垒在！你這毒婦竟也來了蒜魄？” 一聲冷哼從身側(cè)響起，我...
    開封第一講書人閱讀 37,719評論 0贊 266
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤场躯，失蹤者是張志新（化名）和其女友劉穎谈为，沒想到半個月后，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體踢关，經(jīng)...
    沈念sama閱讀 44,186評論 1贊 303
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡伞鲫，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,516評論 2贊 327
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年，在試婚紗的時候發(fā)現(xiàn)自己被綠了签舞。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片秕脓。...
    茶點故事閱讀 38,650評論 1贊 340
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡，死狀恐怖儒搭，靈堂內(nèi)的尸體忽然破棺而出吠架，到底是詐尸還是另有隱情，我是刑警寧澤搂鲫，帶...
    沈念sama閱讀 34,329評論 4贊 330
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布傍药，位于F島的核電站，受9級特大地震影響魂仍，放射性物質(zhì)發(fā)生泄漏拐辽。R本人自食惡果不足惜，卻給世界環(huán)境...
    茶點故事閱讀 39,936評論 3贊 313
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一擦酌、第九天 我趴在偏房一處隱蔽的房頂上張望俱诸。 院中可真熱鬧，春花似錦仑氛、人聲如沸乙埃。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,757評論 0贊 21
  • 一樁弒父案，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽介袜。三九已至甫何，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間遇伞，已是汗流浹背辙喂。 一陣腳步聲響...
    開封第一講書人閱讀 31,991評論 1贊 266
  • 情欲美人皮
    我被黑心中介騙來泰國打工， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留鸠珠，地道東北人巍耗。 一個月前我還...
    沈念sama閱讀 46,370評論 2贊 360
  • 代替公主和親
    正文 我出身青樓，卻偏偏與公主長得像渐排，于是被迫代替她去往敵國和親炬太。 傳聞我的和親對象是個殘疾皇子，可洞房花燭夜當晚...
    茶點故事閱讀 43,527評論 2贊 349

推薦閱讀更多精彩內(nèi)容

  • Dubbo是什么 Dubbo是Alibaba開源的分布式服務(wù)框架驯耻，它最大的特點是按照分層的方式來架構(gòu)亲族，使用這種方式...
    Coselding閱讀 17,186評論 3贊 196
  • 0 準備 安裝注冊中心：Zookeeper、Dubbox自帶的dubbo-registry-simple可缚；安裝Du...
    七寸知架構(gòu)閱讀 13,979評論 0贊 88
  • 銷售部的辛代理在我的印象里是位合格的暖男霎迫，單就這一點，我經(jīng)常感嘆：他怎么不是我老公帘靡。不過看看他的身高和他略妖嬈的女...
    李沐汐閱讀 802評論 20贊 2
  • 失去的東西盡管能回來 也已經(jīng)不再是當初的模樣 你當時想要一杯酒 我只有一杯咖啡 咖啡你倒了 酒你最后也沒喝到 我希...
    墨子淵閱讀 558評論 0贊 0
  • 若問我酒是何味，有苦有甜轰胁，人生百味俱全谒主。能解我百般思量，能度我乘風御風~ 就如《酒須醉·生死不棄》里...
    無字書閱讀 631評論 1贊 1