Spring Boot整合Dubbo简单示例

Spirng Boot 整合 Dubbo 简单示例

预先准备条件

  1. JDK 1.8
  2. Maven
  3. IDEA
  4. Zookepper（我用的是装在云服务器上的，作为Dubbo中服务的注册中心）

项目预览

cenganhui/TOIMGcb19c0721054541N.png

新建 Maven 项目 springboot-dubbo。
父项目中可直接删除src文件夹。

新建子模块 dubbo-api，只需要是一个 Maven 项目即可。

  • 在该子模块中新建包 com.cgh.dubbo.api.service。

  • 新建一个接口 DemoService。

cenganhui/TOIMGc51210721054612N.png

在接口中声明一个 sayHello() 方法。

1
2
3
4
5
6
7
8
9
10
package com.cgh.dubbo.api.service;

/**
 * @author cenganhui
 */
public interface DemoService {

    public String sayHello(String name);

}

新建子模块 dubbo-provider，是一个Spring Boot项目，在其中为 dubbo-api 模块中声明的 service提供具体的实现，并通过 Dubbo 的 @Service 注解将实现的服务发布到 Dubbo 中。

创建项目时勾选上 Web。

添加依赖：引入 Dubbo 和 dubbo-api 模块（由于较高版本的 Dubbo 不导入后面两个依赖可能会报错，因此导入）。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.6.8</version>
</dependency>
<dependency>
    <groupId>org.example</groupId>
    <artifactId>dubbo-api</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.50.Final</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>5.1.0</version>
</dependency>

在 application.properties 中配置必要的几项配置。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
spring.application.name=provider
server.port=8081

# 指定当前应用/服务名字，相同的服务应同名
dubbo.application.name=provider

# 自定义属性
demo.service.version=1.0.0

dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

dubbo.registry.address=zookeeper://47.115.148.227:2181

# provider配置
dubbo.provider.timeout=2000

在启动类 ProviderApplication 中加上 @EnableDubbo 注解，开启 Spring Boot 对 Dubbo 的支持。

新建包 service.impl 来实现 dubbo-api 模块中接口声明的方法。

cenganhui/TOIMG1f0880721054657N.png

新建类 DemoServiceImpl，@Service 注解是 Dubbo 中的，不要引用错了，在该注解中指定了服务的版本号为我们在配置文件中自定义的属性。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
package com.cgh.dubbo.provider.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.cgh.dubbo.api.service.DemoService;

/**
 * @author cenganhui
 */
@Service(version = "${demo.service.version}")
public class DemoServiceImpl implements DemoService {

    @Override
    public String sayHello(String name) {
        return "Hello " + name + ", I'm provider!";
    }

}

新建子模块 dubbo-consumer，是一个 Spring Boot 项目，作为服务消费者，消费服务提供模块 dubbo-provider 提供的服务。

创建项目时勾选上 Web。

添加依赖：引入 Dubbo 和 dubbo-api 模块（由于较高版本的 Dubbo 不导入后面两个依赖可能会报错，因此导入）。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.6.8</version>
</dependency>
<dependency>
    <groupId>org.example</groupId>
    <artifactId>dubbo-api</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.50.Final</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>5.1.0</version>
</dependency>

在 application.properties 中配置必要的几项配置。

1
2
3
4
5
6
7
8
9
10
spring.application.name=consumer
server.port=8082

# 指定当前应用/服务名字，相同的服务应同名
dubbo.application.name=consumer

# 自定义属性
demo.service.version=1.0.0

dubbo.registry.address=zookeeper://47.115.148.227:2181

在启动类 ProviderApplication 中加上 @EnableDubbo 注解，开启 Spring Boot 对 Dubbo 的支持。

新建包 controller 作为访问入口。

cenganhui/TOIMGcefea0721054705N.png

新建类 DemoController，通过 @Reference 注解从 Dubbo 中引入需要的服务，在该注解中指定了服务的版本号为我们在配置文件中自定义的属性。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
package com.cgh.dubbo.consumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.cgh.dubbo.api.service.DemoService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author cenganhui
 */
@RestController
public class DemoController {

    @Reference(version = "${demo.service.version}")
    private DemoService demoService;

    @GetMapping("say/{name}")
    public String sayHello(@PathVariable("name") String name) {
        return demoService.sayHello(name);
    }

}

启动 Zookeeper 服务。

我的服务器是 CentOS 7。

1
2
3
4
5
6
# 进入到目录
cd /home/zk/zookeeper
# 启动服务
bin/zkServer.sh start
# 查看服务状态
bin/zkServer.sh status

cenganhui/TOIMG597070721054746N.png

依次启动 dubbo-provider 和 dubbo-consumer。

启动 dubbo-provider。

cenganhui/TOIMGdd4b60721054832N.png

启动 dubbo-consumer。

cenganhui/TOIMG7a8ef0721054832N.png

都启动成功后，在浏览器中输入 http://127.0.0.1:8082/say/cgh 查看效果。

cenganhui/TOIMG304ec0721054832N.png

项目地址：https://github.com/cenganhui/CGH_SpringBoot_Dubbo_Demo

扫一扫，分享到微信

微信分享二维码
本站总访问量次 | 本站访客数人次

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

我是一个小码农