文档章节

Play源码深入之三:一次访问的前半生-请求

奋斗到天明
 奋斗到天明
发布于 2015/08/27 18:12
字数 1144
阅读 353
收藏 0
点赞 1
评论 0

接着 上篇,play初始化完成之后,第一个请求来到了PlayHandler中,我们看PlayHandler如何处理。 Netty调用play.server.PlayHandler:messageReceived()方法,play将netty的httprequest转化成自己的Http.Request对象。

...
// Plain old HttpRequest
try {
    final Request request = parseRequest(ctx, nettyRequest, messageEvent);

    final Response response = new Response();
    Http.Response.current.set(response);

    // Buffered in memory output
    response.out = new ByteArrayOutputStream();

    // Direct output (will be set later)
    response.direct = null;

    // Streamed output (using response.writeChunk)
    response.onWriteChunk(new Action< Object >() {

        public void invoke(Object result) {
            writeChunk(request, response, ctx, nettyRequest, result);
        }
    });

    // Raw invocation
    boolean raw = Play.pluginCollection.rawInvocation(request, response);
    if (raw) {
        copyResponse(ctx, request, response, nettyRequest);
    } else {

        // Deleguate to Play framework
        Invoker.invoke(new NettyInvocation(request, response, ctx, nettyRequest, messageEvent));

    }

} catch (Exception ex) {
  Logger.warn(ex, "Exception on request. serving 500 back");
    serve500(ex, ctx, nettyRequest);
}
...

构建了Http.Response对象。然后发出原始调用事件rawInvocation,每个插件plugin可以处理这个请求,并决定是否放弃后续处理直接返回Response。如果所有插件处理后没有中断,则交与NettyInvocation处理。 

这时从Eclipse的Debug面板中可以看到,NettyInvocation已经是第三个线程了。 NettyInvocation继承了Invoker.Invocation,在run()方法调用了Invoker.Invocation:run()方法,所以主体就在Invoker.Invocation:run()中

...
public static abstract class Invocation implements Runnable {
    ...
    public void run() {
        if (waitInQueue != null) {
            waitInQueue.stop();
        }
        try {
            preInit();
            if (init()) {
                before();
                boolean withinFilterFctFound = this.withinFilter(new play.libs.F.Function0() {
                    public Void apply() throws Throwable {
                        execute();
                        return null;
                    }
                });
                // No filter function found => we need to execute anyway( as before the use of withinFilter )
                if(!withinFilterFctFound){
                    execute();
                }
                after();
                onSuccess();
            }
        } catch (Suspend e) {
            suspend(e);
            after();
        } catch (Throwable e) {
            onException(e);
        } finally {
            _finally();
        }
    }
    ...
}
...

主体中,通过init()方法初始化了调用相关的参数reqeust/response/scope.param等等的current线程变量。

然后Router负责检查请求的request路径是否在route配置中,是否为静态文件请求。play.mvc.ActionInvoker:resolve()中负责处理调用应用Action方法的初始化,包括路由的匹配、Controller类、方法等。

在getActionMethod方法中,我们可以看到play给每个不以controllers开头的请求路径加上了 controllers.。所以controller就必需写在controllers中了。

