政府 网站 下载自媒体推广

Dubbo 服务调用过程详解

Dubbo 的调用过程分为服务注册与发现和远程调用执行两大阶段，具体流程如下：

---

一、服务注册与发现

1. 服务提供者注册

   • 服务提供者（Provider）启动时，将服务接口、实现类、IP 端口等信息注册到注册中心（如 Zookeeper）。
   • 注册中心存储服务元数据，并通知已订阅的消费者更新服务列表。

2. 服务消费者订阅

   • 消费者（Consumer）启动时，向注册中心订阅所需服务，获取提供者地址列表并缓存在本地。
   • 注册中心通过长连接推送服务变更（如新增/下线提供者）。

---

二、远程调用执行

1. 代理层拦截

   • 消费者通过动态代理（JDK 或 Javassist）生成服务接口的代理对象，调用时转为远程 RPC 请求。

2. 集群容错与负载均衡

   • Directory：从本地缓存获取所有可用的服务提供者（Invoker 列表）。
   • Router：根据路由规则（如标签路由）过滤 Invoker。
   • LoadBalance：按策略（随机、轮询等）选择目标 Invoker。

3. 网络通信与编码

   • 将方法名、参数类型、参数值等序列化为二进制数据（默认使用 Hessian2）。
   • 通过 Netty 发送 Dubbo 协议数据包（Header + Body 结构，Header 含序列化类型、请求 ID 等）。

4. 服务端处理

   • 提供者的 NettyServer 接收请求，解码后派发到业务线程池。
   • 通过反射调用真实服务实现，结果序列化后返回。

5. 结果返回与解码

   • 消费者接收响应数据，解码后唤醒阻塞的调用线程，返回结果。

---

三、关键设计

• 协议设计：Dubbo 协议采用 0xdabb 魔数标识，解决 TCP 粘包问题。
• 异步调用：支持 Future 和回调机制，避免线程阻塞。
• 容错机制：失败自动重试（默认 2 次）、快速失败等策略。

整个过程通过 Filter 链嵌入扩展点（如监控、鉴权），实现高可定制化。