SpringBoot接入第三方客户端开发 - Dubbo集成Spring Boot ，实现多注册中心 - 《Java 笔记》

多注册中心
- Nacos准备
集成Spring Boot
- spring-boot-dubbo-demo-api
- spring-boot-dubbo-demo-provider
简单总结

Java SpringBoot Dubbo
Dubbo集成Spring Boot ，实现多注册中心 - 图1

多注册中心

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，如下：
Dubbo集成Spring Boot ，实现多注册中心 - 图2

数据存储

把服务注册到Nacos上，服务相关信息需要保存。
保存在哪里呢？Nacos提供了两种方式：

本地内存（默认）
数据库

在Nacos的安装目录下/conf下面有个配置文件：application.properties，这个配置文件里就可以做相应的调整。
Dubbo集成Spring Boot ，实现多注册中心 - 图3
这里是配置了数据库，默认是没有配置数据库的，另外还需要把数据库脚本执行，也在本目录下：nacos-mysql.sql
最后，把数据库连接信息改成自己数据库连接信息即可。
另外，想深入学习Nacos的，这个数据库脚本里基本上都是中文注释，帮助还是蛮大的。

启动Nacos

Linux环境下：sh bin/startup.sh
Windows环境下：cmd bin/startup.cmd、或者直接双击startup.cmd即可。
基于Windows环境启动日志如下：
Dubbo集成Spring Boot ，实现多注册中心 - 图4
访问：http://localhost:8848/nacos/index.html

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

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

集成Spring Boot

整体项目如下：
Dubbo集成Spring Boot ，实现多注册中心 - 图7
父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注解，其中定义了一下内容：
Dubbo集成Spring Boot ，实现多注册中心 - 图8
@DubboService

version 服务版本号
timeout 超时时间
retries重试次数
registry注册中心
…
ProviderMain项目启动类
```java 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`。
<a name="MkiEq"></a>
#### 启动provider项目
项目启动好了后，回到Nacos注册中心：<br />![](https://cdn.nlark.com/yuque/0/2021/webp/396745/1637918114532-0aaa9d50-57d6-426a-bbbe-557475e4632f.webp#clientId=u9c79b779-a240-4&crop=0&crop=0&crop=1&crop=1&from=paste&id=u1b0a230b&margin=%5Bobject%20Object%5D&originHeight=244&originWidth=1080&originalType=url&ratio=1&rotation=0&showTitle=false&status=done&style=none&taskId=u74e754e4-6062-4b0a-b9af-153f3b6ec81&title=)<br />证明项目已经注册到Nacos上了.<br />顺便去看看`providers:com.tian.dubbo.service.DemoService::`详情。<br />![](https://cdn.nlark.com/yuque/0/2021/webp/396745/1637918114499-b6e4417b-0bed-47ad-a152-3e8af2d72d30.webp#clientId=u9c79b779-a240-4&crop=0&crop=0&crop=1&crop=1&from=paste&id=u0c7c1251&margin=%5Bobject%20Object%5D&originHeight=360&originWidth=1080&originalType=url&ratio=1&rotation=0&showTitle=false&status=done&style=shadow&taskId=u751a365e-aa42-40f9-b84c-63cd2f65447&title=)<br />再看看Zookeeper注册中心：<br />![](https://cdn.nlark.com/yuque/0/2021/webp/396745/1637918114787-372ba06f-4497-4624-b993-02374ae466fb.webp#clientId=u9c79b779-a240-4&crop=0&crop=0&crop=1&crop=1&from=paste&id=u6647683d&margin=%5Bobject%20Object%5D&originHeight=361&originWidth=510&originalType=url&ratio=1&rotation=0&showTitle=false&status=done&style=shadow&taskId=u63a58bf6-c6a1-456a-a5f5-c2fb0fd05ba&title=)<br />从图中可以看出，服务已经成功注册上去了。<br />到这里，服务提供者已经把服务注册到注册中心上了。<br />再来看看消费者。
<a name="nQV28"></a>
### spring-boot-dubbo-demo-consumer
pom.xml和服务提供者差不多：
```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注解定义的方法：
Dubbo集成Spring Boot ，实现多注册中心 - 图9
@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

Dubbo集成Spring Boot ，实现多注册中心