网站首页制作教程西安竞价托管公司
Dubbo 服务调用过程详解
Dubbo 的调用过程分为服务注册与发现和远程调用执行两大阶段，具体流程如下：
一、服务注册与发现
-
服务提供者注册
- 服务提供者（Provider）启动时，将服务接口、实现类、IP 端口等信息注册到注册中心（如 Zookeeper）。
- 注册中心存储服务元数据，并通知已订阅的消费者更新服务列表。
-
服务消费者订阅
- 消费者（Consumer）启动时，向注册中心订阅所需服务，获取提供者地址列表并缓存在本地。
- 注册中心通过长连接推送服务变更（如新增/下线提供者）。
二、远程调用执行
-
代理层拦截
- 消费者通过动态代理（JDK 或 Javassist）生成服务接口的代理对象，调用时转为远程 RPC 请求。
-
集群容错与负载均衡
- Directory：从本地缓存获取所有可用的服务提供者（Invoker 列表）。
- Router：根据路由规则（如标签路由）过滤 Invoker。
- LoadBalance：按策略（随机、轮询等）选择目标 Invoker。
-
网络通信与编码
- 将方法名、参数类型、参数值等序列化为二进制数据（默认使用 Hessian2）。
- 通过 Netty 发送 Dubbo 协议数据包（Header + Body 结构，Header 含序列化类型、请求 ID 等）。
-
服务端处理
- 提供者的 NettyServer 接收请求，解码后派发到业务线程池。
- 通过反射调用真实服务实现，结果序列化后返回。
-
结果返回与解码
- 消费者接收响应数据，解码后唤醒阻塞的调用线程，返回结果。
三、关键设计
- 协议设计：Dubbo 协议采用 0xdabb 魔数标识，解决 TCP 粘包问题。
- 异步调用：支持 Future 和回调机制，避免线程阻塞。
- 容错机制：失败自动重试（默认 2 次）、快速失败等策略。
整个过程通过 Filter 链嵌入扩展点（如监控、鉴权），实现高可定制化。