1. Dubbo简介与版本说明
Apache Dubbo是一款高性能、轻量级的Java RPC框架，提供了三大核心能力：面向接口的远程方法调用、智能容错和负载均衡、服务自动注册和发现。Dubbo已经成为Apache顶级项目，是微服务架构中最流行的RPC框架之一。更多学习教程www.fgedu.net.cn。
Dubbo 3.x版本进行了全面升级，提供了更好的云原生支持、更强的性能和更丰富的功能。Dubbo支持多种语言实现，包括Java、Go、Python、PHP、Erlang、Rust和Node.js等。学习交流加群风哥微信: itpux-com。
Dubbo核心特性：
– 服务注册与发现：支持Nacos、Zookeeper、Redis等多种注册中心
– 负载均衡：支持随机、轮询、最少活跃调用数、一致性哈希等策略
– 服务降级与熔断：集成Sentinel、Hystrix等熔断组件
– 服务治理：支持路由规则、动态配置、标签路由等
– 多协议支持：Dubbo、REST、gRPC、HTTP、Hessian等协议
– 多注册中心：支持多注册中心集群和跨注册中心调用
– 云原生支持：Kubernetes原生集成、Service Mesh支持
Dubbo核心组件：
– Consumer：服务消费者，调用远程服务的应用
– Registry：注册中心，服务注册与发现的目录服务
– Monitor：监控中心，统计服务调用次数和调用时间
– Container：服务运行容器，负责启动、加载和运行服务提供者
2. Dubbo版本选择与下载地址
Dubbo提供多个版本供用户选择，生产环境建议使用稳定版本。
Dubbo版本状态：
3.3.x Latest 3.3.6 2025-XX-XX Java 8+ 最新特性版本，支持JDK 21
3.2.x Stable 3.2.19 2025-XX-XX Java 8+ 稳定版本
3.1.x Stable 3.1.11 2024-XX-XX Java 8+ 长期支持版本
3.0.x Stable 3.0.15 2024-XX-XX Java 8+ 稳定版本
2.7.x Legacy 2.7.23 2023-XX-XX Java 6+ 传统版本
Dubbo 3.3.x主要特性：
– 全新Service Mesh支持
– Triple协议增强
– Native Image支持
– Spring Boot 3.x支持
– 性能优化和内存优化
官方下载地址：
下载页面：https://dubbo.apache.org/en/download/
GitHub仓库：https://github.com/apache/dubbo
中文文档：https://cn.dubbo.apache.org/zh-cn/
3. Dubbo下载方式详解
方式一：Maven依赖引入（推荐）
添加注册中心依赖（Nacos）：
添加Spring Boot集成依赖：
完整依赖配置：
方式二：下载源码编译
$ git clone https://github.com/apache/dubbo.git
$ cd dubbo/
切换到指定版本分支：
$ git checkout dubbo-3.3.6
编译打包：
$ mvn clean install -DskipTests
输出示例如下：
[INFO] Scanning for projects…
[INFO] ————————————————————————
[INFO] Building Apache Dubbo 3.3.6
[INFO] ————————————————————————
…
[INFO] BUILD SUCCESS
[INFO] ————————————————————————
[INFO] Total time: 15:23 min
[INFO] Finished at: 2026-04-04T10:15:30+08:00
查看编译结果：
$ ls -la dubbo-all/target/
输出示例如下：
total 12345
drwxr-xr-x 2 root root 4096 Apr 4 10:15 .
drwxr-xr-x 3 root root 4096 Apr 4 10:15 ..
-rw-r–r– 1 root root 12345678 Apr 4 10:15 dubbo-all-3.3.6.jar
-rw-r–r– 1 root root 2345678 Apr 4 10:15 dubbo-all-3.3.6-sources.jar
方式三：下载官方发布包
$ cd /fgeudb/software
$ wget https://dlcdn.apache.org/dubbo/3.3.6/dubbo-3.3.6-source-release.zip
输出示例如下：
–2026-04-04 10:00:00– https://dlcdn.apache.org/dubbo/3.3.6/dubbo-3.3.6-source-release.zip
Resolving dlcdn.apache.org (dlcdn.apache.org)… 151.101.2.132
Connecting to dlcdn.apache.org (dlcdn.apache.org)|151.101.2.132|:443… connected.
HTTP request sent, awaiting response… 200 OK
Length: 12345678 (12M) [application/zip]
Saving to: ‘dubbo-3.3.6-source-release.zip’
dubbo-3.3.6-source-release.zip 100%[======================================================================>] 11.77M 5.2MB/s in 2.3s
2026-04-04 10:00:02 (5.2 MB/s) – ‘dubbo-3.3.6-source-release.zip’ saved [12345678/12345678]
解压源码包：
$ unzip dubbo-3.3.6-source-release.zip -d /fgeudb/dubbo/
方式四：使用国内镜像加速
$ cd /fgeudb/software
$ wget https://mirrors.tuna.tsinghua.edu.cn/apache/dubbo/3.3.6/dubbo-3.3.6-source-release.zip
输出示例如下：
–2026-04-04 10:01:00– https://mirrors.tuna.tsinghua.edu.cn/apache/dubbo/3.3.6/dubbo-3.3.6-source-release.zip
Resolving mirrors.tuna.tsinghua.edu.cn… 101.6.15.130
Connecting to mirrors.tuna.tsinghua.edu.cn|101.6.15.130|:443… connected.
HTTP request sent, awaiting response… 200 OK
Length: 12345678 (12M) [application/zip]
Saving to: ‘dubbo-3.3.6-source-release.zip’
dubbo-3.3.6-source-release.zip 100%[======================================================================>] 11.77M 25.3MB/s in 0.5s
2026-04-04 10:01:01 (25.3 MB/s) – ‘dubbo-3.3.6-source-release.zip’ saved [12345678/12345678]
方式五：下载Dubbo Admin管理控制台
$ cd /fgeudb/software
$ wget https://github.com/apache/dubbo-admin/releases/download/0.6.0/dubbo-admin-0.6.0.jar
输出示例如下：
–2026-04-04 10:02:00– https://github.com/apache/dubbo-admin/releases/download/0.6.0/dubbo-admin-0.6.0.jar
Resolving github.com (github.com)… 140.82.121.3
Connecting to github.com (github.com)|140.82.121.3|:443… connected.
HTTP request sent, awaiting response… 200 OK
Length: 56789012 (54M) [application/java-archive]
Saving to: ‘dubbo-admin-0.6.0.jar’
dubbo-admin-0.6.0.jar 100%[======================================================================>] 54.16M 6.5MB/s in 8.4s
2026-04-04 10:02:08 (6.5 MB/s) – ‘dubbo-admin-0.6.0.jar’ saved [56789012/56789012]
4. Dubbo开发环境搭建实战
步骤1：环境准备
$ java -version
输出示例如下：
openjdk version “17.0.13” 2026-01-21
OpenJDK Runtime Environment (build 17.0.13+11-Ubunt-1)
OpenJDK 64-Bit Server VM (build 17.0.13+11-Ubunt-1, mixed mode, sharing, from:www.itpux.com)
检查Maven版本：
$ mvn -version
输出示例如下：
Apache Maven 3.9.6 (bc78907ecb5e5e5c6e5f5e5e5e5e5e5e5e5e5e5e)
Maven home: /usr/share/maven
Java version: 17.0.13, vendor: Oracle Corporation
设置环境变量：
$ export JAVA_HOME=/usr/lib/jvm/java-17-openjdk-amd64
$ export MAVEN_HOME=/usr/share/maven
$ export PATH=$JAVA_HOME/bin:$MAVEN_HOME/bin:$PATH
步骤2：创建Dubbo项目
$ mvn archetype:generate \
-DgroupId=com.fgedu.dubbo \
-DartifactId=dubbo-demo \
-DarchetypeArtifactId=maven-archetype-quickstart \
-DinteractiveMode=false
输出示例如下：
[INFO] Scanning for projects…
[INFO] Building Maven Stub Project (1) [INFO] ————————————————————————
[INFO] Using property: groupId = com.fgedu.dubbo
[INFO] Using property: artifactId = dubbo-demo
[INFO] ————————————————————————
[INFO] BUILD SUCCESS
[INFO] ————————————————————————
[INFO] Total time: 3.456 s
进入项目目录：
$ cd dubbo-demo
创建子模块：
$ mkdir -p dubbo-api dubbo-provider dubbo-consumer
步骤3：配置pom.xml
步骤4：定义服务接口
定义服务接口：
package com.fgedu.dubbo.api;
public interface DemoService {
String sayHello(String name);
String sayHelloAsync(String name);
}
步骤5：实现服务提供者
实现服务接口：
package com.fgedu.dubbo.provider;
import com.fgedu.dubbo.api.DemoService;
import org.apache.dubbo.config.annotation.DubboService;
import java.util.concurrent.CompletableFuture;
@DubboService(version = “1.0.0”, timeout = 5000)
public class DemoServiceImpl implements DemoService {
@Override
public String sayHello(String name) {
return “Hello ” + name + “, from Dubbo Provider!”;
}
@Override
public CompletableFuture
return CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return “Hello ” + name + ” (async)”;
});
}
}
启动类：
package com.fgedu.dubbo.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 ProviderApplication {
public static void main(String[] args) {
SpringApplication.run(ProviderApplication.class, args);
}
}
5. Dubbo生产环境配置优化
步骤1：配置服务提供者
server:
port: 8081
spring:
application:
name: dubbo-provider
dubbo:
application:
name: dubbo-provider
logger: slf4j
registry:
address: nacos://192.168.1.51:8848
username: nacos
password: nacos
parameters:
namespace: dev
group: DUBBO_GROUP
protocol:
name: dubbo
port: 20880
threads: 200
iothreads: 4
dispatcher: all
payload: 8388608
provider:
timeout: 5000
retries: 2
loadbalance: roundrobin
async: false
executes: 100
actives: 50
config-center:
address: nacos://192.168.1.51:8848
namespace: dev
group: DUBBO_GROUP
metadata-report:
address: nacos://192.168.1.51:8848
namespace: dev
group: DUBBO_GROUP
步骤2：配置服务消费者
server:
port: 8082
spring:
application:
name: dubbo-consumer
dubbo:
application:
name: dubbo-consumer
logger: slf4j
registry:
address: nacos://192.168.1.51:8848
username: nacos
password: nacos
parameters:
namespace: dev
group: DUBBO_GROUP
protocol:
name: dubbo
port: -1
consumer:
timeout: 5000
retries: 2
loadbalance: roundrobin
check: false
async: false
actives: 50
config-center:
address: nacos://192.168.1.51:8848
namespace: dev
group: DUBBO_GROUP
metadata-report:
address: nacos://192.168.1.51:8848
namespace: dev
group: DUBBO_GROUP
步骤3：配置JVM参数
-Xms2g 初始堆内存2GB
-Xmx4g 最大堆内存4GB
-Xmn1g 年轻代内存1GB
-XX:+UseG1GC 使用G1垃圾收集器
-XX:MaxGCPauseMillis=200 最大GC停顿时间200ms
-XX:+HeapDumpOnOutOfMemoryError
-XX:HeapDumpPath=/fgeudb/logs/heapdump.hprof
启动命令：
$ java -Xms2g -Xmx4g -Xmn1g -XX:+UseG1GC \
-Dspring.profiles.active=prod \
-jar dubbo-provider.jar
步骤4：配置线程池
@DubboService(
version = “1.0.0”,
timeout = 5000,
threadpool = “fixed”,
threads = 200,
executes = 100
)
public class DemoServiceImpl implements DemoService {
// 服务实现
}
线程池配置说明：
– fixed：固定大小线程池
– cached：缓存线程池
– limited：可伸缩线程池
– eager：优先创建Worker线程池
生产环境建议：
– 使用fixed线程池
– threads设置为CPU核心数*2+1
– executes限制服务最大并发数
6. Dubbo注册中心配置
Nacos注册中心配置
dubbo:
registry:
address: nacos://192.168.1.51:8848
username: nacos
password: nacos
parameters:
namespace: dev
group: DUBBO_GROUP
多注册中心配置：
dubbo:
registries:
nacos1:
address: nacos://192.168.1.51:8848
parameters:
namespace: dev
nacos2:
address: nacos://192.168.1.52:8848
parameters:
namespace: dev
服务指定注册中心：
@DubboService(registry = {“nacos1”, “nacos2”})
public class DemoServiceImpl implements DemoService {
// 服务实现
}
Zookeeper注册中心配置
dubbo:
registry:
address: zookeeper://192.168.1.51:2181
timeout: 10000
session: 60000
集群模式：
dubbo:
registry:
address: zookeeper://192.168.1.51:2181?backup=192.168.1.52:2181,192.168.1.53:2181
注册中心选型建议
– 支持服务注册与配置管理一体化
– 支持命名空间隔离
– 提供可视化管理界面
– 支持权重和元数据管理
– 推荐用于Spring Cloud生态
Zookeeper优势：
– 成熟稳定，经过大规模验证
– 支持分布式协调
– 强一致性保证
– 推荐用于传统Dubbo架构
7. Dubbo集群与高可用配置
集群容错策略
@DubboService(cluster = “failover”)
public class DemoServiceImpl implements DemoService {
// 服务实现
}
容错策略说明：
– failover：失败自动切换，重试其他服务器（默认）
– failfast：快速失败，只发起一次调用，失败立即报错
– failsafe：失败安全，出现异常时直接忽略
– failback：失败自动恢复，后台记录失败请求，定时重发
– forking：并行调用多个服务器，只要一个成功即返回
– broadcast：广播调用所有提供者，任意一个报错则报错
配置重试次数：
@DubboService(cluster = “failover”, retries = 3)
public class DemoServiceImpl implements DemoService {
// 服务实现
}
负载均衡策略
@DubboService(loadbalance = “roundrobin”)
public class DemoServiceImpl implements DemoService {
// 服务实现
}
负载均衡策略说明：
– random：随机，按权重设置随机概率（默认）
– roundrobin：轮询，按公约后的权重设置轮询比率
– leastactive：最少活跃调用数，使慢的提供者收到更少请求
– consistenthash：一致性哈希，相同参数的请求总是发到同一提供者
– shortestresponse：最短响应时间，响应时间越快的选择概率越大
配置权重：
@DubboService(weight = 100)
public class DemoServiceImpl implements DemoService {
// 服务实现
}
动态调整权重（通过Nacos配置）：
dubbo.service.demo.weight=200
服务降级配置
@DubboService(
mock = “com.fgedu.dubbo.provider.DemoServiceMock”,
timeout = 5000
)
public class DemoServiceImpl implements DemoService {
// 服务实现
}
Mock实现：
public class DemoServiceMock implements DemoService {
@Override
public String sayHello(String name) {
return “服务降级：Mock返回”;
}
@Override
public CompletableFuture
return CompletableFuture.completedFuture(“服务降级：Mock返回(async)”);
}
}
消费端配置降级：
@DubboReference(
mock = “return null”,
timeout = 3000
)
private DemoService demoService;
8. 安装验证与测试
启动服务提供者
$ mvn clean package -DskipTests
启动Provider：
$ java -jar dubbo-provider/target/dubbo-provider.jar
输出示例如下：
____ ____ /\ _`\ /\ _`\ \ \ \/\_\ _ __ ___\ \ \/ ___ _ __ \ \ \/_/_ /\`’__\/’ _ `\ \ \ / __`\/\`’__\ \ \ \L\ \\ \ \/ /\ \/\ \ \ \__/\ \L\ \ \ \/ \ \____/ \ \_\ \ \_\ \_\ \____\ \____/\ \_\ \/___/ \/_/ \/_/\/_/\/____/\/___/ \/_/ :: Dubbo Spring Boot :: (v3.3.6)
2026-04-04 10:20:00.000 INFO [main] o.a.dubbo.config.DubboBootstrap: [DUBBO] Dubbo Bootstrap has started.
2026-04-04 10:20:01.000 INFO [main] o.a.dubbo.registry.nacos.NacosRegistry: [DUBBO] Register: dubbo://192.168.1.51:20880/com.fgedu.dubbo.api.DemoService
2026-04-04 10:20:01.000 INFO [main] o.a.dubbo.config.DubboBootstrap: [DUBBO] Dubbo Bootstrap has ready.
启动服务消费者
$ java -jar dubbo-consumer/target/dubbo-consumer.jar
输出示例如下：
2026-04-04 10:21:00.000 INFO [main] o.a.dubbo.config.DubboBootstrap: [DUBBO] Dubbo Bootstrap has started.
2026-04-04 10:21:01.000 INFO [main] o.a.dubbo.registry.nacos.NacosRegistry: [DUBBO] Subscribe: dubbo://192.168.1.51:20880/com.fgedu.dubbo.api.DemoService
2026-04-04 10:21:01.000 INFO [main] o.a.dubbo.config.DubboBootstrap: [DUBBO] Dubbo Bootstrap has ready.
验证服务调用
@RestController
public class TestController {
@DubboReference(version = “1.0.0”)
private DemoService demoService;
@GetMapping(“/hello”)
public String hello(@RequestParam String name) {
return demoService.sayHello(name);
}
}
调用测试：
$ curl “http://localhost:8082/hello?name=fengge”
输出示例如下：
Hello fengge, from Dubbo Provider!
查看Nacos注册信息
http://192.168.1.51:8848/nacos
查看服务列表：
服务名：providers:com.fgedu.dubbo.api.DemoService:1.0.0
实例数：1
健康实例：1
查看服务详情：
实例IP：192.168.1.51
端口：20880
元数据：{“dubbo.protocol”:”dubbo”,”dubbo.version”:”3.3.6″}
9. 服务开发与调用示例
定义服务接口
package com.fgedu.dubbo.api;
import java.util.List;
import java.util.concurrent.CompletableFuture;
public interface UserService {
User getUserById(Long id);
List
CompletableFuture
void createUser(User user);
void updateUser(User user);
void deleteUser(Long id);
}
实体类：
package com.fgedu.dubbo.api;
import java.io.Serializable;
public class User implements Serializable {
private Long id;
private String name;
private Integer age;
private String email;
// getter and setter
}
实现服务提供者
package com.fgedu.dubbo.provider;
import com.fgedu.dubbo.api.User;
import com.fgedu.dubbo.api.UserService;
import org.apache.dubbo.config.annotation.DubboService;
import java.util.concurrent.CompletableFuture;
@DubboService(
version = “1.0.0”,
timeout = 5000,
retries = 2,
loadbalance = “roundrobin”
)
public class UserServiceImpl implements UserService {
@Override
public User getUserById(Long id) {
User user = new User();
user.setId(id);
user.setName(“User” + id);
user.setAge(25);
user.setEmail(“user” + id + “@fgedu.net.cn”);
return user;
}
@Override
public List
return Arrays.asList(
getUserById(1L),
getUserById(2L),
getUserById(3L)
);
}
@Override
public CompletableFuture
return CompletableFuture.supplyAsync(() -> getUserById(id));
}
@Override
public void createUser(User user) {
System.out.println(“Creating user: ” + user.getName());
}
@Override
public void updateUser(User user) {
System.out.println(“Updating user: ” + user.getName());
}
@Override
public void deleteUser(Long id) {
System.out.println(“Deleting user: ” + id);
}
}
服务消费者调用
@RestController
public class UserController {
@DubboReference(version = “1.0.0”, timeout = 5000)
private UserService userService;
@GetMapping(“/user/{id}”)
public User getUser(@PathVariable Long id) {
return userService.getUserById(id);
}
@GetMapping(“/users”)
public List
return userService.listUsers();
}
}
异步调用：
@GetMapping(“/user/async/{id}”)
public CompletableFuture
return userService.getUserAsync(id);
}
泛化调用：
@RestController
public class GenericController {
@DubboReference(interfaceName = “com.fgedu.dubbo.api.UserService”, generic = true)
private GenericService genericService;
@GetMapping(“/generic/user/{id}”)
public Object getUserGeneric(@PathVariable Long id) {
return genericService.$invoke(“getUserById”, new String[]{“java.lang.Long”}, new Object[]{id});
}
}
10. 常见问题与解决方案
问题1：服务注册失败
解决方案：
1. 检查注册中心地址配置：
dubbo.registry.address=nacos://192.168.1.51:8848
2. 检查注册中心是否启动：
$ curl http://192.168.1.51:8848/nacos/v1/ns/service/list
3. 检查网络连通性：
$ telnet 192.168.1.51 8848
4. 检查用户名密码：
dubbo.registry.username=nacos
dubbo.registry.password=nacos
5. 检查命名空间配置：
dubbo.registry.parameters.namespace=dev
问题2：服务调用超时
解决方案：
1. 增加超时时间：
@DubboReference(timeout = 10000)
private DemoService demoService;
2. 检查服务端处理时间：
– 优化业务逻辑
– 增加服务端线程数
3. 检查网络延迟：
$ ping 192.168.1.51
4. 配置重试策略：
@DubboReference(timeout = 5000, retries = 3)
private DemoService demoService;
问题3：服务提供者无响应
解决方案：
1. 检查服务是否启动：
$ ps -ef | grep dubbo
2. 检查端口是否监听：
$ netstat -tlnp | grep 20880
3. 检查服务是否注册：
访问Nacos控制台查看服务列表
4. 检查服务分组和版本：
@DubboService(group = “demo”, version = “1.0.0”)
消费者必须使用相同的group和version
5. 检查check配置：
dubbo.consumer.check=false
问题4：序列化异常
解决方案：
1. 确保实体类实现Serializable：
public class User implements Serializable {
private static final long serialVersionUID = 1L;
// …
}
2. 检查序列化配置：
dubbo.protocol.serialization=hessian2
3. 确保API包版本一致：
提供者和消费者使用相同版本的API包
4. 检查类路径：
确保实体类在API包中定义
Dubbo服务管理命令
$ java -jar dubbo-provider.jar
后台启动：
$ nohup java -jar dubbo-provider.jar > /fgeudb/logs/provider.log 2>&1 &
停止服务：
$ kill -15 $(cat /fgeudb/dubbo/provider.pid)
查看服务日志：
$ tail -f /fgeudb/logs/provider.log
查看Dubbo Admin：
访问 http://192.168.1.51:8080
默认用户名：root
默认密码：root
Telnet管理命令：
$ telnet 192.168.1.51 20880
dubbo> ls
com.fgedu.dubbo.api.DemoService
dubbo> ls com.fgedu.dubbo.api.DemoService
sayHello
sayHelloAsync
dubbo> invoke com.fgedu.dubbo.api.DemoService.sayHello(“test”)
“Hello test, from Dubbo Provider!”
1. 使用Dubbo 3.3.x最新稳定版本；2. 使用Nacos作为注册中心和配置中心；3. 配置合理的超时时间和重试次数；4. 使用fixed线程池并设置合适的线程数；5. 配置服务降级和熔断策略；6. 开启Dubbo Admin监控服务状态；7. 配置合理的JVM内存参数；8. 使用多注册中心实现异地多活；9. 配置服务权重实现灰度发布；10. 定期检查服务健康状态和性能指标。
本文由风哥教程整理发布,仅用于学习测试使用,转载注明出处:http://www.fgedu.net.cn/10327.html
