1.前言
这是一个基于 SpringBoot 整合 Apache Dubbo+Nacos 的极简教程,笔者使用到的技术及版本如下:
SpringBoot 2.4.5
Dubbo 2.7.11
Nacos 2.0.1(自行安装)
Dubbo 官网:https://dubbo.apache.org/zh/
Nacos 官网:https://nacos.io/zh-cn/docs/quick-start.html
2.目录结构
dubbo-client:生产者消费者共有接口
dubbo-consumer:消费者
dubbo-provider:生产者
3.配置文件
pom 核心依赖
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.11</version>
</dependency>
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>nacos-discovery-spring-boot-starter</artifactId>
<version>0.2.7</version>
<exclusions>
<exclusion>
<groupId>com.alibaba.spring</groupId>
<artifactId>spring-context-support</artifactId>
</exclusion>
</exclusions>
</dependency>
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>
<packaging>pom</packaging>
<modules>
<module>dubbo-provider</module>
<module>dubbo-client</module>
<module>dubbo-consumer</module>
</modules>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.4.5</version>
<relativePath/>
</parent>
<groupId>xyz.hcworld</groupId>
<artifactId>rpcscaffold</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>rpcscaffold</name>
<description>SpringBoot整合Apache Dubbo+Nacos的极简教程</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.11</version>
</dependency>
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>nacos-discovery-spring-boot-starter</artifactId>
<version>0.2.7</version>
<exclusions>
<exclusion>
<groupId>com.alibaba.spring</groupId>
<artifactId>spring-context-support</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
注释:需要去除 spring-context-support 依赖,否则运行不起来,但是去除后消费者会报错却不影响使用。
4.接口模块
定义一个消费者和生产者共同拥有的接口子模块。
package xyz.hcworld.service;
/**
* 注入接口
* @ClassName: DemoService
* @Author: 张红尘
* @Date: 2021-05-24
* @Version:1.0
*/
public interface DemoService {
/**
* 测试方法获取service参数
* @param name
* @return
*/
String sayName(String name);
}
5.生产者模块
pom 核心依赖
依赖加入接口模块。
<dependencies>
<dependency>
<groupId>xyz.hcworld</groupId>
<artifactId>dubbo-client</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
</dependencies>
yml 配置文件
# 设置nacos的地址(配置中心)
nacos:
discovery:
server-addr: 192.168.2.142:8848
# 设置dubbo的参数
dubbo:
application:
# 当前消费者的配置名
name: dubbo-provider-demo
registry:
address: nacos://192.168.2.142:8848
# 协议(缺省值)
protocol:
name: dubbo
port: -1
# 当前接口的名字与版本
demo:
service:
version: 1.0.0
name: demoService
类
新版 Dubbo 将 @Service 标注为过时,所以最新的注解应当使用 @DubboService ,如果使用 @Service 容易与 Spring 的 @Service 搞混。
package xyz.hcworld.service.impl;
import org.apache.dubbo.config.annotation.DubboService;
import org.apache.dubbo.rpc.RpcContext;
import org.springframework.beans.factory.annotation.Value;
import xyz.hcworld.service.DemoService;
/**
* @ClassName: DemoServiceImpl
* @Author: 张红尘
* @Date: 2021-05-24
* @Version:1.0
*/
@DubboService(interfaceClass = DemoService.class,interfaceName = "${demo.service.name}",version = "${demo.service.version}")
public class DemoServiceImpl implements DemoService {
@Value("${demo.service.name}")
private String serviceName;
@Override
public String sayName(String name) {
RpcContext rpcContext = RpcContext.getContext();
return String.format("Service [name :%s , port : %d] %s(\"%s\") : Hello,%s",
serviceName,
rpcContext.getLocalPort(),
rpcContext.getMethodName(),
name,
name);
}
}
6.消费者模块
pom 文件与同生产者模块一致,yml 文件修改 name 其余也与生产者模块一致。
dubbo:
application:
# 当前消费者的配置名
name: dubbo-consumer-demo
类
生产者消费者的接口名与接口版本必须一致。使用 @DubboReference 注入远程接口。
package xyz.hcworld.controller;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import xyz.hcworld.service.DemoService;
/**
* @ClassName: DubboController
* @Author: 张红尘
* @Date: 2021-05-24
* @Version:1.0
*/
@RestController
public class DubboController {
@DubboReference(interfaceClass = DemoService.class,interfaceName = "${demo.service.name}",version = "${demo.service.version}")
private DemoService demoService;
@RequestMapping("/hello")
public String sayHello(){
return demoService.sayName("张");
}
}
7.结果
生产者启动结果
消费者启动结果
注释:报错是因为去除了 com.alibaba.spring 下的 spring-context-support,但并不影响使用,不去除将无法启动,如果有其他异常可以与作者进行讨论研究。
浏览器请求结果
Nacos 可视化
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于