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

一个简单的入门 Demo,这里我采用 SpringBoot 的全注解方式,感觉 XML 的方式更麻烦一点

代码地址

1. 前言

一般现在用于生产环境的 Dubbo 注册中心都是 ZooKeeper,那我们首先启动 ZooKeeper,安装可以查看: ZooKeeper安装使用

2. 创建

我们先创建一个父工程

2.1. 父工程

打开 IDEA,File-New-Project...,选择 Maven 点击下一步 Next

groupId 我们填写我们的包名 com.demo,artifactId 填写我们的项目名 01-Dubbo-SpringBoot,version 先默认,点击下一步 Next

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

创建完成,打开,可以把除 pom.xml 的其他文件都删除了,再新建一个 .gitignore 的 Git 忽略文件,IDEA 生成的文件删除了还是会生成,所以就不用删了

图片

修改 pom.xml 的版本属性,写一个统一的版本号,子工程统一使用

<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工程

这个主要是存放接口的,抽取出来,方便服务提供者和消费者直接使用,不需要两边建立重复的接口文件

我们在父工程下点击 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>

并且创建一个服务接口 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工程

这个是提供服务的工程,我们在父工程下点击 File-New-Module,这里选择 Spring Initializr(SpringBoot),默认点击下一步 Next,填写模块名 artifactId 为 provider-service

图片

点击下一步 Next,修改名称为 provider-service,点击完成 Finish 即可,然后修改当前模块的 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

实现一个服务接口 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工程

这个是消费服务的工程,我们在父工程下点击 File-New-Module,这里选择 Spring Initializr(SpringBoot),默认点击下一步 Next,填写模块名 artifactId 为 consumer-service

图片

点击下一步 Next,修改名称为 consumer-service,点击完成 Finish 即可,然后修改当前模块的 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 来调用服务

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 提供服务,再启动 consumer-service 调用服务,两个都是 SpringBoot 工程,可以直接启动,启动成功后可以直接调用 consumer-service 的两个 Controller 方法

图片
图片

后台打印

图片
图片

这样就调用成功了,Dubbo 简单的生产服务和消费服务就是这样

参考

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,456评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,370评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,337评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,583评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,596评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,572评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,936评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,595评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,850评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,601评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,685评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,371评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,951评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,934评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,167评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,636评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,411评论 2 342