16 Dubbo + ZooKeeper

16.1 Dubbo下載

GigHub下載地址：https://github.com/apache/dubbo-admin/tree/master-0.2.0

下載解壓，點擊進入dubbo-admin檔案夾，在該路徑下給專案打包

mvn package -Dmaven.skip.test=true  //-Dmaven.skip.test表示不打包測驗包

打包成功后，在專案的target目錄下有打包成功的檔案:dubbo-admin-0.0.1-SNAPSHOT.jar

16.2 ZooKeeper下載安裝

ZooKeeper下載地址：https://archive.apache.org/dist/zookeeper/

下載解壓，點擊進入得到如下檔案夾

在conf目錄下添加zoo.cfg檔案

直接復制一份zoo_sample.cfg，把檔案名改為“zoo.cfg”即可

服務端與客戶端

16.3 Dubbo+ZooKeeper測驗

管理員身份啟動ZooKeeper服務端

運行Dubbo，運行打包好的dubbo-admin-0.0.1-SNAPSHOT.jar檔案

在dubbo-admin-0.0.1-SNAPSHOT.jar路徑下，直接使用命令運行

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

在瀏覽器中打開：http://localhost:7001/

用戶名：root
密碼：root

16.4 服務注冊發現實戰

1、創建專案

創建一個Maven的Module名為dubbo+zookeeper，刪掉多余的檔案，在該Module下創建兩個SpringBoot專案，分別為 provider-service , sonsumer-service

2、撰寫provider-service專案

匯入相關依賴

<dependencies>
    <!-- 匯入依賴 dubbo + zookeeper-->
    <!-- dubbo-spring-boot-starter -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
        <version>2.7.3</version>
    </dependency>
    <!-- zkclient -->
    <dependency>
        <groupId>com.github.sgroschupf</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.1</version>
    </dependency>
    <!--日志會沖突-->
    <!-- curator-framework -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>5.2.0</version>
    </dependency>
    <!-- curator-recipes -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>5.2.0</version>
    </dependency>
    <!-- zookeeper -->
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.7.0</version>
        <!--排除這個slf4j-Log4j12-->
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <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>
</dependencies>

撰寫組態檔 application.properties

server.port=8001
# 服務應用名字
dubbo.application.name=provider-server
#注冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#哪些服務要被注冊
dubbo.scan.base-packages=com.dzj.service

撰寫業務介面以及實作類

檔案路徑：com--dzj-service--TicketService.java

package com.dzj.service;

public interface TicketService {
    public String getTicket();
}

檔案路徑：com--dzj--service--TicketServiceImpl.java

package com.dzj.service;

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

//服務注冊與發現
//@DubboService  //可以被掃描到，在專案啟動就自動注冊到注冊中心
@Service
@Component
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "常回家看看";
    }
}

打開我們的Zookeeper服務，啟動運行provider-server專案，登錄Dubbo

可以看到我們的專案已經注冊到Dubbo注冊中心

接下來我們就看看如何在consumer-server專案中如何去使用我們注冊到注冊中心上的方法

3、撰寫consumer-server

匯入相關依賴

<dependencies>
    <!-- 匯入依賴 dubbo + zookeeper-->
    <!-- dubbo-spring-boot-starter -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
        <version>2.7.3</version>
    </dependency>
    <!-- zkclient -->
    <dependency>
        <groupId>com.github.sgroschupf</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.1</version>
    </dependency>
    <!--日志會沖突-->
    <!-- curator-framework -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>5.2.0</version>
    </dependency>
    <!-- curator-recipes -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>5.2.0</version>
    </dependency>
    <!-- zookeeper -->
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.7.0</version>
        <!--排除這個slf4j-Log4j12-->
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <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>
</dependencies>

撰寫組態檔application.properties

server.port=8002
#消費者去哪里拿服務，需要暴露自己的名字
dubbo.application.name=consumer-server
#注冊中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

撰寫介面以及實作類

檔案路徑：com--dzj--service--TicketService.java

package com.dzj.service;

public interface TicketService {
    public String getTicket();
}

檔案路徑：com--dzj-service--UserService.java

package com.dzj.service;

import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service  //這里是放到容器中
public class UserService {

    //想拿到provider-server提供的票,要去我們的注冊中心拿到我們的服務
    @Reference //參考，Pom坐標,可以定義路徑相同的介面名
    TicketService ticketService;

    public void buyTicket(){
        String ticket = ticketService.getTicket();
        System.out.println("在注冊中心拿到--->"+ticket);
    }
}

在SpringBoot的測驗類中呼叫測驗

package com.dzj;

import com.dzj.service.UserService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ConsumerServerApplicationTests {

    @Autowired
    UserService userService;

    @Test
    void contextLoads() {
        userService.buyTicket();
    }

}

打開我們的Zookeeper服務，啟動運行provider-server專案，啟動運行測驗類

查看結果，呼叫成功

本文來自博客園，作者：小公羊，轉載請注明原文鏈接：https://www.cnblogs.com/aadzj/p/15636911.html

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/383999.html

標籤：Java

上一篇：Redis分布式鎖解鎖案例講解

下一篇：【作業篇】介面冪等問題探究