框架
配置
dubbo的配置项分为三类:
- 服务发现:表示该配置用于服务的注册与发现,目的是让消费方找到提供方。
- 服务治理:表示该配置用于治理服务间的关系,或者为开发测试提供遍历条件。
- 性能调优:表示该配置用于性能调优,不同的选项会对性能造成影响。
服务容器只是一个简单的 Main 方法,并加载一个简单的 Spring 容器,用于暴露服务。
只有 group,interface,version 是服务的匹配条件,三者决定是不是同一个服务,其它配置项均为调优和治理参数。所有配置最终都将转换为 URL [3] 表示,并由服务提供方生成,经注册中心传递给消费方,各属性对应 URL 的参数,参见配置项一览表中的 "对应URL参数" 列
部分参数分析
stub(类别:服务治理)
设为true,表示使用缺省代理类名,即:接口名 + Stub后缀,服务接口客户端本地代理类名,用于在客户端执行本地逻辑,如本地缓存等,该本地代理类的构造函数必须允许传入远程代理对象,构造函数如:public XxxServiceStub(XxxService xxxService)
设置Stub类似于对RPC接口做切面编程,也可以通过Stub封装RPC接口的异常,消费方Demo如下。如果DubboFacade的接口调用异常,会返回Stub的Default返回值。
- DubboFacadeStub.class
public class DubboFacadeStub implements DubboFacade {
private DubboFacade dubboFacade;
// 必须提供,dubbo框架会在消费者这一方调用这个方法
public DubboFacadeStub(DubboFacade dubboFacade) {
this.dubboFacade = dubboFacade;
}
@Override
public String sayHello() {
try{
return dubboFacade.sayHello();
} catch (Exception e) {
return "RPC Hello is Error, This is backUp Hello.";
}
}
}
- dubbo-consumer.xml
<!-- 生成远程服务代理, 可以和本地bean一样使用服务-->
<dubbo:reference id="dubboFacade" stub="com.example.royal.stubs.DubboFacadeStub" interface="com.example.core.facade.DubboFacade" check="false"/>
优雅停机
Dubbo 是通过 JDK 的 ShutdownHook 来完成优雅停机的,所以如果用户使用 kill -9 PID 等强制关闭指令,是不会执行优雅停机的,只有通过 kill PID 时,才会执行。
原理
服务提供方
停止时,先标记为不接收新请求,新请求过来时直接报错,让客户端重试其它机器。
然后,检测线程池中的线程是否正在运行,如果有,等待所有线程执行完成,除非超时,则强制关闭。
服务消费方
停止时,不再发起新的调用请求,所有新的调用在客户端即报错。
然后,检测有没有请求的响应还没有返回,等待响应返回,除非超时,则强制关闭
设置方式
设置优雅停机超时时间,缺省超时时间是 10 秒,如果超时则强制关闭。
####### dubbo.properties
dubbo.service.shutdown.wait=15000
如果 ShutdownHook 不能生效,可以自行调用,使用tomcat等容器部署的場景,建议通过扩展ContextListener等自行调用以下代码实现优雅停机:
ProtocolConfig.destroyAll();