远程调用——webservice 协议
目标：介绍 webservice 协议的设计和实现，介绍 dubbo-rpc-webservice 的源码。
前言
dubbo 集成 webservice 协议，基于 Apache CXF 的 frontend-simple 和 transports-http 实现，CXF 是 Apache 开源的一个 RPC 框架，由 Xfire 和 Celtix 合并而来。关于 webservice 协议的优势以及介绍可以查看官方文档，我就不多赘述。
源码分析
（一）WebServiceProtocol
该类继承了 AbstractProxyProtocol，是 webservice 协议的关键逻辑实现。
1. 属性
/**
* 默认端口
*/
public static final int DEFAULT_PORT = 80;
/**
* 服务集合
*/
private final Map<String, HttpServer> serverMap = new ConcurrentHashMap<String, HttpServer>();
/**
* 总线，该总线使用 CXF 内置的扩展管理器来加载组件（而不是使用 Spring 总线实现）。虽然加载速度更快，但它不允许像 Spring 总线那样进行大量配置和定制。
*/
private final ExtensionManagerBus bus = new ExtensionManagerBus();
/**
* http 通信工厂对象
*/
private final HTTPTransportFactory transportFactory = new HTTPTransportFactory();
/**
* http 绑定者
*/
private HttpBinder httpBinder;
2.doExport
@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
// 获得地址
String addr = getAddr(url);
// 获得 http 服务
HttpServer httpServer = serverMap.get(addr);
// 如果服务为空，则重新创建服务器。并且加入集合
if (httpServer == null) {
httpServer = httpBinder.bind(url, new WebServiceHandler());
serverMap.put(addr, httpServer);
}
// 服务加载器
final ServerFactoryBean serverFactoryBean = new ServerFactoryBean();
// 设置地址
serverFactoryBean.setAddress(url.getAbsolutePath());
// 设置服务类型
serverFactoryBean.setServiceClass(type);
// 设置实现类
serverFactoryBean.setServiceBean(impl);
// 设置总线
serverFactoryBean.setBus(bus);
// 设置通信工厂
serverFactoryBean.setDestinationFactory(transportFactory);
// 创建
serverFactoryBean.create();
return new Runnable() {
@Override
public void run() {
if(serverFactoryBean.getServer()!= null) {
serverFactoryBean.getServer().destroy();
}
if(serverFactoryBean.getBus()!=null) {
serverFactoryBean.getBus().shutdown(true);
}
}
};
}
该方法是服务暴露的逻辑实现，基于 cxf 一些类。
3.doRefer
@Override
@SuppressWarnings(“unchecked”)
protected <T> T doRefer(final Class<T> serviceType, final URL url) throws RpcException {
// 创建代理工厂
ClientProxyFactoryBean proxyFactoryBean = new ClientProxyFactoryBean();
// 设置地址
proxyFactoryBean.setAddress(url.setProtocol(“http”).toIdentityString());
// 设置服务类型
proxyFactoryBean.setServiceClass(serviceType);
// 设置总线
proxyFactoryBean.setBus(bus);
// 创建
T ref = (T) proxyFactoryBean.create();
// 获得代理
Client proxy = ClientProxy.getClient(ref);
// 获得 HTTPConduit 处理“http”和“https”传输协议。实例由显式设置或配置的策略控制
HTTPConduit conduit = (HTTPConduit) proxy.getConduit();
// 用于配置客户端 HTTP 端口的属性
HTTPClientPolicy policy = new HTTPClientPolicy();
// 配置连接超时时间
policy.setConnectionTimeout(url.getParameter(Constants.CONNECT_TIMEOUT_KEY, Constants.DEFAULT_CONNECT_TIMEOUT));
// 配置调用超时时间
policy.setReceiveTimeout(url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT));
conduit.setClient(policy);
return ref;
}
该方法是服务引用的逻辑实现。
4.WebServiceHandler
private class WebServiceHandler implements HttpHandler {
private volatile ServletController servletController;
@Override
public void handle(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
// 如果 servletController 为空，则重新加载一个
if (servletController == null) {
HttpServlet httpServlet = DispatcherServlet.getInstance();
if (httpServlet == null) {
response.sendError(500, “No such DispatcherServlet instance.”);
return;
}
// 创建 servletController
synchronized (this) {
if (servletController == null) {
servletController = new ServletController(transportFactory.getRegistry(), httpServlet.getServletConfig(), httpServlet);
}
}
}
// 设置远程地址
RpcContext.getContext().setRemoteAddress(request.getRemoteAddr(), request.getRemotePort());
// 调用方法
servletController.invoke(request, response);
}
}
该内部类实现了 HttpHandler 接口，是 WebService 协议的请求的处理类。
后记
该部分相关的源码解析地址：https://github.com/CrazyHZM/i…
该文章讲解了远程调用中关于 webservice 协议实现的部分，到这里关于 rpc 远程调用的部分就结束了，关于远程调用核心的几个内容就是代理、协议，再加上不同功能增强的过滤器等，关键是要把 api 中关于接口设计方面的内容看清楚，后面各类协议因为很多都是基于第三方的框架去实现，虽然方法逻辑有所区别，但是整体的思路和框架一定顺着 api 设计的去实现。接下来我将开始对 cluster 集群模块进行讲解。