文章/答案/技术大牛

发布

社区首页 >专栏 >10分钟搞定Dubbo集成Spring Boot ，实现多注册中心

10分钟搞定Dubbo集成Spring Boot ，实现多注册中心

故里

发布于 2021-12-20 09:04:59

1.2K10

代码可运行

文章被收录于专栏：故里学Java故里学Java

运行总次数：0

代码可运行

Dubbo源码分析：小白入门篇

在前面的案例中，我们使用的是Zookeeper作为注册中心。

但是如果有需要多个注册中心，怎么办？没事田哥给你安排。

还是先来张Dubbo架构图：

多注册中心

Dubbo目前差不多能支持市面上所有的注册中心：

Consul
Zookeeper
Eureka
Redis
Nacos
....

其实，我们在实际开发中，Dubbo注册中心大部分都是使用Zookeeper和Nacos。

所以，本次分享就是使用Zookeeper和Nacos进行演示。

Nacos准备

我们先从官网把Nacos下载到本地，然后在进行安装。

官网介绍：https://nacos.io/zh-cn/docs/what-is-nacos.html

下载地址：https://github.com/alibaba/nacos/releases/tag/1.4.0

运行模式

Nacos Server 有两种运行模式：

standalone 单机模式
cluster 集群模式

本文采用的是standalone模式

如果不是部署Nacos集群,则将模式修改为单机模式

打开bin/startup.cmd文件，将MODE从cluster改为 standalone,如下：

数据存储

我们把服务注册到Nacos上，服务相关信息需要保存。

保存在哪里呢？Nacos提供了两种方式：

本地内存（默认）
数据库

我们在Nacos的安装目录下/conf下面有个配置文件：application.properties，这个配置文件里就可以做相应的调整。

这里我是配置了数据库，默认是没有配置数据库的，另外还需要把数据库脚本执行，也在本目录下：nacos-mysql.sql

最后，把数据库连接信息改成自己数据库连接信息即可。

另外，想深入学习Nacos的，这个数据库脚本里基本上都是中文注释，帮助还是蛮大的。

启动Nacos

Linux环境下：sh bin/startup.sh

Windows环境下：cmd bin/startup.cmd、或者直接双击startup.cmd即可。

基于Windows环境启动日志如下：

访问：http://localhost:8848/nacos/index.html

输入用户名/密码访问 nacos/nacos

好了，说完Nacos的安装，暂时先告一段落，我们继续。

Zookeeper注册中心，这里就不在赘述了，我们在上一篇文章中就用的是Zookeeper作为注册中心的。

集成Spring Boot

整体项目如下：

项目模块这里就不介绍了，和我们上一次分享的文章一样。

父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>

    <groupId>com.tian.dubbo</groupId>
    <artifactId>spring-boot-dubbo-demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>spring-boot-dubbo-demo-api</module>
        <module>spring-boot-dubbo-demo-provider</module>
        <module>spring-boot-dubbo-demo-consumer</module>
    </modules>

    <properties>
        <spring-boot.version>2.2.1.RELEASE</spring-boot.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

spring-boot-dubbo-demo-api

API项目中就简单的是一个接口类：

package com.tian.dubbo.service;

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

spring-boot-dubbo-demo-provider

服务提供者项目中的代码解释如下：

<?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>
        <artifactId>spring-boot-dubbo-demo</artifactId>
        <groupId>com.tian.dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring-boot-dubbo-demo-provider</artifactId>

    <properties>
        <dubbo.version>3.0.4</dubbo.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>3.0.2.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>3.0.2.1</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.0.2</version>
        </dependency>
        <dependency>
            <groupId>com.tian.dubbo</groupId>
            <artifactId>spring-boot-dubbo-demo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
    </dependencies>

</project>

集成了Zookeeper、Nacos以及相关starter。

`application.properties`配置项

application.properties配置内容：

## 随机端口
server.port=-1
spring.application.name=spring-boot-dubbo-demo-provider


dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
## dubbo.registries.name.address
## name可以理解为注册中心名字
dubbo.registries.shanghai.address=zookeeper://127.0.0.1:2181
dubbo.registries.shanghai.timeout=10000 

dubbo.registries.beijing.address=nacos://127.0.0.1:8848

我们就把Zookeeper和Nacos地址配上了。

DemoServiceImpl业务实现类

package com.tian.dubbo.service;

import org.apache.dubbo.config.annotation.DubboService;

@DubboService
public class DemoServiceImpl implements DemoService {
    public String sayHello(String msg) {
        System.out.println("provider receive msg : " + msg);
        return "provider return " + msg;
    }
}

我们在Spring相关项目中，一个通常都是使用注解@Service表示我们这个是一个Service Bean，于是Dubbo也搞了一套，但此时使用的是注解@DubboService。

如果我这个Service只想注册到一个注册中心，我们可以使用：

