整合spingBoot + dubbo + zookeeper實作分布式開發應用

環境搭建

專案結構圖：

1.我們首先做好服務端

pom.xml

   <dependencies>
        <!--匯入依賴：Dubbo + zookeeper-->
        <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>
        <!--引入zkclient,可能會日志沖突,還需要剔除日志依賴-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</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.wlm.service

TicketService

package com.wlm.service;

public interface TicketService {
    public String getTicket();
}

TicketServiceImpl.java

package com.wlm.service;

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

//zookeeper:服務注冊與發現
@Service //可以被掃描到，在專案一啟動就自動注冊到注冊中心
@Component //使用了Dubbo后盡量不要用Service注解
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "咸魚_翻身";
    }
}

2.啟動服務端

打開服務端，開啟之后不要點掉，讓他在后臺運行：

執行服務端的jar包，待會我們要監控服務端：

運行上面的服務端代碼，然后去游覽器中查看
http://localhost:7001/

3.我們再來做客戶端

pom.xml

<dependencies>
        <!--匯入相關的依賴-->
        <!--匯入依賴：Dubbo + zookeeper-->
        <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>
        <!--引入zkclient,可能會日志沖突,還需要剔除日志依賴-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</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

TicketService

package com.wlm.service;

public interface TicketService {
    public String getTicket();
}

UserService.java

package com.wlm.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);
    }
}

ConsumerServerApplicationTests.java

package com.wlm;

import com.wlm.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();
    }

}

運行ConsumerServerApplicationTests.java結果：拿到服務端的”咸魚_翻身“

4.總結

前提：zookeeper服務已經開啟
1.首先提供者提供服務

• 匯入依賴
• 配置注冊中心的地址，以及服務發現名，和要掃描的包
• 在想要被注冊的服務上面增加一個注解@Service

2.消費者如何消費

• 匯入依賴
• 配置注冊中心的地址，配置自己的服務名
• 從遠程注入服務 @Reference