SpringBoot內建DUBBO，完整demo

上篇文章完成了ZooKeeper叢集的搭建https://blog.csdn.net/supreme000/article/details/109021543

本篇文章實作SprigBoot與DUBBO的內建，用搭建好的ZooKeeper叢集作注冊中心

概述

工程結構

SpringBoot內建DUBBO，完整demo

一個父工程，三個子子產品，service-api定義接口與資料結構，service-provider與service-consumer子產品內建service-api子產品，service-provider作為服務生産者實作service-api中定義的接口，service-consumer作為消費者調用接口。

service-api接口子產品

定義一個使用者資訊DTO

package com.dubbo.api.dto;

import java.io.Serializable;

public class UserDTO implements Serializable {

    private static final long serialVersionUID = 1L;

    /**
     * 使用者編号
     */
    private Integer id;
    /**
     * 昵稱
     */
    private String name;
    /**
     * 性别
     */
    private Integer gender;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getGender() {
        return gender;
    }

    public void setGender(Integer gender) {
        this.gender = gender;
    }

    @Override
    public String toString() {
        return "UserDTO{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", gender=" + gender +
                '}';
    }
}

定義一個接口UserService

package com.dubbo.api.service;

import com.dubbo.api.dto.UserDTO;

public interface UserService {

    /**
     * 根據使用者id擷取使用者資訊
     * @param id 使用者id
     * @return
     */
    UserDTO getUser(Integer id);
}

service-provider生産者子產品

引入service-api子產品，內建SpringBoot，DUBBO，Curator（用于操作ZooKeeper）依賴

pom檔案

<?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">
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>service-provider</artifactId>

    <dependencies>

        <dependency>
            <groupId>com.dubbo</groupId>
            <artifactId>service-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!-- 引入 Spring Boot 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!-- 實作對 Dubbo 的自動化配置 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.4.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.4.1</version>
        </dependency>

        <!-- 使用 Zookeeper 作為注冊中心 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.13.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.13.0</version>
        </dependency>

    </dependencies>


</project>

實作UserService接口

package com.dubbo.provider.service;

import com.dubbo.api.dto.UserDTO;
import com.dubbo.api.service.UserService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService {
    private static final Logger log = LoggerFactory.getLogger(UserServiceImpl.class);

    @Override
    public UserDTO getUser(Integer id) {
        log.info("服務生産者收到RPC調用，使用者id：{}", id);
        UserDTO userDTO = new UserDTO();
        userDTO.setId(id);
        userDTO.setGender(id%2);
        userDTO.setName(id + "号使用者");
        return userDTO;
    }
}

在resources下配置dubbo.xml配置檔案

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <dubbo:application name="service-provider"/>
    <dubbo:protocol name="dubbo" port="-1"/>
    <dubbo:provider timeout="1000"/>
    <!--多注冊中心配置-->
    <dubbo:registry address="zookeeper://你的zookeeper服務ip:端口" id="zoo1"/>
    <dubbo:registry address="zookeeper://你的zookeeper服務ip:端口" id="zoo2"/>
    <dubbo:registry address="zookeeper://你的zookeeper服務ip:端口" id="zoo3"/>

    <!--服務提供者暴露服務配置 -->
    <bean id="userServiceImpl" class="com.dubbo.provider.service.UserServiceImpl"/>
    <dubbo:service ref="userServiceImpl" inter version="1.0.0"/>

</beans>

啟動類

package com.dubbo.provider;

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

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

使用@ImportResource注解引用dubbo.xml檔案

service-consumer消費者子產品

pom檔案

<?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">
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>service-consumer</artifactId>

    <dependencies>
        <!-- 引入定義的 Dubbo API 接口 -->
        <dependency>
            <groupId>com.dubbo</groupId>
            <artifactId>service-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!-- 引入 Spring Boot 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!-- 實作對 Dubbo 的自動化配置 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.4.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.4.1</version>
        </dependency>

        <!-- 使用 Zookeeper 作為注冊中心 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.13.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.13.0</version>
        </dependency>

    </dependencies>


