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

大家好，我是老田

上次，我们分享了Dubbo入门案例的使用。

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内容如下：

<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.0modelVersion>

    <groupId>com.tian.dubbogroupId>
    <artifactId>spring-boot-dubbo-demoartifactId>
    <packaging>pompackaging>
    <version>1.0-SNAPSHOTversion>
    <modules>
        <module>spring-boot-dubbo-demo-apimodule>
        <module>spring-boot-dubbo-demo-providermodule>
        <module>spring-boot-dubbo-demo-consumermodule>
    modules>

    <properties>
        <spring-boot.version>2.2.1.RELEASEspring-boot.version>
    properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.bootgroupId>
                <artifactId>spring-boot-dependenciesartifactId>
                <version>${spring-boot.version}version>
                <type>pomtype>
                <scope>importscope>
            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

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

<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-demoartifactId>
        <groupId>com.tian.dubbogroupId>
        <version>1.0-SNAPSHOTversion>
    parent>
    <modelVersion>4.0.0modelVersion>

    <artifactId>spring-boot-dubbo-demo-providerartifactId>

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

    <dependencies>
        <dependency>
            <groupId>org.apache.dubbogroupId>
            <artifactId>dubbo-spring-boot-starterartifactId>
            <version>3.0.2.1version>
        dependency>
        <dependency>
            <groupId>org.apache.dubbogroupId>
            <artifactId>dubbo-dependencies-zookeeperartifactId>
            <version>3.0.2.1version>
            <type>pomtype>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4jgroupId>
                    <artifactId>slf4j-log4j12artifactId>
                exclusion>
            exclusions>
        dependency>
        <dependency>
            <groupId>com.alibaba.nacosgroupId>
            <artifactId>nacos-clientartifactId>
            <version>2.0.2version>
        dependency>
        <dependency>
            <groupId>com.tian.dubbogroupId>
            <artifactId>spring-boot-dubbo-demo-apiartifactId>
            <version>0.0.1-SNAPSHOTversion>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starterartifactId>
        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注解，其中定义了一下内容：

• 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和服务提供者差不多：

<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-demoartifactId>
        <groupId>com.tian.dubbogroupId>
        <version>1.0-SNAPSHOTversion>
    parent>
    <modelVersion>4.0.0modelVersion>

    <artifactId>spring-boot-dubbo-demo-consumerartifactId>

    <dependencies>
        <dependency>
            <groupId>org.apache.dubbogroupId>
            <artifactId>dubbo-spring-boot-starterartifactId>
            <version>3.0.2.1version>
        dependency>
        <dependency>
            <groupId>org.apache.dubbogroupId>
            <artifactId>dubbo-dependencies-zookeeperartifactId>
            <version>3.0.2.1version>
            <type>pomtype>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4jgroupId>
                    <artifactId>slf4j-log4j12artifactId>
                exclusion>
            exclusions>
        dependency>
        <dependency>
            <groupId>com.alibaba.nacosgroupId>
            <artifactId>nacos-clientartifactId>
            <version>2.0.2version>
        dependency>
        <dependency>
            <groupId>com.tian.dubbogroupId>
            <artifactId>spring-boot-dubbo-demo-apiartifactId>
            <version>0.0.1-SNAPSHOTversion>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starterartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-webartifactId>
        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注解定义的方法：

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

• 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

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

Next：Dubbo源码分析系列：Dubbo高级特性！

喜欢的朋友，我们下一期见！

推荐阅读：

Redis 宕机，数据丢了，老板要辞退我

线上服务的FGC问题排查，看这篇就够了！

程序员必备基础：10种常见安全漏洞浅析

网关技术选型，为什么选择 Openresty ？

Redis主节点的Key已过期的处理

欢迎关注微信公众号：互联网全栈架构，收取更多有价值的信息。