Dubbo源码解析（三十三）远程调用——webservice协议

远程调用——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协议的请求的处理类。

后记

该部分相关的源码解析地址：github.com/CrazyHZM/in…

该文章讲解了远程调用中关于webservice协议实现的部分，到这里关于rpc远程调用的部分就结束了，关于远程调用核心的几个内容就是代理、协议，再加上不一样功能加强的过滤器等，关键是要把api中关于接口设计方面的内容看清楚，后面各种协议由于不少都是基于第三方的框架去实现，虽然方法逻辑有所区别，可是总体的思路和框架必定顺着api设计的去实现。接下来我将开始对cluster集群模块进行讲解。