正文 

当前位置： 首页 > java > java框架

springboot整合dubbo和zookeeper

lijianming180      2022-05-19     638

关键词：

Dubbo是一款由阿里巴巴开发的远程服务调用框架（RPC），其可以透明化的调用远程服务，就像调用本地服务一样简单。截至目前，Dubbo发布了基于Spring Boot构建的版本，版本号为0.2.0，这使得其与Spring Boot项目整合变得更为简单方便。而Zookeeper在这里充当的是服务注册中心的角色，我们将各个微服务提供的服务通过Dubbo注册到Zookeeper中，然后服务消费者通过Dubbo从Zookeeper中获取相应服务并消费。本文案例的架构图可以简单用下图表示：

技术图片

本文案例最终项目结构如下图所示：

技术图片

项目采用Maven构建，各模块的作用：

模块 描述
common-api 统一定义接口，供其余子模块引用
server-provider 服务提供者，实现common-api模块中的接口，然后暴露到Zookeeper中，供服务消费者使用
server-consumer 服务消费者，通过Dubbo从Zookeeper中获取服务并消费

环境准备

Zookeeper安装

在搭建项目之前需要启动Zookeeper服务，Zookeeper下载地址：http://zookeeper.apache.org/releases.html#download。

下载后解压，将config目录下的zoo_sample.cfg重命名为zoo.cfg(Zookeeper配置文件，默认端口为2181，可根据实际进行修改)。然后双击bin目录下的zkServer.cmd启动即可。

构建父模块

新建一个Maven项目，groupId为cc.mrbird，artifactId为dubbo-boot，packaging指定为pom。然后引入Spring Boot，dubbo-spring-boot-starter和Zookeeper相关依赖：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
<?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>cc.mrbird</groupId>
    <artifactId>dubbo-boot</artifactId>
    <packaging>pom</packaging>
    <version>1.0</version>

    <name>dubbo-boot</name>
    <description>Spring Boot-Dubbo-ZooKeeper</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.4.RELEASE</version>
        <relativePath/>
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <project.version>1.0</project.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- dubbo -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <!-- zookeeper -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.8</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>${java.version}</source>
                    <target>${java.version}</target>
                    <encoding>${project.build.sourceEncoding}</encoding>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

构建Common-api

新建一个Maven模块，artifactId为common-api，目录结构如下所示：

技术图片

pom.xml：

1
2
3
4
5
6
7
8
9
10
11
12
13
<?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>dubbo-boot</artifactId>
        <groupId>cc.mrbird</groupId>
        <version>1.0</version>
    </parent>

    <modelVersion>4.0.0</modelVersion>
    <artifactId>common-api</artifactId>
</project>

项目只包含一个HelloService接口：

1
2
3
4
5
package cc.mrbird.common.api;

public interface HelloService {
    String hello(String message);
}

至此我们可以开始构建服务提供者和服务消费者了。

构建Server-Provider

新建一个Maven模块，用于暴露Dubbo服务，artifactId为server-provider，目录结构如下所示：

技术图片

pom内容如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<?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 大专栏  Springboot整合Dubbo和Zookeeper:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-boot</artifactId>
        <groupId>cc.mrbird</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>server-provider</artifactId>

    <dependencies>
        <dependency>
            <groupId>cc.mrbird</groupId>
            <artifactId>common-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>
</project>

这里我们引入了common-api模块，用于后续实现相应的服务。

在Spring Boot启动类中我们加入@EnableDubbo注解，表示要开启dubbo功能:

1
2
3
4
5
6
7
8
9
10
11
12
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@EnableDubbo
@SpringBootApplication
public class ProviderApplicaiton {
    public static void main(String[] args) {
        SpringApplication.run(ProviderApplicaiton.class, args);
        System.out.println("complete");
    }
}

接着在applicaiton.yml中配置Dubbo：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
server:
  port: 8080

dubbo:
  application:
    # 服务名称，保持唯一
    name: server-provider
    # zookeeper地址，用于向其注册服务
  registry:
    address: zookeeper://127.0.0.1:2181
  #暴露服务方式
  protocol:
    # dubbo协议，固定写法
    name: dubbo
    # 暴露服务端口 （默认是20880，不同的服务提供者端口不能重复）
    port: 20880

