一個(gè)簡(jiǎn)單的入門 Demo,這里我采用 SpringBoot 的全注解方式,感覺(jué) XML 的方式更麻煩一點(diǎn)
代碼地址
- Github: https://github.com/dolyw/ProjectStudy/tree/master/Dubbo/01-Dubbo-SpringBoot
- Gitee(碼云): https://gitee.com/dolyw/ProjectStudy/tree/master/Dubbo/01-Dubbo-SpringBoot
1. 前言
一般現(xiàn)在用于生產(chǎn)環(huán)境的 Dubbo 注冊(cè)中心都是 ZooKeeper,那我們首先啟動(dòng) ZooKeeper颜骤,安裝可以查看: ZooKeeper安裝使用
2. 創(chuàng)建
我們先創(chuàng)建一個(gè)父工程
2.1. 父工程
打開(kāi) IDEA惋砂,F(xiàn)ile-New-Project...,選擇 Maven 點(diǎn)擊下一步 Next
groupId 我們填寫我們的包名 com.demo腰埂,artifactId 填寫我們的項(xiàng)目名 01-Dubbo-SpringBoot,version 先默認(rèn)蜈膨,點(diǎn)擊下一步 Next
位置存在在 E:\XUE\ProjectStudy\Dubbo\01-Dubbo-SpringBoot屿笼,點(diǎn)擊完成 Finish
創(chuàng)建完成,打開(kāi)翁巍,可以把除 pom.xml 的其他文件都刪除了驴一,再新建一個(gè) .gitignore 的 Git 忽略文件,IDEA 生成的文件刪除了還是會(huì)生成灶壶,所以就不用刪了
修改 pom.xml 的版本屬性蛔趴,寫一個(gè)統(tǒng)一的版本號(hào),子工程統(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工程
這個(gè)主要是存放接口的例朱,抽取出來(lái)孝情,方便服務(wù)提供者和消費(fèi)者直接使用,不需要兩邊建立重復(fù)的接口文件
我們?cè)诟腹こ滔曼c(diǎn)擊 File-New-Module洒嗤,還是選擇 Maven箫荡,點(diǎn)擊下一步 Next,填寫模塊名 artifactId 為 common-api渔隶,點(diǎn)擊下一步 Next羔挡,修改名稱為 common-api,點(diǎn)擊完成 Finish 即可
修改 common-api 工程 pom.xml 版本號(hào) 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)建一個(gè)服務(wù)接口 IDemoService
package com.demo;
/**
* IDemoService
*
* @author wliduo[i@dolyw.com]
* @date 2019/12/18 16:37
*/
public interface IDemoService {
/**
* 說(shuō)你好
*
* @param
* @return java.lang.String
* @throws
* @author wliduo[i@dolyw.com]
* @date 2019/12/20 10:11
*/
String sayHello(String name);
}
2.3. Provider工程
這個(gè)是提供服務(wù)的工程绞灼,我們?cè)诟腹こ滔曼c(diǎn)擊 File-New-Module,這里選擇 Spring Initializr(SpringBoot)呈野,默認(rèn)點(diǎn)擊下一步 Next低矮,填寫模塊名 artifactId 為 provider-service
點(diǎn)擊下一步 Next,修改名稱為 provider-service被冒,點(diǎn)擊完成 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
實(shí)現(xiàn)一個(gè)服務(wù)接口 DemoServiceImpl,如果無(wú)法引入 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工程
這個(gè)是消費(fèi)服務(wù)的工程蝗锥,我們?cè)诟腹こ滔曼c(diǎn)擊 File-New-Module,這里選擇 Spring Initializr(SpringBoot)率触,默認(rèn)點(diǎn)擊下一步 Next终议,填寫模塊名 artifactId 為 consumer-service
點(diǎn)擊下一步 Next,修改名稱為 consumer-service,點(diǎn)擊完成 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
我們寫一個(gè) DemoController 來(lái)調(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. 啟動(dòng)
先啟動(dòng) Zookeeper细燎,然后啟動(dòng) provider-service 提供服務(wù),再啟動(dòng) consumer-service 調(diào)用服務(wù)陆馁,兩個(gè)都是 SpringBoot 工程,可以直接啟動(dòng)合愈,啟動(dòng)成功后可以直接調(diào)用 consumer-service 的兩個(gè) Controller 方法
后臺(tái)打印
這樣就調(diào)用成功了叮贩,Dubbo 簡(jiǎn)單的生產(chǎn)服務(wù)和消費(fèi)服務(wù)就是這樣
參考