-
Notifications
You must be signed in to change notification settings - Fork 14
/
dubboImplementation.md
73 lines (58 loc) · 3.05 KB
/
dubboImplementation.md
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
# Dubbo Implementation
## 初始化过程细节
### 解析服务
所有 dubbo 的标签，都统一用 `DubboBeanDefinitionParser` 进行解析，基于一对一属性映射，将 XML 标签解析为 Bean 对象
### 暴露服务
1. 只暴露服务端口
- `ServiceConfig` 解析出的 URL 的格式为： `dubbo://service-host/com.foo.FooService?version=1.0.0`
2. 向注册中心暴露服务
- `ServiceConfig` 解析出的 URL 的格式为:
`registry://registry-host/org.apache.dubbo.registry.RegistryService?`
`export=URL.encode("dubbo://service-host/com.foo.FooService?version=1.0.0")`
### 引用服务
1. 直连引用服务
- `ReferenceConfig` 解析出的 URL 的格式为：`dubbo://service-host/com.foo.FooService?version=1.0.0`
2. 从注册中心发现引用服务
- `ReferenceConfig` 解析出的 URL 的格式为： `registry://registry-host/org.apache.dubbo.registry.RegistryService?`
`refer=URL.encode("consumer://consumer-host/com.foo.FooService?version=1.0.0")`
## 远程调用细节
### 服务提供者暴露一个服务的详细过程
Dubbo 处理服务暴露的关键就在 `Invoker` 转换到 `Exporter` 的过程
- Dubbo 的实现: 在 `DubboProtocol` 类的 `export` 方法
- RMI 的实现: 在 `RmiProtocol` 类的 `export` 方法
### 服务消费者消费一个服务的详细过程
`ReferenceConfig` 类的 `init` 方法调用 `Protocol` 的 `refer` 方法生成 `Invoker` 实例，这是服务消费的关键
### 满眼都是 Invoker
服务消费者代码：
```
public class DemoClientAction {
private DemoService demoService;
public void setDemoService(DemoService demoService) {
this.demoService = demoService;
}
public void start() {
String hello = demoService.sayHello("world" + i);
}
}
```
`DemoService` 就是上图中服务消费端的 proxy，用户代码通过这个 proxy 调用其对应的 `Invoker`，而该 `Invoker` 实现了真正的远程服务调用
```
public class DemoServiceImpl implements DemoService {
public String sayHello(String name) throws RemoteException {
return "Hello " + name;
}
}
```
上面这个类会被封装成为一个 `AbstractProxyInvoker` 实例，并新生成一个 `Exporter` 实例。这样当网络通讯层收到一个请求后，会找到对应的 `Exporter` 实例，并调用它所对应的 `AbstractProxyInvoker` 实例，从而真正调用了服务提供者的代码
## 远程通讯细节
### 协议头约定
### 线程派发模型
- Dispather: `all`, `direct`, `message`, `execution`, `connection`
- ThreadPool: `fixed`, `cached`
## References
- [实现细节](http://dubbo.apache.org/zh-cn/docs/dev/implementation.html)