如果Zookeeper是集群的话，spring.dubbo.registry.address配置为：

1
2
3
4
spring:
  dubbo:
    registry:
      address: zookeeper://127.0.0.1:2181?backup=127.0.0.1:2180,127.0.0.1:2182

接下来我们在cc.mrbird.provider.service路径下创建一个HelloService接口的实现类：

1
2
3
4
5
6
7
8
9
10
11
12
import cc.mrbird.common.api.HelloService;
import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Service(interfaceClass = HelloService.class)
@Component
public class HelloServiceImpl implements HelloService {
    @Override
    public String hello(String message) {
        return "hello," + message;
    }
}

值得注意的是@Service注解为Dubbo提供的com.alibaba.dubbo.config.annotation.Service，而非Spring的那个。其中interfaceClass是指要发布服务的接口。

通过上面的配置，我们已经将HelloService接口的实现暴露到Zookeeper中了，接下来我们继续创建一个服务消费者，来消费这个服务。

搭建Server-Consumer

新建一个Maven模块，用于消费Dubbo服务，artifactId为server-consumer，目录结构如下所示：

技术图片

pom内容如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<?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>dubbo-boot</artifactId>
        <groupId>cc.mrbird</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>server-consumer</artifactId>

    <dependencies>
        <dependency>
            <groupId>cc.mrbird</groupId>
            <artifactId>common-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>
</project>

同样的，我们也在Spring Boot启动类中我们加入@EnableDubbo注解，表示要开启dubbo功能。

接着在applicaiton.yml中配置Dubbo：

1
2
3
4
5
6
7
8
9
10
11
12
13
server:
  port: 8081

dubbo:
  application:
    # 服务名称，保持唯一
    name: server-consumer
    # zookeeper地址，用于从中获取注册的服务
  registry:
    address: zookeeper://127.0.0.1:2181
  protocol:
    # dubbo协议，固定写法
    name: dubbo

同服务提供者，我们需要指定Zookeeper的地址，协议为dubbo。

接着我们定义一个TestController，演示服务消费：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import cc.mrbird.common.api.HelloService;
import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HelloController {

    @Reference
    private HelloService helloService;

    @GetMapping("/hello/{message}")
    public String hello(@PathVariable String message) {
        return this.helloService.hello(message);
    }
}

通过Dubbo的@Reference注解注入需要使用的interface，类似于Spring的@Autowired。

测试

分别启动Server-Provider和Server-Consumer，访问http://localhost:8081/hello/mrbird：

技术图片

说明远程服务调用已经成功。

这里只是通过Spring Boot和Dubbo的整合来简单了解Dubbo的使用，仅作抛砖引玉，更为详细的Dubbo配置可以查看官方文档：http://dubbo.apache.org/zh-cn/docs/user/quick-start.html

springboot整合dubbo+zookeeper

dockerpullzookeeperdockerrun--namezk01-p2181:2181--restartalways-d2e30cac00aca 表明zookeeper已成功启动 Zookeeper和Dubbo•ZooKeeperZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件，... 查看详情

springboot整合dubbo

SpringBoot整合Dubbo一、Dubbo　　Dubbo是一款高性能、轻量级的开源JavaRPC框架，　　它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。　　　　关键点介绍：　　1.注册与发现　　... 查看详情

springboot整合dubbo+zookeeper——实现发布并访问远程服务

前言什么是Dubbo？——开源分布式服务框架Dubbo(读音[ˈdʌbəʊ])是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的RPC实现服务的输出和输入功能，可以和Spring框架无缝集成。Dubbo是一款高性能、轻量级的... 查看详情

springboot初步整合dubbo+zookeeper项目

provider服务端application.properties配置server.port=8070spring.datasource.url=jdbc:mysql://127.0.0.1:3306/product?characterEncoding=UTF-8spring.datasource.username=rootspring.datasource.password=654321#驼峰标 查看详情

springboot整合dubbox与zookeeper

springboot中dubbo依赖的引入和配置（application.properties）参见：https://blog.csdn.net/wohaqiyi/article/details/72967805。需要注意的是在消费方工程里，controller包可以不必放到service包下（我认为也不应该），只要在application.properties里合理配置s... 查看详情

springboot和dubbo+zookeeper组合案例

