坏味道
 | 这里记录的是Dubbo设计或实现不优雅的地方。 |
URL转换
1. 点对点暴露和引用服务
1.1. 直接暴露服务：
EXPORT(dubbo://provider-address/com.xxx.XxxService?version=1.0.0")
1.2. 点对点直连服务：
REFER(dubbo://provider-address/com.xxx.XxxService?version=1.0.0)
2. 通过注册中心暴露服务
2.1. 向注册中心暴露服务：
EXPORT(registry://registry-address/com.alibaba.dubbo.registry.RegistrySerevice?registry=dubbo&export=ENCODE(dubbo://provider-address/com.xxx.XxxService?version=1.0.0))
2.2. 获取注册中心：url.setProtocol(url.getParameter("registry", "dubbo"))
GETREGISTRY(dubbo://registry-address/com.alibaba.dubbo.registry.RegistrySerevice)
2.3. 注册服务地址：url.getParameterAndDecoded("export"))
REGISTER(dubbo://provider-address/com.xxx.XxxService?version=1.0.0)
3. 通过注册中心引用服务
3.1. 从注册中心订阅服务：
REFER(registry://registry-address/com.alibaba.dubbo.registry.RegistrySerevice?registry=dubbo&refer=ENCODE(version=1.0.0))
3.2. 获取注册中心：url.setProtocol(url.getParameter("registry", "dubbo"))
GETREGISTRY(dubbo://registry-address/com.alibaba.dubbo.registry.RegistrySerevice)
3.3. 订阅服务地址：url.addParameters(url.getParameterAndDecoded("refer"))
SUBSCRIBE(dubbo://registry-address/com.xxx.XxxService?version=1.0.0)
3.4. 通知服务地址：url.addParameters(url.getParameterAndDecoded("refer"))
NOTIFY(dubbo://provider-address/com.xxx.XxxService?version=1.0.0)
4. 注册中心推送路由规则
4.1. 注册中心路由规则推送：
NOTIFY(route://registry-address/com.xxx.XxxService?router=script&type=js&rule=ENCODE(function{...}))
4.2. 获取路由器：url.setProtocol(url.getParameter("router", "script"))
GETROUTE(script://registry-address/com.xxx.XxxService?type=js&rule=ENCODE(function{...}))
5. 从文件加载路由规则
5.1. 从文件加载路由规则：
GETROUTE(file://path/file.js?router=script)
5.2. 获取路由器：url.setProtocol(url.getParameter("router", "script")).addParameter("type", SUFFIX(file)).addParameter("rule", READ(file))
GETROUTE(script://path/file.js?type=js&rule=ENCODE(function{...}))
调用参数
- path 服务路径
- group 服务分组
- version 服务版本
- dubbo 使用的dubbo版本
- token 验证令牌
- timeout 调用超时
扩展点的加载
1. 自适应扩展点
ExtensionLoader加载扩展点时，会检查扩展点的属性（通过set方法判断），如该属性是扩展点类型，则会注入扩展点对象。因为注入时不能确定使用哪个扩展点（在使用时确定），所以注入的是一个自适应扩展（一个代理）。自适应扩展点调用时，选取一个真正的扩展点，并代理到其上完成调用。Dubbo是根据调用方法参数（上面有调用哪个扩展点的信息）来选取一个真正的扩展点。
在Dubbo给定所有的扩展点上调用都有URL参数（整个扩展点网的上下文信息）。自适应扩展即是从URL确定要调用哪个扩展点实现。URL哪个Key的Value用来确定使用哪个扩展点，这个信息通过的@Adaptive注解在方法上说明。
由于自适应扩展点的上面的约定，ExtensionLoader会为扩展点自动生成自适应扩展点类(通过字节码)，并将其实例注入。
ExtensionLoader生成的自适应扩展点类如下：
@Adaptive注解使用如下：
如果URL这些Key都没有Value，使用 用 缺省的扩展（在接口的Default中设定的值）。
比如，String[] {"key1", "key2"}，表示
先在URL上找key1的Value作为要Adapt成的Extension名；
key1没有Value，则使用key2的Value作为要Adapt成的Extension名。
key2没有Value，使用缺省的扩展。
如果没有设定缺省扩展，则方法调用会抛出IllegalStateException。
如果不设置则缺省使用Extension接口类名的点分隔小写字串。
即对于Extension接口com.alibaba.dubbo.xxx.YyyInvokerWrapper的缺省值为String[] {"yyy.invoker.wrapper"}
Callback功能
1. 参数回调
1.1主要原理:在一个Consumer->provider的长连接上，自动在Consumer端暴露一个服务（实现方法参数上声明的接口A），provider端便可反向调用到consumer端的接口实例.
1.2实现细节：
- 为了在传输时能够对回调接口实例进行转换，自动暴露与自动引用目前在DubboCodec中实现.此处需要考虑将此逻辑与codec逻辑分离.
- 在根据invocation信息获取exporter时，需要判断是否是回调，如果是回调，会从attachments中取得回调服务实例的id，在获取exporter，此处用于consumer端可以对同一个callback接口做不同的实现。
2. 事件通知
2.1主要原理：Consumer在invoke方法时，判断如果有配置onreturn/onerror...则将onreturn对应的参数值(实例方法)加入到异步调用的回调列表中.
2.2实现细节：参数的传递采用URL，但URL中没有支持string-object，所以将实例方法存储在staticMap中，此处实现需要进行改造，http://code.alibabatech.com/jira/browse/DUBBO-168
Lazy连接
DubboProtocol特有功能，默认关闭
当客户端与服务端创建代理时，暂不建立tcp长连接，当有数据请求时在做连接初始化
此项功能自动关闭连接重试功能，开启发送重试功能（即发送数据时如果连接已断开，尝试重新建立连接）.
共享连接
DubboProtocol特有功能，默认开启
JVM A暴露了多个服务，JVM B引用了A中的多个服务，共享连接是说A与B多个服务调用是通过同一个TCP长连接进行数据传输，已达到减少服务端连接数的目的.
实现细节：对于同一个地址由于使用了共享连接，那invoker的destroy就需要特别注意，一方面要满足对同一个地址refer的invoker全部destroy后，连接需要关闭，另一方面还需要注意如何避免部分invoker destroy时不能关闭连接。在实现中采用了引用计数的方案，但为了防范，在连接关闭时，重新建立了一个Lazy connection(称为幽灵连接),用于当出现异常场景时，避免影响业务逻辑的正常调用.
sticky 策略
有多个服务提供者的情况下，配置了sticky后，在提供者可用的情况下，调用会继续发送到上一次的服务提供者. sticky策略默认开启了连接的lazy选项,用于避免开启无用的连接.
服务提供者选择逻辑
1.存在多个服务提供者的情况下，首先根据Loadbalance进行选择，如果选择的provider处于可用状态，则进行后续调用
2.如果第一步选择的服务提供者不可用，则从剩余服务提供者列表中继续选择，如果可用，进行后续调用
3.如果所有的服务提供者都不可用，重新遍历整个列表（优先从没有选过的列表中选择），判断是否有可用的服务提供者（选择过程中，不可用的服务提供者可能会恢复到可用状态），如果有，则进行后续调用
4.如果第三步没有选择出可用的服务提供者，会选第一步选出的invoker中的下一个（如果不是最后一个），避免碰撞.