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



    4.0.0

    com.tian.dubbo
    spring-boot-dubbo-demo
    pom
    1.0-SNAPSHOT
    
        spring-boot-dubbo-demo-api
        spring-boot-dubbo-demo-provider
        spring-boot-dubbo-demo-consumer
    

    
        2.2.1.RELEASE
    

    
        
            
                org.springframework.boot
                spring-boot-dependencies
                ${spring-boot.version}
                pom
                import

spring-boot-dubbo-demo-api

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

package com.tian.dubbo.service;

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

spring-boot-dubbo-demo-provider

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



    
        spring-boot-dubbo-demo
        com.tian.dubbo
        1.0-SNAPSHOT
    
    4.0.0

    spring-boot-dubbo-demo-provider

    
        3.0.4
    

    
        
            org.apache.dubbo
            dubbo-spring-boot-starter
            3.0.2.1
        
        
            org.apache.dubbo
            dubbo-dependencies-zookeeper
            3.0.2.1
            pom
            
                
                    org.slf4j
                    slf4j-log4j12
                
            
        
        
            com.alibaba.nacos
            nacos-client
            2.0.2
        
        
            com.tian.dubbo
            spring-boot-dubbo-demo-api
            0.0.1-SNAPSHOT
        
        
            org.springframework.boot
            spring-boot-starter

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



    
        spring-boot-dubbo-demo
        com.tian.dubbo
        1.0-SNAPSHOT
    
    4.0.0

    spring-boot-dubbo-demo-consumer

    
        
            org.apache.dubbo
            dubbo-spring-boot-starter
            3.0.2.1
        
        
            org.apache.dubbo
            dubbo-dependencies-zookeeper
            3.0.2.1
            pom
            
                
                    org.slf4j
                    slf4j-log4j12
                
            
        
        
            com.alibaba.nacos
            nacos-client
            2.0.2
        
        
            com.tian.dubbo
            spring-boot-dubbo-demo-api
            0.0.1-SNAPSHOT
        
        
            org.springframework.boot
            spring-boot-starter
        
        
            org.springframework.boot
            spring-boot-starter-web

多了一个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

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

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

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

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

Java相关栏目本月热门文章