...
    public static Object[] getActionMethod(String fullAction) {
        Method actionMethod = null;
        Class controllerClass = null;
        try {
            if (!fullAction.startsWith("controllers.")) {
                fullAction = "controllers." + fullAction;
            }
   ...

init结束。在主体before()触发beforeInvocation事件后,play开始调用各个插件的过滤器处理请求。其中事务处理过滤器就写在了JPAPlugin中。

...
        private boolean withinFilter(play.libs.F.Function0 fct) throws Throwable {
            boolean withinFilterFctFound = false;
            for (PlayPlugin plugin : Play.pluginCollection.getEnabledPlugins()) {
                if (plugin.getFilter() != null){
                    withinFilterFctFound = true;
                    plugin.getFilter().withinFilter(fct);
                }
            }
            return withinFilterFctFound;
        }
        ....

如果请求的方法被NoTransaction注解后,就会不会开启事务。而在开启了事务后,JPA回调play.libs.F.Function0匿名内部类中的apply方法,从而调用execute处理请求。

public class JPA {
    ...
    public static  T withinFilter(F.Function0 block) throws Throwable {
        if(InvocationContext.current().getAnnotation(NoTransaction.class) != null ) {
            //Called method or class is annotated with @NoTransaction telling us that
            //we should not start a transaction
            return block.apply();
        }

        boolean readOnly = false;
        String name = DEFAULT;
        Transactional tx = InvocationContext.current().getAnnotation(Transactional.class);
        if (tx != null) {
            readOnly = tx.readOnly();
        }
        PersistenceUnit pu = InvocationContext.current().getAnnotation(PersistenceUnit.class);
        if (pu != null) {
            name = pu.name();
        }

        return withTransaction(name, readOnly, block);
    }
    ...

    public static  T withTransaction(String dbName, boolean readOnly, F.Function0 block) throws Throwable {
        ...
        for (String name : emfs.keySet()) {
            EntityManager localEm = JPA.newEntityManager(name);
            JPA.bindForCurrentThread(name, localEm, readOnly);

            if (!readOnly) {
                localEm.getTransaction().begin();
            }
        }

        T result = block.apply();   
        ...
    }
    ...
}

在做了如此多的准备工作之后,play.mvc.ActionInvoker中invoker方法,终于要调用我们应用中route文件对应的Controller.action方法了。

public static void invoke(Request request, Http.Response response) {
    ...
    Play.pluginCollection.beforeActionInvocation(actionMethod);

    // Monitoring
    monitor = MonitorFactory.start(request.action + "()");

    // 3. Invoke the action
    try {
      // @Before
      handleBefores(request);

      // Action

      Result actionResult = null;
      String cacheKey = null;

      // Check the cache (only for GET or HEAD)
      if ((request.method.equals("GET") || request.method.equals("HEAD")) && actionMethod.isAnnotationPresent(CacheFor.class)) {
          cacheKey = actionMethod.getAnnotation(CacheFor.class).id();
          if ("".equals(cacheKey)) {
              cacheKey = "urlcache:" + request.url + request.querystring;
          }
          actionResult = (Result) play.cache.Cache.get(cacheKey);
      }

      if (actionResult == null) {
          ControllerInstrumentation.initActionCall();
          try {
              inferResult(invokeControllerMethod(actionMethod));
          } catch(Result result) {
              actionResult = result;
              // Cache it if needed
              if (cacheKey != null) {
                  play.cache.Cache.set(cacheKey, actionResult, actionMethod.getAnnotation(CacheFor.class).value());
              }
          } catch (InvocationTargetException ex) {
              ....
          }
      }
    ...
}

首先,play发出调用前的事件beforeActionInvocation,VolidationPlugin响应,进行校验工作。 

然后,处理@before注解。 

再是,正式处理请求,这是也能看到play被人诟病的基于异常的返回机制。

而参数的绑定就在getActionMethodArgs中,先对请求参数进行了一次重构,形成一棵树状对象。

public static Object[] getActionMethodArgs(Method method, Object o) throws Exception {
        ...
        
        for (int i = 0; i < method.getParameterTypes().length; i++) {
            ...

            rArgs[i] = Binder.bind(
                        root,
                        paramsNames[i],
                        method.getParameterTypes()[i],
                        method.getGenericParameterTypes()[i],
                        method.getParameterAnnotations()[i],
                        new Binder.MethodAndParamInfo(o, method, i + 1));
        }

        CachedBoundActionMethodArgs.current().storeActionMethodArgs(method, rArgs);
        return rArgs;
    }

在play.data.binding.Binder:bind()方法中,我们可以看见,play再次发出了绑定事件,这次也就JPA响应,用Hibenate加载域模型对象。

public static Object bind(RootParamNode parentParamNode, String name, Class<?> clazz, Type type, Annotation[] annotations, MethodAndParamInfo methodAndParamInfo) {
    ...

    if (paramNode != null) {

        // Let a chance to plugins to bind this object
        result = Play.pluginCollection.bind(parentParamNode, name, clazz, type, annotations);
        if (result != null) {
            return result;
        }

        result = internalBind(paramNode, clazz, type, bindingAnnotations);
    }

    ...
}

在invokeWithContinuation方法中,终于看到了 result = method.invoke(instance, realArgs);这是Controller.action()方法的invoke,其实正常情况result没什么用,因为返回结果都是异常,result根本没得收。

static Object invokeWithContinuation(Method method, Object instance, Object[] realArgs) throws Exception {
        ...
        try {
            pStackRecorder.isRestoring = !pStackRecorder.isEmpty();

            // Execute code
            result = method.invoke(instance, realArgs);

            ...
        } finally {
            pStackRecorder.deregisterThread(old);
        }
        return result;
    }

method.invoke就已经进入应用程序了,而到此就是一个访问的前半生——请求。

© 著作权归作者所有

共有 人打赏支持
奋斗到天明
粉丝 18
博文 112
码字总数 82707
作品 0
昌平
程序员
Play源码解析计划

最近有想法看看Play的源码,以提高自己的编码水平。之前都是东看看,西看看。最后看来去却好像无所大成。有人说过,伤敌十指,不如断敌一指,于是我有开始了学习之路。 原计划是采用1.2.3版本...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

Play源码深入之二:Play应用启动时框架的初始化

接着上篇在python的辅助下,理理输入启动命令之后,play框架进行的初始化工作。 application.py中的javacmd方法中就有play.server.Server。 def javacmd(self, javaargs, cp_args=None, clas...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

Play源码深入之四:一次访问的后半生-响应

在处理了我们应用的代码之后,就会再次进入Play框架的范围,我们就接着说下一个请求的下半生。 在Controller中定义一系列的render方法: 可以对应到play.mvc.results包中各种Render开头的类:...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

Play框架拾遗之三:模板引擎

1、模板语法 用表达式时,如下使用时,只有client不为null的情况下,才进行client.name的输出。 <h1>Client ${client?.name}</h1> 在应用中,模板引擎默认对所有的动态表达式进行转义,以此来...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

Play 1.x框架学习之七:多数据库切换与源码修改 ( Databases Switch And Modify Source Code)

在单数据源(单个ip)下的多库,可以使用use xxdb 命令进行切换,但是如果多个数据源的情况下,use命令就不行了。在play框架中,提供了多数据源多库的切换。本文不提供完全的例子,只提供部分...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

PlayScala 2.5.x - Filter开发指南

Filter简介 Filter是Play基于责任链模式(Chain of Responsibility)实现的过滤器,利用Filter可以过滤所有的请求和响应。Play的Filter实现非常灵活,你可以在Filter中修改请求和响应,或终止F...

joymufeng ⋅ 2016/06/01 ⋅ 0

Play源码深入之五:Job模块的原理

先看play.jobs.JobsPlugin。 public void onApplicationStart() { int core = Integer.parseInt(Play.configuration.getProperty("play.jobs.pool", "10")); executor = new ScheduledThread......

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

彩钢瓦机生产厂家批发@恍惚醒来半生已过

彩钢瓦机生产厂家批发@恍惚醒来半生已过 想起单纯的幼年,那一片湛蓝,一群泥鳅般的孩子们,逮蛐蛐,捉蚂蚱;山涧抓鱼,摸虾;彩钢瓦机生产厂家批发片爬树掏鸟窝,摘槐花……如此夸姣的回想,...

shimengxi ⋅ 04/05 ⋅ 0

Play 1.2.3 反序列化速度慢

继续之前讲的SSH+EJB迁移到Play 1.2.3上,今天出了一个很奇怪的BUG。 在进行表单提交的时候,提交数据中有一个List列表数据,如果List数据多的话,服务端处理会很慢,有时甚至超时!比如10条...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

Play源码深入之七:Play的MVC实现

整体来说,Play1.x是一个较完善的框架,各种功能都一应俱全,有点像句老话“麻雀虽小五脏俱全”哈。虽没有Struts、SpringMVC的大名气,但是使用起来,相当顺手。本文将深入Play1.x的MVC,也整...

刀狂剑痴 ⋅ 2015/08/27 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

用ZBLOG2.3博客写读书笔记网站能创造今日头条的辉煌吗?

最近两年,著名的自媒体网站今日头条可以说是火得一塌糊涂,虽然从目前来看也遇到了一点瓶颈,毕竟发展到了一定的规模,继续增长就更加难了,但如今的今日头条规模和流量已经非常大了。 我们...

原创小博客 ⋅ 35分钟前 ⋅ 0

MyBatis四大核心概念

本文讲解 MyBatis 四大核心概念(SqlSessionFactoryBuilder、SqlSessionFactory、SqlSession、Mapper)。 MyBatis 作为互联网数据库映射工具界的“上古神器”,训有四大“神兽”,谓之:Sql...

waylau ⋅ 55分钟前 ⋅ 0

以太坊java开发包web3j简介

web3j(org.web3j)是Java版本的以太坊JSON RPC接口协议封装实现,如果需要将你的Java应用或安卓应用接入以太坊,或者希望用java开发一个钱包应用,那么用web3j就对了。 web3j的功能相当完整...

汇智网教程 ⋅ 今天 ⋅ 0

2个线程交替打印100以内的数字

重点提示: 线程的本质上只是一个壳子,真正的逻辑其实在“竞态条件”中。 举个例子,比如本题中的打印,那么在竞态条件中,我只需要一个方法即可; 假如我的需求是2个线程,一个+1,一个-1,...

Germmy ⋅ 今天 ⋅ 0

Springboot2 之 Spring Data Redis 实现消息队列——发布/订阅模式

一般来说,消息队列有两种场景,一种是发布者订阅者模式,一种是生产者消费者模式,这里利用redis消息“发布/订阅”来简单实现订阅者模式。 实现之前先过过 redis 发布订阅的一些基础概念和操...

Simonton ⋅ 今天 ⋅ 0

error:Could not find gradle

一.更新Android Studio后打开Project,报如下错误: Error: Could not find com.android.tools.build:gradle:2.2.1. Searched in the following locations: file:/D:/software/android/andro......

Yao--靠自己 ⋅ 昨天 ⋅ 0

Spring boot 项目打包及引入本地jar包

Spring Boot 项目打包以及引入本地Jar包 [TOC] 上篇文章提到 Maven 项目添加本地jar包的三种方式 ,本篇文章记录下在实际项目中的应用。 spring boot 打包方式 我们知道,传统应用可以将程序...

Os_yxguang ⋅ 昨天 ⋅ 0

常见数据结构(二)-树(二叉树,红黑树,B树)

本文介绍数据结构中几种常见的树:二分查找树,2-3树,红黑树,B树 写在前面 本文所有图片均截图自coursera上普林斯顿的课程《Algorithms, Part I》中的Slides 相关命题的证明可参考《算法(第...

浮躁的码农 ⋅ 昨天 ⋅ 0

android -------- 混淆打包报错 (warning - InnerClass ...)

最近做Android混淆打包遇到一些问题,Android Sdutio 3.1 版本打包的 错误如下: Android studio warning - InnerClass annotations are missing corresponding EnclosingMember annotation......

切切歆语 ⋅ 昨天 ⋅ 0

eclipse酷炫大法之设置主题、皮肤

eclipse酷炫大法 目前两款不错的eclipse 1.系统设置 Window->Preferences->General->Appearance 2.Eclipse Marketplace下载【推荐】 Help->Eclipse Marketplace->搜索‘theme’进行安装 比如......

anlve ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部