SpringBoot 整合 Dubbo，调用或者提供 Dubbo 接口

出于公司业务需求，需要在已经上线的SpringBoot服务上增加Dubbo接口，并与其它Dubbo服务对接。通过以下步骤实现了SpringBoot中的Dubbo接口。

Module

无论是服务提供者还是消费者，都应当独立引入接口 jar 包. 所以应当在服务提供者中建立新的 Module. 操作路径为：File -> Project Structure -> Modules -> +. 该 Jar 包仅包含 interface 文件和 DTO 模型. 假定 Module 名为 dubbo-api. 假定服务接口为 com.test.dubboapi.service.DubboTestService

build.gradle 依赖

SpringBoot 的版本号为 1.5.17 所以 dubbo-spring-boot-start 采用 0.1.0 版本

compile project(":dubbo-api") # 对应 Module 名
compile 'com.alibaba.boot:dubbo-spring-boot-starter:0.1.0'
compile 'com.alibaba:dubbo:2.6.0'

settings.gradle 配置

增加子模块 dubbo-api

include 'dubbo-api' # 增加这一行

Application.yml 配置

SpringBoot 采用 gradle 构建，暂时没有接入注册中心，服务提供者关键配置如下

dubbo:
    application:
        name: springboot-dubbo-provider # dubbo 服务名
        id: springboot-dubbo-provider # dubbo 服务id
    protocol:
        name: dubbo # 不可变动的配置
        port: 20880 # dubbo接口暴露的商品，默认为20880
    scan:
        base-packages: com.test.service.impl # 应用了dubbo注解的包路径
    registry:
        address: N/A # 注册中心地址，不使用注册中心时要配置 N/A

消费者关键配置如下

dubbo:
    application:
        name: springboot-dubbo-consumer # dubbo 服务名
        id: springboot-dubbo-consumer # dubbo 服务id
    scan:
        base-packages: com.test.controller # 应用了dubbo注解的包路径
    registry:
        address: N/A # 注册中心地址，不使用注册中心时要配置 N/A
    reference:
        com.test.dubboapi.service.url: dubbo://xxx.xxx.xxx.xxx:20880 # url前对应需要注册的服务(即服务提供者的服务接口类的类路径)，url后对应服务提供者部署的IP地址(或域名)和配置的 dubbo.protocol.port

服务提供者的服务实现

package com.test.service.impl

import com.test.dubboapi.service.DubboTestService;
import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Service(interfaceClass = DubboTestService.class)
@Component
public class DubboTestServiceImpl implements DubboTestService {

    @Override
    public String dubbotTest(String input) {
        // ... ...
        return ... ...
    }
}

服务消费者的服务实现

package com.test.controller

import cc.ewell.dubboapi.service.DubboTestService;
import com.alibaba.dubbo.config.annotation.Reference;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiParam;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
@Api("DUBBO TEST")
public class DubboController {

    @Reference(check = false, timeout = 30000)
    private DubboTestService dubboTestService;

    @GetMapping("/dubboTest")
    public String dubboTest(@RequestParam("input") @ApiParam("入参") String input) {
        return dubboTestService.dubbotTest(input);
    }
}

启动类

启动类上增加@EnableDubboConfig注解.