SpringBoot+Dubbo+Zookeeper实现分布式系统步骤

---

一、分布式系统通俗解释

场景比喻：想象一个大型超市（分布式系统）：

• 收银台（服务消费者）：处理顾客请求
• 仓库（服务提供者）：提供商品
• 总控室（Zookeeper）：记录哪个仓库有什么商品
• 物流系统（Dubbo）：负责收银台和仓库之间的通信

当顾客要买可乐时：

1. 收银台询问总控室：哪里能拿到可乐？
2. 总控室返回仓库A的地址
3. 收银台通过物流系统向仓库A请求可乐
4. 仓库A将可乐送到收银台

---

二、环境准备（详细版）

1. 软件版本

• JDK 8
• Maven 3.6.3
• Zookeeper 3.7.0 (下载地址)

2. 安装Zookeeper（单机模式）

# 解压后进入conf目录
cp zoo_sample.cfg zoo.cfg
# 修改配置（关键部分）
dataDir=/tmp/zookeeper
clientPort=2181# 启动服务（Linux/Mac）
bin/zkServer.sh start
# Windows双击zkServer.cmd

---

三、完整项目结构（带详细注释）

distributed-demo
├── api           # 服务接口定义
├── provider      # 服务提供者
└── consumer      # 服务消费者

---

四、手把手代码实现

步骤1：创建父工程（管理依赖）

<!-- pom.xml -->
<project><groupId>com.example</groupId><artifactId>distributed-demo</artifactId><version>1.0</version><packaging>pom</packaging><modules><module>api</module><module>provider</module><module>consumer</module></modules><properties><dubbo.version>2.7.15</dubbo.version><zk.version>3.7.0</zk.version></properties><dependencies><!-- 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-framework</artifactId><version>5.1.0</version></dependency></dependencies>
</project>

步骤2：API模块（定义服务契约）

// api/src/main/java/com/example/api/CalculatorService.java
public interface CalculatorService {/*** 加法服务* @param a 加数* @param b 被加数* @return 和*/int add(int a, int b);
}

步骤3：服务提供者（实现具体逻辑）

// provider/src/main/java/com/example/provider/CalculatorServiceImpl.java
@DubboService // 关键注解：声明这是Dubbo服务
public class CalculatorServiceImpl implements CalculatorService {@Overridepublic int add(int a, int b) {System.out.println("收到请求：" + a + "+" + b);return a + b;}
}// provider/src/main/resources/application.properties
# 应用配置
spring.application.name=calculator-provider
server.port=8081# Dubbo配置
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
dubbo.scan.base-packages=com.example.provider

步骤4：服务消费者（调用远程服务）

// consumer/src/main/java/com/example/consumer/CalculatorController.java
@RestController
public class CalculatorController {@DubboReference // 关键注解：引用远程服务private CalculatorService calculatorService;@GetMapping("/add")public String add(@RequestParam int a, @RequestParam int b) {return a + " + " + b + " = " + calculatorService.add(a, b);}
}// consumer/src/main/resources/application.properties
spring.application.name=calculator-consumer
server.port=8080dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.consumer.timeout=3000

步骤5：启动类配置

// Provider启动类
@SpringBootApplication
@EnableDubbo // 启用Dubbo功能
public class ProviderApplication {public static void main(String[] args) {SpringApplication.run(ProviderApplication.class, args);System.out.println("Provider启动成功！");}
}// Consumer启动类
@SpringBootApplication
@EnableDubbo
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class, args);System.out.println("Consumer启动成功！");}
}

---

五、运行流程详解

1. 启动顺序

2. 验证步骤

1. 启动Zookeeper
2. 启动Provider（控制台看到Provider启动成功！）
3. 启动Consumer
4. 访问测试接口：

   http://localhost:8080/add?a=5&b=3
   

   应返回：5 + 3 = 8

3. 查看服务注册情况

使用Zookeeper客户端工具（推荐PrettyZoo）连接localhost:2181，查看节点：

/dubbo/com.example.api.CalculatorService/providers

---

六、核心机制详解

1. 服务注册过程

1. Provider启动时向Zookeeper注册自己的地址
2. 注册信息包括：IP、端口、接口名称、版本等
3. Zookeeper以临时节点存储这些信息

2. 服务发现过程

1. Consumer启动时订阅所需服务
2. Zookeeper推送Provider地址列表
3. Dubbo根据负载均衡策略选择Provider

3. 通信协议

• 默认使用Dubbo协议（TCP长连接）
• 数据序列化：Hessian2二进制格式

---

七、常见问题解决方案

1. 服务无法注册

• 检查Zookeeper是否运行：telnet 127.0.0.1 2181
• 查看Provider日志是否有注册异常
• 确认Dubbo版本与Zookeeper版本兼容

2. 调用超时

# 在consumer的配置中添加
dubbo.consumer.timeout=5000 # 单位毫秒

3. 接口包路径不一致

必须保证接口的 全限定名 在Provider和Consumer中完全一致！

---

八、扩展实践建议

1. 多Provider测试：启动两个Provider实例，观察负载均衡
2. 服务治理：集成Dubbo Admin控制台
3. 容错机制：添加@DubboReference(cluster = "failover")