全部标签
写点什么
学习MySQL开源云计算行业资讯算法Python人工智能区块链Linux前端个人成长面试架构师编程企业动态新基建敏捷安全读书笔记高效工作团队管理创业活动专区生涯规划知识管理运维产品经理 查看更多

我是一个请求，我该何去何从

用户头像
华为云开发者社区
关注
发布于: 2021 年 06 月 22 日

​​​​​​​​​​​​​​​​​​摘要：本文主要分析在 cse 框架下一个请求是怎么被接受和处理的。


本文分享自华为云社区《我是一个请求，我该何去何从？》，原文作者：向昊。

前置知识


cse 的通信是基于 vert.x 来搞的，所以我们首先得了解下里面的几个概念：



所以我们知道干活的就是这个家伙，它就是这个模式中的工具人


  • Route：可以看成是一个条件集合（可以指定 url 的匹配规则），它用这些条件来判断一个 http 请求或失败是否应该被路由到指定的 Handler

  • Router：可以看成一个核心的控制器，管理着 Route

  • VertxHttpDispatcher：是 cse 里的类，可以看成是请求分发处理器，即一个请求过来了怎么处理都是由它来管理的。

初始化

RestServerVerticle


经过一系列流程最终会调用这个方法：


io.vertx.core.impl.DeploymentManager#doDeploy()：注意如果在这个地方打断点，可能会进多次。因为上面也提到过我们的操作都是基于 Verticle 的，cse 中有 2 种 Verticle，一种是 org.apache.servicecomb.foundation.vertx.client.ClientVerticle 一种是 org.apache.servicecomb.transport.rest.vertx.RestServerVerticle，这篇文章我们主要分析接受请求的流程，即着眼于 RestServerVerticle，至于 ClientVerticle 的分析，先挖个坑，以后填上~


调用栈如下：



VertxHttpDispatcher


由上图可知，会调用如下方法：


	// org.apache.servicecomb.transport.rest.vertx.RestServerVerticle#start	public void start(Promise<Void> startPromise) throws Exception {	    // ...	    Router mainRouter = Router.router(vertx);	    mountAccessLogHandler(mainRouter);	    mountCorsHandler(mainRouter);	    initDispatcher(mainRouter);	    // ...	}
复制代码


​在这里我们看到了上文提到的 Router，继续看 initDispatcher(mainRouter)这个方法：


	// org.apache.servicecomb.transport.rest.vertx.RestServerVerticle#initDispatcher	private void initDispatcher(Router mainRouter) {	    List<VertxHttpDispatcher> dispatchers = SPIServiceUtils.getSortedService(VertxHttpDispatcher.class);	    for (VertxHttpDispatcher dispatcher : dispatchers) {	        if (dispatcher.enabled()) {	            dispatcher.init(mainRouter);	        }	    }	}
复制代码


​首先通过 SPI 方式获取所有 VertxHttpDispatcher，然后循环调用其 init 方法，由于分析的不是边缘服务，即这里我们没有自定义 VertxHttpDispatcher。

Router


接着上文分析，会调用如下方法：


	// org.apache.servicecomb.transport.rest.vertx.VertxRestDispatcher	public void init(Router router) {	    // cookies handler are enabled by default start from 3.8.3	    String pattern = DynamicPropertyFactory.getInstance().getStringProperty(KEY_PATTERN, null).get();	    if(pattern == null) {	        router.route().handler(createBodyHandler());	        router.route().failureHandler(this::failureHandler).handler(this::onRequest);	    } else {	        router.routeWithRegex(pattern).handler(createBodyHandler());	        router.routeWithRegex(pattern).failureHandler(this::failureHandler).handler(this::onRequest);	    }	}
复制代码


​由于一般不会主动去设置 servicecomb.http.dispatcher.rest.pattern 这个配置，即 pattern 为空，所以这个时候是没有特定 url 的匹配规则，即会匹配所有的 url


我们需要注意 handler(this::onRequest)这段代码，这个代码就是接受到请求后的处理。

处理请求


经过上面的初始化后，咱们的准备工作已经准备就绪，这个时候突然来了一个请求（GEThttp://127.0.0.1:18088/agdms/v1/stock-apps/query?pkgName=test），便会触发上面提到的回调，如下：


	// org.apache.servicecomb.transport.rest.vertx.VertxRestDispatcher#onRequest	protected void onRequest(RoutingContext context) {	    if (transport == null) {	        transport = CseContext.getInstance().getTransportManager().findTransport(Const.RESTFUL);	    }	    HttpServletRequestEx requestEx = new VertxServerRequestToHttpServletRequest(context);	    HttpServletResponseEx responseEx = new VertxServerResponseToHttpServletResponse(context.response());	 	    VertxRestInvocation vertxRestInvocation = new VertxRestInvocation();	    context.put(RestConst.REST_PRODUCER_INVOCATION, vertxRestInvocation);	    vertxRestInvocation.invoke(transport, requestEx, responseEx, httpServerFilters);	}
