SpringBoot + Dubbo的全注解方式入門使用

一個簡單的入門 Demo,這里我采用 SpringBoot 的全注解方式,感覺 XML 的方式更麻煩一點

代碼地址

1. 前言

一般現(xiàn)在用于生產(chǎn)環(huán)境的 Dubbo 注冊中心都是 ZooKeeper,那我們首先啟動 ZooKeeper,安裝可以查看: ZooKeeper安裝使用

2. 創(chuàng)建

我們先創(chuàng)建一個父工程

2.1. 父工程

打開 IDEA,F(xiàn)ile-New-Project...,選擇 Maven 點擊下一步 Next

groupId 我們填寫我們的包名 com.demo,artifactId 填寫我們的項目名 01-Dubbo-SpringBoot,version 先默認(rèn),點擊下一步 Next

位置存在在 E:\XUE\ProjectStudy\Dubbo\01-Dubbo-SpringBoot,點擊完成 Finish

創(chuàng)建完成,打開,可以把除 pom.xml 的其他文件都刪除了,再新建一個 .gitignore 的 Git 忽略文件,IDEA 生成的文件刪除了還是會生成,所以就不用刪了

圖片

修改 pom.xml 的版本屬性,寫一個統(tǒng)一的版本號,子工程統(tǒng)一使用

<version>${revision}</version>

<properties>
    <revision>1.0.0</revision>
    <java.version>1.8</java.version>
    <dubbo.version>2.7.4.1</dubbo.version>
</properties>

2.2. API工程

這個主要是存放接口的,抽取出來,方便服務(wù)提供者和消費者直接使用,不需要兩邊建立重復(fù)的接口文件

我們在父工程下點擊 File-New-Module,還是選擇 Maven,點擊下一步 Next,填寫模塊名 artifactId 為 common-api,點擊下一步 Next,修改名稱為 common-api,點擊完成 Finish 即可

修改 common-api 工程 pom.xml 版本號 version 為 ${revision},pom.xml如下

<?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>

    <parent>
        <artifactId>01-Dubbo-SpringBoot</artifactId>
        <groupId>com.demo</groupId>
        <version>${revision}</version>
        <relativePath>../pom.xml</relativePath>
    </parent>

    <groupId>com.demo</groupId>
    <artifactId>common-api</artifactId>
    <packaging>jar</packaging>
    <version>${revision}</version>

    <name>common-api</name>
    <description>Dubbo Demo project</description>

</project>

并且創(chuàng)建一個服務(wù)接口 IDemoService

package com.demo;

/**
 * IDemoService
 *
 * @author wliduo[i@dolyw.com]
 * @date 2019/12/18 16:37
 */
public interface IDemoService {

    /**
     * 說你好
     *
     * @param
     * @return java.lang.String
     * @throws
     * @author wliduo[i@dolyw.com]
     * @date 2019/12/20 10:11
     */
    String sayHello(String name);

}

2.3. Provider工程

這個是提供服務(wù)的工程,我們在父工程下點擊 File-New-Module,這里選擇 Spring Initializr(SpringBoot),默認(rèn)點擊下一步 Next,填寫模塊名 artifactId 為 provider-service

圖片

點擊下一步 Next,修改名稱為 provider-service,點擊完成 Finish 即可,然后修改當(dāng)前模塊的 pom 文件如下

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <parent>
        <artifactId>01-Dubbo-SpringBoot</artifactId>
        <groupId>com.demo</groupId>
        <version>${revision}</version>
        <relativePath>../pom.xml</relativePath>
    </parent>

    <groupId>com.demo</groupId>
    <artifactId>provider-service</artifactId>
    <packaging>jar</packaging>
    <version>${revision}</version>

    <name>provider-service</name>
    <description>Dubbo Demo project for Spring Boot</description>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>

        <!-- Zookeeper dependencies -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>${dubbo.version}</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <!-- common-api -->
        <dependency>
            <groupId>com.demo</groupId>
            <artifactId>common-api</artifactId>
            <version>${revision}</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

Zookeeper 配置信息 application.yml

server:
  port: 8881

spring:
  application:
    name: provider-service

