天天看點

springboot快速內建dubbo

當springboot和dubbo走到了一起,那麼如何讓它兩更快更容易的內建在一起呢?dubbo-spring-boot-starter幫助我們做到了這點,它實作了dubbo在springboot項目中自動配置(@EnableAutoConfiguration)。

dubbo-spring-boot-starter子產品

dubbo-spring-boot-starter主要由以下部分内容組成:

  • dubbo-spring-boot-parent 子產品主要管理 Dubbo Spring Boot 工程的 Maven 依賴;
  • dubbo-spring-boot-autoconfigure 子產品提供 Spring Boot’s @EnableAutoConfiguration 的實作 - DubboAutoConfiguration, 它簡化了 Dubbo 核心元件的裝配;
  • dubbo-spring-boot-actuator 提供 Production-Ready 特性:健康檢查、控制斷點、外部化配置等;

dubbo-starter方式內建dubbo案例

現在通過一個案例來看springboot使用dubbo-spring-boot-starter來內建dubbo是多麼簡單的事兒。

這裡通過dubbo直連的方式,不引入注冊中心。

首先在項目POM檔案中中引入如下資訊(制定dubbo的版本号以及dubbo的依賴管理):

<properties>
        <dubbo.version>2.7.0</dubbo.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>
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-dependencies-bom</artifactId>
                <version>${dubbo.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>javax.servlet</groupId>
                        <artifactId>servlet-api</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>log4j</groupId>
                        <artifactId>log4j</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    </dependencyManagement>
           

然後定義一個公共的server-api:

public interface HelloService {

    String hello(String name);
}
           

springboot-dubbo-provider

在服務提供者中引入如下依賴:

<dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
           

在application.yml檔案中設定dubbo的簡單配置:

spring:
  application:
    name: springboot-dubbo-provider

dubbo:
#  application:
#    name: #defualt is ${spring.application.name}
  protocol:
    name: dubbo
    port: 28080
  registry:
    address: N/A
  scan:
    base-packages: com.lazycece.sbac.dubbo.provider.service
  provider:
    group: demo
           

HelloSerice服務提供資訊如下:

package com.lazycece.sbac.dubbo.provider.service;

import com.lazycece.sbac.dubbo.api.HelloService;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @author lazycece
 * @date 2019/03/30
 */
@Component
@Service(version = "1.0.0", timeout = 3000)
public class HelloServiceImpl implements HelloService {

    @Value("${dubbo.application.name}")
    private String serviceName;

    @Override
    public String hello(String name) {
        return String.format("Hello, %s ! the service is %s", name, serviceName);
    }
}
           

springboot-dubbo-consumer

在服務消費者中引入如下依賴:

<dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
           

在application.yml檔案中設定dubbo的簡單配置:

spring:
  application:
    name: springboot-dubbo-consumer
dubbo:
  consumer:
    group: demo
           

HelloSerice服務消費案例代碼如下:

package com.lazycece.sbac.dubbo.consumer.controller;

import com.lazycece.sbac.dubbo.api.HelloService;
import org.apache.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;

/**
 * @author lazycece
 * @date 2019/03/30
 */
@RestController
public class HelloController {

    @Reference(version = "1.0.0", url = "dubbo://127.0.0.1:28080")
    private HelloService helloService;

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

結果驗證

在浏覽器通路如下位址:http://localhost:8080/hello/lazycece

輸出資訊為: Hello, lazycece ! the service is springboot-dubbo-provider

案例代碼

案例代碼位址:https://github.com/lazycece/springboot-actual-combat/tree/master/springboot-ac-dubbo

繼續閱讀