复制代码


​最主要的就是那个 invoke 方法：


	// org.apache.servicecomb.common.rest.RestProducerInvocation#invoke	public void invoke(Transport transport, HttpServletRequestEx requestEx, HttpServletResponseEx responseEx,	    List<HttpServerFilter> httpServerFilters) {	    this.transport = transport;	    this.requestEx = requestEx;	    this.responseEx = responseEx;	    this.httpServerFilters = httpServerFilters;	    requestEx.setAttribute(RestConst.REST_REQUEST, requestEx);	 	    try {	        findRestOperation();	    } catch (InvocationException e) {	        sendFailResponse(e);	        return;	    }	    scheduleInvocation();	}
复制代码


​这里看似简单，其实后背隐藏着大量的逻辑，下面来简单分析下 findRestOperation()和 scheduleInvocation()这 2 个方法。

findRestOperation


从名字我们也可以看出这个方法主要是寻找出对应的 OperationId


	// org.apache.servicecomb.common.rest.RestProducerInvocation#findRestOperation    	protected void findRestOperation() {	      MicroserviceMeta selfMicroserviceMeta = SCBEngine.getInstance().getProducerMicroserviceMeta();	      findRestOperation(selfMicroserviceMeta);	  }
复制代码


  • SCBEngine.getInstance().getProducerMicroserviceMeta()：这个是获取该服务的一些信息，项目启动时，会将本服务的基本信息注册到注册中心上去。相关代码可以参考：org.apache.servicecomb.serviceregistry.RegistryUtils#init。


本服务信息如下：



​我们主要关注这个参数：intfSchemaMetaMgr，即我们在契约中定义的接口，或者是代码中的 Controller 下的方法。


  • findRestOperation(selfMicroserviceMeta)：首先通过上面的 microserviceMeta 获取该服务下所有对外暴露的 url，然后根据请求的 RequestURI 和 Method 来获取 OperationLocator，进而对 restOperationMeta 进行赋值，其内容如下：



​可以看到这个 restOperationMeta 里面的内容十分丰富，和我们接口是完全对应的。

scheduleInvocation


现在我们知道了请求所对应的 Operation 相关信息了，那么接下来就要进行调用了。但是调用前还要进行一些前置动作，比如参数的校验、流控等等。


现在选取关键代码进行分析：


  • createInvocation：这个就是创建一个 Invocation，Invocation 在 cse 中还是一个比较重要的概念。它分为服务端和消费端，它们之间的区别还是挺大的。创建服务端的 Invocation 时候它会加载服务端相关的 Handler，同理消费端会加载消费端相关的 Handler。这次我们创建的是服务端的 Invocation，即它会加载 org.apache.servicecomb.qps.ProviderQpsFlowControlHandler、org.apache.servicecomb.qps.ProviderQpsFlowControlHandler、org.apache.servicecomb.core.handler.impl.ProducerOperationHandler 这 3 个 Handler（当然这些都是可配置的，不过最后一个是默认加载的）


  • runOnExecutor：这个方法超级重要，咱们也详细分析下，最终调用如下：


	// org.apache.servicecomb.common.rest.AbstractRestInvocation#invoke	public void invoke() {	    try {	        Response response = prepareInvoke();	        if (response != null) {	            sendResponseQuietly(response);	            return;	        }	 	        doInvoke();	    } catch (Throwable e) {	        LOGGER.error("unknown rest exception.", e);	        sendFailResponse(e);	    }	}
复制代码


​prepareInvoke：这个方法主要是执行 HttpServerFilter 里面的方法。如果 response 不为空就直接返回了。像参数校验就是这个 org.apache.servicecomb.common.rest.filter.inner.ServerRestArgsFilter 的功能，一般报 400 bad request 就可以进去跟跟代码了


doInvoke：类似责任链模式，会调用上面说的 3 个 Handler，前面 2 个 Handler 咱们不详细分析了，直接看最后一个 Handler，即 org.apache.servicecomb.core.handler.impl.ProducerOperationHandler


	// org.apache.servicecomb.core.handler.impl.ProducerOperationHandler#handle	public void handle(Invocation invocation, AsyncResponse asyncResp) throws Exception {	    SwaggerProducerOperation producerOperation =	        invocation.getOperationMeta().getExtData(Const.PRODUCER_OPERATION);	    if (producerOperation == null) {	        asyncResp.producerFail(	            ExceptionUtils.producerOperationNotExist(invocation.getSchemaId(),	                invocation.getOperationName()));	        return;	    }	    producerOperation.invoke(invocation, asyncResp);	}