demo:
  service:
    version: 1.0

embedded:
  zookeeper:
    port: 2181

dubbo:
  application:
    name: ${spring.application.name}
  scan:
    # 掃描Service注解
    base-packages: com.demo.service
  protocol:
    name: dubbo
    port: -1
  registry:
    address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache

實現(xiàn)一個服務(wù)接口 DemoServiceImpl,如果無法引入 IDemoService,就把 common-api 工程打包下

package com.demo.service;

import com.demo.IDemoService;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Value;

/**
 * DemoServiceImpl
 *
 * @author wliduo[i@dolyw.com]
 * @date 2019/12/20 10:10
 */
@Service(version = "${demo.service.version}")
public class DemoServiceImpl implements IDemoService {

    /**
     * The default value of ${dubbo.application.name} is ${spring.application.name}
     */
    @Value("${spring.application.name}")
    private String serviceName;

    @Override
    public String sayHello(String name) {
        System.out.println(name + "連接成功");
        return serviceName + ": " + name;
    }

}

2.4. Consumer工程

這個是消費服務(wù)的工程,我們在父工程下點擊 File-New-Module,這里選擇 Spring Initializr(SpringBoot),默認(rèn)點擊下一步 Next,填寫模塊名 artifactId 為 consumer-service

圖片

點擊下一步 Next,修改名稱為 consumer-service,點擊完成 Finish 即可,然后修改當(dāng)前模塊的 pom 文件如下

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <parent>
        <artifactId>01-Dubbo-SpringBoot</artifactId>
        <groupId>com.demo</groupId>
        <version>${revision}</version>
        <relativePath>../pom.xml</relativePath>
    </parent>

    <groupId>com.demo</groupId>
    <artifactId>consumer-service</artifactId>
    <packaging>jar</packaging>
    <version>${revision}</version>

    <name>consumer-service</name>
    <description>Dubbo Demo project for Spring Boot</description>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>

        <!-- Zookeeper dependencies -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>${dubbo.version}</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <!-- common-api -->
        <dependency>
            <groupId>com.demo</groupId>
            <artifactId>common-api</artifactId>
            <version>${revision}</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

Zookeeper 配置信息 application.yml

server:
  port: 8882

spring:
  application:
    name: consumer-service

demo:
  service:
    version: 1.0

embedded:
  zookeeper:
    port: 2181

dubbo:
  application:
    name: ${spring.application.name}
  registry:
    address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache

我們寫一個 DemoController 來調(diào)用服務(wù)

package com.demo.controller;

import com.demo.IDemoService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * DemoController
 *
 * @author wliduo[i@dolyw.com]
 * @date 2019/12/20 11:08
 */
@RestController
@RequestMapping
public class DemoController {

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

    @GetMapping("/")
    public String sayHello() {
        String text = demoService.sayHello("Hello");
        System.out.println(text);
        return text;
    }

    @GetMapping("/demo")
    public String sayXXX(@RequestParam("name") String name) {
        String text = demoService.sayHello(name);
        System.out.println(text);
        return text;
    }

}

2.5. 聚合

把父工程的 pom 文件改下

<?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>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>com.demo</groupId>
    <artifactId>01-Dubbo-SpringBoot</artifactId>
    <packaging>pom</packaging>
    <version>${revision}</version>

    <name>01-Dubbo-SpringBoot</name>
    <description>Dubbo Demo project</description>

    <properties>
        <revision>1.0.0</revision>
        <java.version>1.8</java.version>
        <dubbo.version>2.7.4.1</dubbo.version>
    </properties>

    <modules>
        <module>common-api</module>
        <module>provider-service</module>
    </modules>

</project>

3. 啟動

先啟動 Zookeeper,然后啟動 provider-service 提供服務(wù),再啟動 consumer-service 調(diào)用服務(wù),兩個都是 SpringBoot 工程,可以直接啟動,啟動成功后可以直接調(diào)用 consumer-service 的兩個 Controller 方法

圖片
圖片

后臺打印

圖片
圖片

這樣就調(diào)用成功了,Dubbo 簡單的生產(chǎn)服務(wù)和消費服務(wù)就是這樣

參考

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容