@DubboService(registry = {"beijing"})

关于@DubboService注解，其中定义了一下内容：

@DubboService

version 服务版本号
timeout 超时时间
retries重试次数
registry注册中心
...

ProviderMain项目启动类

package com.tian.dubbo;

import org.apache.dubbo.config.spring.context.annotation.DubboComponentScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@DubboComponentScan(basePackages = "com.tian.dubbo.service")
@SpringBootApplication
public class ProviderMain {

    public static void main(String[] args) {
        SpringApplication.run(ProviderMain.class, args);
    }

}

上面，我们已经给给业务实现类加上了注解@DubboService，和Spring一样的，都是需要进行扫描ComponentScan。

启动provider项目

项目启动好了后，我们回到Nacos注册中心：

证明我们的项目已经注册到Nacos上了.

顺便我们去看看providers:com.tian.dubbo.service.DemoService::详情。

再看看Zookeeper注册中心：

从图中可以看出，我们的服务已经成功注册上去了。

到这里，我们的服务提供者已经把服务注册到注册中心上了。

我们再来看看消费者。

spring-boot-dubbo-demo-consumer

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">
    <parent>
        <artifactId>spring-boot-dubbo-demo</artifactId>
        <groupId>com.tian.dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring-boot-dubbo-demo-consumer</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>3.0.2.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>3.0.2.1</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.0.2</version>
        </dependency>
        <dependency>
            <groupId>com.tian.dubbo</groupId>
            <artifactId>spring-boot-dubbo-demo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>
</project>

多了一个web的starter。

application.properties配置文件

spring.application.name=spring-boot-dubbo-sample-consumer


dubbo.registries.shanghai.address=zookeeper://127.0.0.1:2181
dubbo.registries.shanghai.timeout=10000 

dubbo.registries.beijing.address=nacos://127.0.0.1:8848

server.port=20882

我们也配置两个注册中心。

controller测试类

我们在消费者这边写一个Controller：

package com.tian.dubbo.controller;


import com.tian.dubbo.service.DemoService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class DemoController {

    @DubboReference(registry = {"shanghai","beijing"})
    private DemoService demoService;

    @GetMapping("/sayHello")
    public String sayHello(){
        return demoService.sayHello("tian");
    }

}

我们在Spring项目中，要注入一个Service通常都是使用注解@Autowired或者@Service，但在使用Dubbo服务注入的时候，使用的注解是@DubboReference。

并且，@DubboService类似的也可以指定注册中心是一个或者多个。

关于@DubboReference注解定义的方法：

@DubboReference

具体这些是用来干什么，其实我们可以从命名上基本就能猜到。比如：

version就是用来做服务版本升级用
check就是服务启动时是否需要检查服务是否可用
url基本上是用于开发联调时候用的，绕过注册中心，直连服务
timaout 超时时间设置
registry注册中心
...

官网都是中文文档，所以这里就不在一一介绍了。

启动类

package com.tian.dubbo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

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

启动类就没什么特别，和普通Spring项目启动一样。

下面，我们来验证一下。

验证

我们访问：http://localhost:20882/sayHello

返回：provider return tian

证明我们消费者已经成功的调用到服务并返回了正确的信息。

好了，本次的演示成功了完成。

简单总结

在本文演示案例中，关于Dubbo配置文件内容，我们只是简单的配置了注册中心信息。其实我们还可以配置默认注册中心、权重等信息，相关的配置建议看官网即可。

官方文档地址：

https://dubbo.apache.org/zh/docs/advanced/multi-registry/

Dubbo集成Spring Boot实现多注册中西做一个大致的总结，步骤不如下：

Nacos和Zookeeper注册中心的搭建
创建一个api项目，打成jar包
创建服务提供者项目依赖api的jar包
引入相应的Nacos和Zookeeper依赖jar包
消费者和提供者都添加spring-boot-starter的依赖
消费者和提供者都添加dubbo-spring-boot-starter依赖
消费者和提供者都添加application.properties配置文件并配置项目配置项
提供者中业务实现类Service中需要添加注解@DubboServie
消费者需要注入Service，使用注解@DubboReference

好了，以上就是今天分享的内容。

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2021-12-20，如有侵权请联系 cloudcommunity@tencent.com 删除

对象存储

本文分享自故里学Java 微信公众号，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

1 条评论

热度

最新

thisdcw

2024-12-15

一模一样的配置,为什么我的会报错 Error creating bean with name 'dubboBootstrapApplicationListener': Initialization of bean failed; nested exception is java.lang.NoClassDefFoundError: com/alibaba/nacos/api/exception/NacosException啊

回复回复点赞举报

编辑精选文章

换一批

万字详解高可用架构设计

4649

Go 开发者必备：Protocol Buffers 入门指南

亿级月活的社交 APP，陌陌如何做到 3 分钟定位故障？