复制代码


producerOperation 是在启动流程中赋值的，具体代码可以参考：org.apache.servicecomb.core.definition.schema.ProducerSchemaFactory#getOrCreateProducerSchema，其内容如下：



​可以看到，这其下内容对应的就是我们代码中接口对应的方法。

接着会调用 org.apache.servicecomb.swagger.engine.SwaggerProducerOperation#invoke 方法：


	// org.apache.servicecomb.swagger.engine.SwaggerProducerOperation#invoke	public void invoke(SwaggerInvocation invocation, AsyncResponse asyncResp) {	    if (CompletableFuture.class.equals(producerMethod.getReturnType())) {	        completableFutureInvoke(invocation, asyncResp);	        return;	    }	 	    syncInvoke(invocation, asyncResp);	}
复制代码


由于我们的同步调用，即直接看 syncInvoke 方法即可：


	public void syncInvoke(SwaggerInvocation invocation, AsyncResponse asyncResp) {	    ContextUtils.setInvocationContext(invocation);	    Response response = doInvoke(invocation);	    ContextUtils.removeInvocationContext();	    asyncResp.handle(response);	}
复制代码


咱们一般上下文传递信息就是这行代码"搞的鬼"：

ContextUtils.setInvocationContext(invocation)，然后再看 doInvoke 方法：


	public Response doInvoke(SwaggerInvocation invocation) {	    Response response = null;	    try {	        invocation.onBusinessMethodStart();	 	        Object[] args = argumentsMapper.toProducerArgs(invocation);	        for (ProducerInvokeExtension producerInvokeExtension : producerInvokeExtenstionList) {	            producerInvokeExtension.beforeMethodInvoke(invocation, this, args);	        }	 	        Object result = producerMethod.invoke(producerInstance, args);	        response = responseMapper.mapResponse(invocation.getStatus(), result);	 	        invocation.onBusinessMethodFinish();	        invocation.onBusinessFinish();	    } catch (Throwable e) {	        if (shouldPrintErrorLog(e)){	            LOGGER.error("unexpected error operation={}, message={}",	                invocation.getInvocationQualifiedName(), e.getMessage());	        }	        invocation.onBusinessMethodFinish();	        invocation.onBusinessFinish();	        response = processException(invocation, e);	    }	    return response;	}
复制代码


​producerInvokeExtenstionList：根据 SPI 加载 ProducerInvokeExtension 相关类，系统会自动加载 org.apache.servicecomb.swagger.invocation.validator.ParameterValidator，顾名思义这个就是校验请求参数的。如校验 @Notnull、@Max(50)这些标签。


producerMethod.invoke(producerInstance, args)：通过反射去调用到具体的方法上！


这样整个流程差不多完结了，剩下的就是响应转换和返回响应信息。

总结


这样我们大概了解到了我们的服务是怎么接受和处理请求的，即请求进入我们服务后，首先会获取服务信息，然后根据请求的路径和方法去匹配具体的接口，然后经过 Handler 和 Filter 的处理，再通过反射调用到我们的业务代码上，最后返回响应。


整体流程看似简单但是背后隐藏了大量的逻辑，本文也是摘取相对重要的流程进行分析，还有很多地方没有分析到的，比如在调用 runOnExecutor 之前会进行线程切换，还有同步调用和异步调用的区别以及服务启动时候初始化的逻辑等等。这些内容也是比较有意思，值得深挖。


点击关注，第一时间了解华为云新鲜技术~

划线
评论
复制
发布于: 2021 年 06 月 22 日阅读数: 10

版权声明: 本文为 InfoQ 作者【华为云开发者社区】的原创文章。

原文链接:【http://xie.infoq.cn/article/d42e62dfc49b3c2dd1f5b47d6】。文章转载请联系作者。

CSE请求条件VerticleRoute
用户头像

华为云开发者社区

关注

提供全面深入的云计算技术干货 2020.07.14 加入

华为云开发者社区，提供全面深入的云计算前景分析、丰富的技术干货、程序样例，分享华为云前沿资讯动态，方便开发者快速成长与发展，欢迎提问、互动，多方位了解云计算！ 传送门：https://bbs.huaweicloud.com/

评论

发布
暂无评论
Copyright © 2021, Geekbang Technology Ltd. All rights reserved. 极客邦控股（北京）有限公司 | 京 ICP 备 16027448 号 - 5京公网安备京公网安备 11010502039052号
我是一个请求，我该何去何从