Spring Boot 环境下构建 Dubbo 分布式服务架构实战
远程过程调用机制
在微服务架构中，各个服务节点之间的通信通常依赖 RPC（Remote Procedure Call）机制。借助 RPC 框架，开发者能够以调用本地方法的编程模型来触发远程服务器上的逻辑，从而有效屏蔽底层的网络传输、序列化及协议解析等复杂细节。
构建服务提供者 (Provider)
提供者是业务逻辑的实际承载方，负责将接口实现暴露到网络中，并向注册中心完成服务注册。
1. 依赖管理
在提供者的 pom.xml 中，需引入 Spring Boot 基础 Web 依赖、Apache Dubbo 的 Spring Boot Starter，以及用于服务发现的 Zookeeper 客户端。
<?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>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.12</version>
</parent>
<groupId>com.demo.rpc</groupId>
<artifactId>order-provider</artifactId>
<version>1.0.0</version>
<properties>
<java.version>11</java.version>
<dubbo.version>3.2.0</dubbo.version>
</properties>
<dependencies>
<!-- 公共接口模块 -->
<dependency>
<groupId>com.demo.rpc</groupId>
<artifactId>order-api</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Apache Dubbo 集成组件 -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>${dubbo.version}</version>
</dependency>
<!-- Zookeeper 注册中心客户端 -->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-x-discovery</artifactId>
<version>5.1.0</version>
</dependency>
</dependencies>
</project>2. 应用配置
在 application.yml 中定义 Tomcat 端口、Dubbo 应用程序名、Zookeeper 注册中心地址以及 Dubbo 协议通信端口。
server:
port: 8081
dubbo:
application:
name: order-provider-service
registry:
address: zookeeper://192.168.1.100:2181
protocol:
name: dubbo
port: 208813. 暴露服务接口
使用 Apache Dubbo 提供的 @DubboService 注解标记实现类，将其注册为远程服务。此处以实现一个订单查询服务为例。
package com.demo.rpc.provider.service;
import org.apache.dubbo.config.annotation.DubboService;
import com.demo.rpc.api.OrderApi;
@DubboService
public class OrderServiceImpl implements OrderApi {
@Override
public String fetchOrderDetails() {
return "订单编号: ORD-9982, 状态: 已支付";
}
}4. 启动提供者
在 Spring Boot 启动类上添加 @EnableDubbo 注解，以激活 Dubbo 的自动化配置与包扫描功能。
package com.demo.rpc.provider;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableDubbo
public class OrderProviderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderProviderApplication.class, args);
}
}构建服务消费者 (Consumer)
消费者负责从注册中心订阅服务列表，并在本地生成代理对象，从而对远程节点发起透明的方法调用。
1. 依赖管理
消费者的依赖与提供者类似，同样需要集成 Web 模块与 Dubbo 注册中心组件。
<?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>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.12</version>
</parent>
<groupId>com.demo.rpc</groupId>
<artifactId>order-consumer</artifactId>
<version>1.0.0</version>
<properties>
<java.version>11</java.version>
<dubbo.version>3.2.0</dubbo.version>
</properties>
<dependencies>
<!-- 公共接口模块 -->
<dependency>
<groupId>com.demo.rpc</groupId>
<artifactId>order-api</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Apache Dubbo 集成组件 -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>${dubbo.version}</version>
</dependency>
<!-- Zookeeper 注册中心客户端 -->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-x-discovery</artifactId>
<version>5.1.0</version>
</dependency>
</dependencies>
</project>2. 应用配置
配置独立的 Tomcat 运行端口，并连接至同一个 Zookeeper 注册中心集群。
server:
port: 8082
dubbo:
application:
name: order-consumer-service
registry:
address: zookeeper://192.168.1.100:21813. 消费远程服务
在控制层中，利用 @DubboReference 注解向 Spring 容器注入远程服务的代理引用。开发者无需关心网络通信细节，直接调用接口方法即可。
package com.demo.rpc.consumer.controller;
import org.apache.dubbo.config.annotation.DubboReference;
import com.demo.rpc.api.OrderApi;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class OrderController {
@DubboReference
private OrderApi orderApi;
@GetMapping("/api/order/details")
public String getOrderInfo() {
return orderApi.fetchOrderDetails();
}
}4. 启动消费者
同样在启动类中启用 Dubbo 支持，完成消费者应用的初始化。
package com.demo.rpc.consumer;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableDubbo
public class OrderConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(OrderConsumerApplication.class, args);
}
}