elasticsearch之请求处理流程（Rest/RPC ）

.Action概述

ES提供client供集群节点或java客户端访问集群用。client模块通过代理模式，将所有的操作都集成到client接口中。这样外部调用只需要初始化client就能够完成所有的调用功能。在每个方法后面都有一个***action来承接相应的功能。elasticsearch中的绝大部分操作都是通过相应的action，这些action在action包中。它的结构如下图所示：

上图是action包的部分截图，这里面对应着各个功能的action。各个action的包也都非常类似于index。这些action的实现也非常类似，都是基础自action，下图是indexaction的继承关系：

因为这些action并未真正实现相应的功能，只是一个代理，因此实现上也非常简单。他们的主要作用是提供新建response和request的方法及对应的action名称。还拿indexaction为例，它的方法图如下所示：

可以看到它只是提供了两个新建response和request的方法，及一个字NAME字段，这个NAME字段会用于后面action调用中。每个action对应的功能实现是在对应的transportAction中。

实际上***action也并非是真正的功能实现者，它只是一个代理，它的真正实现者是transport***Action.在ES中，Transport*Action 是比较核心的类集合。这里至少有两组映射关系。

Action -> Transport*Action
Transport*Action -> *TransportHandler

对应的功能是，可以通过Action 找到对应的TransportAction，这些TransportAction 如果是query类,则会调用SearchServiceTransportAction，并且通过第二层映射找到对应的Handler,否则可能就直接通过对应的Service完成操作。

第一层映射关系由类似下面的代码在ActionModule中完成：

第二层映射目前看来只有在查询相关的功能才有，其他的Transport*Action 则只调用对应的Service 来完成实际的操作。类似 SearchServiceTransportAction ，可以看做是SearchService进一步封装。如下：

2.rest请求到action的映射

对于java的Client请求，可以直接找到对应的action请求，但是ES为了提供更为通用的restful请求，通过restControl进行了由http到action的映射。

首先，每一个action在初始化时，针对自身能处理的action向restController进行注册，以RestCreateIndexAction为例，

    public RestCreateIndexAction(Settings settings, RestController controller, Client client) {

        super(settings, controller, client);

        controller.registerHandler(RestRequest.Method.PUT, "/{index}", this);

        controller.registerHandler(RestRequest.Method.POST, "/{index}", this);

    }

restController维护了几个队列，用来处理不同类型的http请求。

 /**

     * Registers a rest handler to be execute when the provided method and path match the request.

     */

    public void registerHandler(RestRequest.Method method, String path, RestHandler handler) {

        switch (method) {

            case GET:

                getHandlers.insert(path, handler);

                break;

            case DELETE:

                deleteHandlers.insert(path, handler);

                break;

            case POST:

                postHandlers.insert(path, handler);

                break;

            case PUT:

                putHandlers.insert(path, handler);

                break;

            case OPTIONS:

                optionsHandlers.insert(path, handler);

                break;

            case HEAD:

                headHandlers.insert(path, handler);

                break;

            default:

                throw new IllegalArgumentException("Can't handle [" + method + "] for path [" + path + "]");

        }

    }

当httpServer收到请求时候，优先进行plugin处理，然后转发给 RestController来处理。

    public void internalDispatchRequest(final HttpRequest request, final HttpChannel channel) {

        String rawPath = request.rawPath();

        if (rawPath.startsWith("/_plugin/")) {

            RestFilterChain filterChain = restController.filterChain(pluginSiteFilter);

            filterChain.continueProcessing(request, channel);

            return;

        } else if (rawPath.equals("/favicon.ico")) {

            handleFavicon(request, channel);

            return;

        }

        restController.dispatchRequest(request, channel);

    }

RestController收到请求后，如果有filter，先进行r过滤。然后进行executeHandler，最后通过channel返回操作结果

void executeHandler(RestRequest request, RestChannel channel) throws Exception {

        final RestHandler handler = getHandler(request);

        if (handler != null) {

            handler.handleRequest(request, channel); //根据action注册的path，调用对应action的handleRequest方法，在该方法内通过channel返回操作结果

} else { if (request.method() == RestRequest.Method.OPTIONS) { // when we have OPTIONS request, simply send OK by default (with the Access Control Origin header which gets automatically added) channel.sendResponse(new BytesRestResponse(OK)); } else { channel.sendResponse(new BytesRestResponse(BAD_REQUEST, "No handler found for uri [" + request.uri() + "] and method [" + request.method() + "]")); } } }

巴特西

elasticsearch之请求处理流程（Rest/RPC ）

最新文章

热门文章