SpringBoot融合了maven的特点，所以可以和maven完美整合接下来要做一个分布式项目，首先要有共享的接口先建一个maven项目 详情：UserAddress.javapackagecom.changping.bean;importjava.io.Serializable;publicclassUserAddressimplementsSerializable{ private 查看详情

《springboot+dubbo+zookeeper整合搭建简单的分布式应用》(代码片段)

为什么要使用分布式系统？容错减少延迟/提高性能可用性负载均衡总而言之，其实目的只有一个，”用户体验“。什么是分布式系统？分布式系统是由使用分发中间件连接的自治计算机组成的网络。它们有助于共享不同的资源... 查看详情

springboot整合dubbo（yml格式配置）

yml文件如果只作为服务的消费者不用暴露端口号，扫描的包名根据自己service改dubbo:application:name:springboot-dubbo-demo#应用名registry:address:zookeeper://127.0.0.1:2181#zookeeper地址#port:2181#提供注册的端口protocol:name:dubboport:"20889"#dubbo服 查看详情

duboo3.0+springboot+zookeeper整合例子（附源码）(代码片段)

dubbo整合SpringBoot例子dubbo新版本（3.0以上）在相对于dubbo旧版本（2.5、2.6、2.7），有很多的不相同的地方。官方文档也说了新版本的特性：https://dubbo.apache.org/zh/docs/v3.0/new-in-dubbo3本文就来使用dubbo新版本搭建... 查看详情

dubbo学习——springboot整合dubbo(代码片段)

...中获取到所有的提供者/消费者进行配置管理。Dubboadminisaspringbootapplicat 查看详情

dubbo学习——springboot整合dubbo(代码片段)

...中获取到所有的提供者/消费者进行配置管理。Dubboadminisaspringbootapplicat 查看详情

duboo3.0+springboot+zookeeper整合例子（附源码）(代码片段)

dubbo3.0整合SpringBoot例子dubbo新版本（3.0以上）在相对于dubbo旧版本（2.5、2.6、2.7），有很多的不相同的地方。官方文档也说了新版本的特性：https://dubbo.apache.org/zh/docs/v3.0/new-in-dubbo3本文就来使用dubbo3.0新版本... 查看详情

springboot2整合dubbox全注解

前题  dubbox是dubbo的一个升级版，简单说就是本来dubbo是阿里开发的，现在阿里不维护了，当当网拿过去继续开发。本来阿里的dubbo维护到2.6版本，而再高版本的都是当当网维护的就叫成dubbox了。  dubbo的机制是这样... 查看详情

2020最新ideaspringboot整合dubbo(zookeeper版)(代码片段)

2020最新IDEASpringBoot整合Dubbo(zookeeper版)首先，要在电脑上安装配置好zookeeper哦~这是我云服务器上的zookeeper状态接下来，开始整合1.准备一个dubbo-api的SpringBoot项目用来存储Entity类和Server接口的项目，配置文件无须改动。e... 查看详情

springboot与dubbo整合遇到的坑

整合环境：dubbo2.6.2springboot2.1.5遇到的问题：服务一直无法注册到zookeeper注册中心项目结构：使用application.properties文件：配置都没问题，启动的时候也没有明显的错误；然后就去百度看到大部分都是这种配置，之后在一篇博客中... 查看详情

springboot和dubbo整合

创建3个项目dubbo-api新建一个maven项目，这个项目只有接口(或实体类)dubbo-service和dubbo-web这两个依赖于dubbo-api<groupId>com.zhang</groupId><artifactId>dubbo-api</artifactId><version>1.0</version>& 查看详情

9.2springboot使用zookeeper和dubbo

一.项目搭建1.步骤建立一个空项目，添加两个springboot模块：provide-server和consumer-server 一个提供服务另一个消费服务（略）两个模块的pom.xml中都导入依赖编写provide-server代码编写consumer-server代码启动dubbo和zookeeper（略）启动prov... 查看详情

springboot整合dubbo+zookeeper实现分布式消费者与服务者的业务调用

📢📢📢📣📣📣哈喽！大家好，我是【Bug终结者】，【CSDN新星创作者】🏆，阿里云技术博主🏆，51CTO人气博主🏆，INfoQ写作专家🏆一位上进心十足 查看详情