SpringBoot整合Dubbo+Zookeeper實現(xiàn)RPC調(diào)用

更新時間：2023年07月30日 10:47:44 作者：失敗的面

這篇文章主要給大家介紹了Spring Boot整合Dubbo+Zookeeper實現(xiàn)RPC調(diào)用的步驟詳解，文中有詳細的代碼示例，對我們的學習或工作有一定的幫助,需要的朋友可以參考下

Spring Boot整合Dubbo+Zookeeper實現(xiàn)RPC調(diào)用

技術棧說明

Dubbo：Dubbo作為RPC框架，能在多個服務之間實現(xiàn)遠程服務的調(diào)用。比如有兩個獨立的微服務A和B，A服務想要調(diào)用B服務時，因為兩者不在同個內(nèi)存空間中，不能直接調(diào)用，所以可以通過Dubbo實現(xiàn)這點。

功能和Spring Cloud的Feign相同，兩者都是應用于微服務架構的遠程調(diào)用框架

Zookeeper：作為注冊中心去管理Dubbo服務，這點和Eureka、Nacos相同。

概述

通過一個示例說明Dubbo+Zookeeper在Spring Boot中的應用。

現(xiàn)有兩個服務provider和consumer，即生產(chǎn)者和消費者：

實現(xiàn)步驟

搭建Zookeeper集群服務作為注冊中心（docker-compose）
Spring Boot項目，添加依賴，并創(chuàng)建三個Module：
- api：提供Service接口，但不實現(xiàn)
- provider：實現(xiàn)api的Service接口
- consumer：調(diào)用api的Service接口，并對外提供訪問接口

期望結果

調(diào)用consumer服務的訪問接口，能訪問到數(shù)據(jù)，則說明provider實現(xiàn)的服務成功注冊到zookeeper注冊中心，并被consumer獲取到。

實現(xiàn)

Zookeeper集群搭建（docker-compose）

zookeeper.yml：

version: "3"
services:
  zk1:
    image: zookeeper
    network_mode: mynetwork
    container_name: zk1
    restart: always
    hostname: zk1
    # 端口映射，三個容器的對外端口是不同的
    ports:
      - 2181:2181
      - 8081:8080
    # 路徑映射，路徑也要注意不同
    volumes:
      - /etc/localtime:/etc/localtime
      - /home/mycontainers/zk1/data:/data
      - /home/mycontainers/zk1/datalog:/datalog
    environment:
      # 當前zk實例的id
      - ZOO_MY_ID=1
      # 整個zk集群的機器、端口列表
      - ZOO_SERVERS=server.1=0.0.0.0:2888:3888;2181 server.2=zk2:2888:3888;2181 server.3=zk3:2888:3888;2181
  zk2:
    image: zookeeper
    network_mode: mynetwork
    container_name: zk2
    restart: always
    hostname: zk2
    # 端口映射，三個容器的對外端口是不同的
    ports:
      - 2182:2181
      - 8082:8080
    # 路徑映射，路徑也要注意不同
    volumes:
      - /etc/localtime:/etc/localtime
      - /home/mycontainers/zk2/data:/data
      - /home/mycontainers/zk2/datalog:/datalog
    environment:
      # 當前zk實例的id
      - ZOO_MY_ID=2
      # 整個zk集群的機器、端口列表
      - ZOO_SERVERS=server.1=zk1:2888:3888;2181 server.2=0.0.0.0:2888:3888;2181 server.3=zk3:2888:3888;2181
  zk3:
    image: zookeeper
    network_mode: mynetwork
    container_name: zk3
    restart: always
    hostname: zk3
    # 端口映射，三個容器的對外端口是不同的
    ports:
      - 2183:2181
      - 8083:8080
    # 路徑映射，路徑也要注意不同
    volumes:
      - /etc/localtime:/etc/localtime
      - /home/mycontainers/zk3/data:/data
      - /home/mycontainers/zk3/datalog:/datalog
    environment:
      # 當前zk實例的id
      - ZOO_MY_ID=3
      # 整個zk集群的機器、端口列表
      - ZOO_SERVERS=server.1=zk1:2888:3888;2181 server.2=zk2:2888:3888;2181 server.3=0.0.0.0:2888:3888;2181

啟動服務：

docker-compose -f zookeeper.yml up

訪問Zookeeper：http://mylocalhost:8081/commands

有Json結果輸出表示Zookeeper服務啟動成功。

Spring Boot添加Dubbo依賴

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>2.3.4.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>3.1.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
            <version>3.1.0</version>
        </dependency>
    </dependencies>
</dependencyManagement>
<!--使用阿里云的Maven源-->
<repositories>
    <repository>
        <id>aliyunmaven</id>
        <name>aliyun</name>
        <url>https://maven.aliyun.com/repository/public</url>
    </repository>
</repositories>

dubbo-api代碼

僅提供接口，不提供實現(xiàn)，讓provider去實現(xiàn)代碼，來驗證provider和consumer之間的脫藕。

/service
	TimeService

package com.cc.service;
import java.time.LocalDateTime;
public interface TimeService {
    LocalDateTime getTime();
}

dubbo-provider代碼

provider和consumer的pom.xml是一致的：

<dependencies>
    <!--springboot啟動器-->
    <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>junit</groupId>
        <artifactId>junit</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-registry-zookeeper</artifactId>
    </dependency>
    <dependency>
        <groupId>com.com.cc</groupId>
        <artifactId>dubbo-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
</dependencies>

application.yml

server:
  port: 8081
dubbo:
  application:
    name: provider-app
  registry:
    address: zookeeper://mylocalhost:2181

provider去實現(xiàn)類的接口，TimeServiceImpl.java：

package com.cc.service.impl;
import com.cc.service.TimeService;
import org.apache.dubbo.config.annotation.DubboService;
import java.time.LocalDateTime;
// 使用這個注解，可以將該接口實現(xiàn)注冊到注冊中心
@DubboService
public class TimeServiceImpl implements TimeService {
    @Override
    public LocalDateTime getTime() {
        return LocalDateTime.now();
    }
}

啟動類需要添加@EnableDubbo注解：

@EnableDubbo
@SpringBootApplication
public class ProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}

dubbo-consumer代碼

application.yml：

server:
  port: 8082
dubbo:
  application:
    name: consumer-app
  registry:
    address: zookeeper://mylocalhost:2181

對外提供訪問接口：

@RestController
public class ConsumerController {
    @DubboReference
    private TimeService timeService;
    @GetMapping("/")
    public String getTime() {
        return timeService.getTime().format(DateTimeFormatter.ISO_DATE_TIME);
    }
}

記得添加@Dubbo注解：

@EnableDubbo
@SpringBootApplication
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}