</project>

在resources下配置dubbo.xml配置檔案

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <dubbo:application name="user-service-consumer"/>
    <dubbo:consumer timeout="1000"/>

    <!--多注冊中心配置-->
    <dubbo:registry address="zookeeper://你的zookeeper服務ip:端口" id="zoo1"/>
    <dubbo:registry address="zookeeper://你的zookeeper服務ip:端口" id="zoo2"/>
    <dubbo:registry address="zookeeper://你的zookeeper服務ip:端口" id="zoo3"/>

    <!-- 服務消費者引用服務配置 -->
    <dubbo:reference id="userService" inter
                     version="1.0.0" validation="false" />
</beans>

使用<dubbo:reference>标簽指定要調用的服務

啟動類

package com.dubbo.consumer;

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

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

測試類

package com.dubbo.consumer.test;

import com.dubbo.api.dto.UserDTO;
import com.dubbo.api.service.UserService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class UserServiceRPCTest implements CommandLineRunner {
    private static final Logger log = LoggerFactory.getLogger(UserServiceRPCTest.class);

    @Resource
    private UserService userService;

    @Override
    public void run(String... args) throws Exception {
        for(int i = 0; i < 100; i++){
            UserDTO userDTO = userService.getUser(i);
            log.info("服務消費者發起RPC調用，傳回結果是{}", userDTO.toString());
        }
    }
}

實作CommandLineRunner接口，消費者工程啟動後執行run方法，開始調用生産者的服務

運作

dubbo在調用服務時是基于軟負載均衡算法的，這裡可以試驗一下，在本地啟動兩個生産者服務

在ZooKeeper伺服器上，使用

./zkCli.sh

進入zookeeper背景，使用

ls /dubbo/com.dubbo.api.service.UserService/providers

檢視已注冊的服務

SpringBoot內建DUBBO，完整demo

可以看到兩個已經啟動的生産者服務

啟動消費者服務，DUBBO基于自由的負載均衡算法配置設定這100個請求

兩個生産者收到的如下所示

第一個生産者服務

SpringBoot內建DUBBO，完整demo

第二個生産者服務

SpringBoot內建DUBBO，完整demo

此時在zookeeper背景使用

ls /dubbo/com.dubbo.api.service.UserService/consumers

可以看到消費者的訂閱服務的相關資訊

SpringBoot內建DUBBO，完整demo

完整代碼

連結：https://pan.baidu.com/s/16uIRl-sgyO8_jgrJEPHs6A

提取碼：h0xu

SpringBoot內建DUBBO，完整demo

繼續閱讀

kafka環境部署(二)

Kafka學習篇（二）——Kafka環境搭建安裝JDK安裝KafkaKafka指令Kafka配置

zookeeper叢集配置簡單版本

Spring Boot：靜态資源

Kafka：Topic概念與API介紹

ZooKeeper ： Curator架構之分布式屏障DistributedDoubleBarrier

ZooKeeper ： Curator架構之分布式鎖InterProcessMutex

jeecg-boot的shiro認證過程2. jwtFilter

SpringSecurity整合短信驗證碼認證

基于Springboot+VUE+Mysql的大學生校園疫情防控管理系統

springboot使用 swagger-ui 2.10.5 有關版本更新帶來的問題

阿裡巴巴分布式服務架構 Dubbo 團隊成員梁飛專訪

阿裡巴巴分布式服務架構Dubbo介紹引言SOA化服務架構DubboDubbo的主要特點

Dubbo：來自于阿裡巴巴的分布式服務架構 Dubbo：來自于阿裡巴巴的分布式服務架構

Nacos 2.0 更新前後性能對比壓測

spring boot @SpringBootApplication @EnableAutoConfiguration 的工作原理