远程调用——rmi 协议
目标：介绍 rmi 协议的设计和实现，介绍 dubbo-rpc-rmi 的源码。
前言
dubbo 支持 rmi 协议，主要基于 spring 封装的 org.springframework.remoting.rmi 包来实现，当然最原始还是依赖 JDK 标准的 java.rmi.* 包，采用阻塞式短连接和 JDK 标准序列化方式。关于 rmi 协议的介绍可以参考 dubbo 官方文档。
地址：http://dubbo.apache.org/zh-cn…
源码分析
（一）RmiRemoteInvocation
该类继承了 RemoteInvocation，主要是在 RemoteInvocation 的基础上新增 dubbo 自身所需的附加值，避免这些附加值没有被传递，为了做一些验证处理。
public class RmiRemoteInvocation extends RemoteInvocation {
private static final long serialVersionUID = 1L;
private static final String dubboAttachmentsAttrName = “dubbo.attachments”;
/**
* executed on consumer side
*/
public RmiRemoteInvocation(MethodInvocation methodInvocation) {
super(methodInvocation);
// 添加 dubbo 附加值的属性
addAttribute(dubboAttachmentsAttrName, new HashMap<String, String>(RpcContext.getContext().getAttachments()));
}
/**
* Need to restore context on provider side (Though context will be overridden by Invocation’s attachment
* when ContextFilter gets executed, we will restore the attachment when Invocation is constructed, check more
* 需要在提供者端恢复上下文（尽管上下文将被 Invocation 的附件覆盖
* 当 ContextFilter 执行时，我们将在构造 Invocation 时恢复附件，检查更多
* from {@link com.alibaba.dubbo.rpc.proxy.InvokerInvocationHandler}
*/
@SuppressWarnings(“unchecked”)
@Override
public Object invoke(Object targetObject) throws NoSuchMethodException, IllegalAccessException,
InvocationTargetException {
// 获得上下文
RpcContext context = RpcContext.getContext();
// 设置参数
context.setAttachments((Map<String, String>) getAttribute(dubboAttachmentsAttrName));
try {
return super.invoke(targetObject);
} finally {
// 清空参数
context.setAttachments(null);
}
}
}
（二）RmiProtocol
该类继承了 AbstractProxyProtocol 类，是 rmi 协议实现的核心，跟其他协议一样，也实现了自己的服务暴露和服务引用方法。
1.doExport
@Override
protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
// rmi 暴露者
final RmiServiceExporter rmiServiceExporter = new RmiServiceExporter();
// 设置端口
rmiServiceExporter.setRegistryPort(url.getPort());
// 设置服务名称
rmiServiceExporter.setServiceName(url.getPath());
// 设置接口
rmiServiceExporter.setServiceInterface(type);
// 设置服务实现
rmiServiceExporter.setService(impl);
try {
// 初始化 bean 的时候执行
rmiServiceExporter.afterPropertiesSet();
} catch (RemoteException e) {
throw new RpcException(e.getMessage(), e);
}
return new Runnable() {
@Override
public void run() {
try {
// 销毁
rmiServiceExporter.destroy();
} catch (Throwable e) {
logger.warn(e.getMessage(), e);
}
}
};
}
该方法是服务暴露的逻辑实现。
2.doRefer
@Override
@SuppressWarnings(“unchecked”)
protected <T> T doRefer(final Class<T> serviceType, final URL url) throws RpcException {
// FactoryBean 对于 RMI 代理，支持传统的 RMI 服务和 RMI 调用者，创建 RmiProxyFactoryBean 对象
final RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
// RMI needs extra parameter since it uses customized remote invocation object
// 检测版本
if (url.getParameter(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion()).equals(Version.getProtocolVersion())) {
// Check dubbo version on provider, this feature only support
// 设置 RemoteInvocationFactory 以用于此访问器
rmiProxyFactoryBean.setRemoteInvocationFactory(new RemoteInvocationFactory() {
@Override
public RemoteInvocation createRemoteInvocation(MethodInvocation methodInvocation) {
// 自定义调用工厂可以向调用添加更多上下文信息
return new RmiRemoteInvocation(methodInvocation);
}
});
}
// 设置此远程访问者的目标服务的 URL。URL 必须与特定远程处理提供程序的规则兼容。
rmiProxyFactoryBean.setServiceUrl(url.toIdentityString());
// 设置要访问的服务的接口。界面必须适合特定的服务和远程处理策略
rmiProxyFactoryBean.setServiceInterface(serviceType);
// 设置是否在找到 RMI 存根后缓存它
rmiProxyFactoryBean.setCacheStub(true);
// 设置是否在启动时查找 RMI 存根
rmiProxyFactoryBean.setLookupStubOnStartup(true);
// 设置是否在连接失败时刷新 RMI 存根
rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);
// // 初始化 bean 的时候执行
rmiProxyFactoryBean.afterPropertiesSet();
return (T) rmiProxyFactoryBean.getObject();
}
该方法是服务引用的逻辑实现。
后记
该部分相关的源码解析地址：https://github.com/CrazyHZM/i…
该文章讲解了远程调用中关于 rmi 协议实现的部分，逻辑比较简单。接下来我将开始对 rpc 模块关于 thrift 协议部分进行讲解。