dubbo 实战之二:与 SpringBoot 集成
创建子工程 springbootmulticastconsumer,启动后提供一个 web 接口,咱们调用这个 web 接口时,springbootmulticastconsumer 会远程调用 springbootmulticastprovider 提供的服务,如下图:
本篇的实战暂不使用注册中心,而是服务提供方启动时广播自己的地址,再由消费方启动时订阅,并随时远程调用,调用逻辑如下图所示:
[](()源码下载
如果您不想编码,可以在 GitHub 下载所有源码,地址和链接信息如下表所示:
| 名称 | 链接 | 备注 |
| :-- | :-- | :-- |
| 项目主页 | https://github.com/zq2599/blog_demos | 该项目在 GitHub 上的主页 |
| git 仓库地址(https) | https://github.com/zq2599/blog_demos.git | 该项目源码的仓库地址,https 协议 |
| git 仓库地址(ssh) | git@github.com:zq2599/blog_demos.git | 该项目源码的仓库地址,ssh 协议 |
这个 git 项目中有多个文件夹,本章的应用在 dubbopractice 文件夹下,如下图红框所示:
dubbopractice 是父子结构的工程,本篇的代码在 springbootmulticastprovider 和 springbootmulticastconsumer 这两个子工程中,如下图:
[](()编码(服务提供方)
先创建提供服务的工程 springbootmulticastprovider,一共要创建 4 个文件,创建顺序和功能如下表:
| 创建顺序 | 文件名 | 作用 |
| --- | --- | --- |
| 1 | pom.xml | 工程的 pom 文件 |
| 2 | src/main/resources/application.yml | 配置文件 |
| 3 | DemoServiceImpl.java | 提供具体的服务 |
| 4 | SpringBootMulticastProviderApplication.java | 启动类 |
完整的文件位置如下图:
接下来逐个创建上述内容;
创建名为 springbootmulticastprovider 的子工程,pom.xml 内容如下,要重点关注的是新增依赖 dubbo-spring-boot-starter,这就是 dubbo 在 SpringBoot 环境的 starter 依赖:
<?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">
<parent>
<artifactId>dubbopractice</artifactId>
<groupId>com.bolingcavalry</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<groupId>com.bolingcavalry</groupId>
<artifactId>springbootmulticastprovider</artifactId>
<version>1.0-SNAPSHOT</version>
<name>springbootmulticastprovider</name>
<description>Demo project for dubbo service provider from Spring Boot, multicast mode</description>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${springboot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<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>
</dependency>
<dependency>
<groupId>com.bolingcavalry</groupId>
<artifactId>practiceinterface</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</de 《一线大厂 Java 面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》无偿开源 威信搜索公众号【编程进阶路】 pendency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${springboot.version}</version>
</plugin>
</plugins>
</build>
</project>
配置文件 application.yml,要注意的是 registry.address 的配置是广播模式:
dubbo:
application:
#application-name 本模块名字
name: springboot-multicast-provider
id: springboot-multicast-provider
registry:
address: multicast://224.5.6.7:1234
id: registry
protocol:
name: dubbo
port: 20880
编写服务实现类 DemoServiceImpl.java,注意 @Service 注解将当前类的实例作为远程服务对外暴露:
package com.bolingcavalry.springbootmulticastprovider;
import com.bolingcavalry.dubbopractice.service.DemoService;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.Service;
import org.apache.dubbo.rpc.RpcContext;
@Slf4j
@Service
public class DemoServiceImpl implements DemoService {
@Override
public String sayHello(String name) {
log.info("I'm springboot-multicast-provider, Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "I'm springboot-multicast-provider, Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();
}
}
编写 SpringBoot 启动类 SpringBootMulticastProviderApplication.java,注意要添加 @EnableDubbo 注解:
package com.bolingcavalry.springbootmulticastprovider;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableDubbo
public class SpringBootMulticastProviderApplication {
public static void main(String[] args) {
SpringApplication.run(SpringBootMulticastProviderApplication.class, args);
}
}
至此服务提供方编码完成,直接在 IDEA 上运行 SpringBootMulticastProviderApplication 类即可启动服务,启动成功后的日志输出如下图:
[](()编码(服务消费方)
现在网络上已经有了服务,咱们再来编写服用消费方的代码,一共要创建 6 个文件,创建顺序和功能如下表:
| 创建顺序 | 文件名 | 作用 |
| --- | --- | --- |
| 1 | pom.xml | 工程的 pom 文件 |
| 2 | src/main/resources/application.yml | 配置文件 |
| 3 | RemoteInvokeServiceImpl.java | service 层,在这里远程调用服务提供方的服务 |
| 4 | DemoController.java | web 接口类,对外提供 web 服务 |
| 5 | SwaggerConfig.java | swagger 配置类,便于通过页面测试接口 |
| 6 | SpringBootMulticastConsumerApplication.java | 启动类 |
完整的文件位置如下图:
接下来逐个创建上述文件;
创建名为 springbootmulticastconsumer 的子工程,pom.xml 内容如下,同样需要依赖 dubbo-spring-boot-starter:
<?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">
<parent>
<artifactId>dubbopractice</artifactId>
<groupId>com.bolingcavalry</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<groupId>com.bolingcavalry</groupId>
<artifactId>springbootmulticastconsumer</artifactId>
<version>1.0-SNAPSHOT</version>
<name>springbootmulticastconsumer</name>
<description>Demo project for dubbo service consumer from Spring Boot, multicast mode</description>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${springboot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<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>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
</dependency>
<dependency>
<groupId>com.bolingcavalry</groupId>
<artifactId>practiceinterface</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${springboot.version}</version>
评论