文档章节

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

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

在处理了我们应用的代码之后,就会再次进入Play框架的范围,我们就接着说下一个请求的下半生。 在Controller中定义一系列的render方法:

屏幕快照 2015-07-31 07.25.46 AM

可以对应到play.mvc.results包中各种Render开头的类: 

屏幕快照 2015-07-31 07.26.40 AM 

重点在RenderTemplate中。

public class Controller implements ControllerSupport, LocalVariablesSupport {
...
    protected static String template() {
        final Request theRequest = Request.current();
        final String format = theRequest.format;
        String templateName = theRequest.action.replace(".", "/") + "." + (format == null ? "html" : format);
        if (templateName.startsWith("@")) {
            templateName = templateName.substring(1);
            if (!templateName.contains(".")) {
                templateName = theRequest.controller + "." + templateName;
            }
            templateName = templateName.replace(".", "/") + "." + (format == null ? "html" : format);
        }
        return null == templateNameResolver ? templateName : templateNameResolver.resolveTemplateName(templateName);
    }
...
}

当我们用render方法,没有写模版名称时,在play.mvc。Controller:template()方法中play会依据request中action名称等参数构建template路径。

public class TemplateLoader {
    ...
    public static BaseTemplate load(String key, String source) {
        if (!templates.containsKey(key) || templates.get(key).compiledTemplate == null) {
            BaseTemplate template = new GroovyTemplate(key, source);
            if (template.loadFromCache()) {
                templates.put(key, template);
            } else {
                templates.put(key, new GroovyTemplateCompiler().compile(template));
            }
        } else {
            BaseTemplate template = new GroovyTemplate(key, source);
            if (Play.mode == Play.Mode.DEV) {
                templates.put(key, new GroovyTemplateCompiler().compile(template));
            }
        }
        if (templates.get(key) == null) {
            throw new TemplateNotFoundException(key);
        }
        return templates.get(key);
    }
    ...
}

我们可以看到,最后会用GroovyTemplate封装读到的template文件。然后当作异常抛出。ActionInvoker.invoke捕捉到。

public class ActionInvoker {
    ...
    public static void invoke(Http.Request request, Http.Response response) {
        Monitor monitor = null;
        try {
            ....
            try {
                ...
                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) {
                        ...
                    }
                }

                // @After
                handleAfters(request);

                monitor.stop();
                monitor = null;
                // OK, re-throw the original action result
                if (actionResult != null) {
                    throw actionResult;
                }
                throw new NoResult();
            } catch (...) {
                ...
            }

        } catch (Result result) {
            Play.pluginCollection.onActionInvocationResult(result);
            Scope.Session.current().save();
            Scope.Flash.current().save();
            result.apply(request, response);
            Play.pluginCollection.afterActionInvocation();
            // @Finally
            handleFinallies(request, null);
        } catch (...) {
            ...
        } finally {
            ...
        }
    }
    ...
}

其中 result.apply(request, response);是第二张图中所显示的所有结果类都覆写的方法,如play.mvc.results中,直接将结果写到response中。

public class RenderTemplate extends Result {
    ...
    public void apply(Request request, Response response) {
        try {
            final String contentType = MimeTypes.getContentType(name, "text/plain");
            response.out.write(content.getBytes(getEncoding()));
            setContentTypeIfNotSet(response, contentType);
        } catch (Exception e) {
            throw new UnexpectedException(e);
        }
    }
    ...
}

play之后会处理After注解的方法。将发出调用结束的事件onActionInvocationResult,ValidationPlugin会响应。最后是处理Finally注解。 回到JPA中来,Play将处理事务。并判定是否要回滚事务。

public class JPA {
    ...
    public static  T withTransaction(String dbName, boolean readOnly, F.Function0 block) throws Throwable {
        if (isEnabled()) {
            boolean closeEm = true;
            // For each existing persisence unit
           
            try {
                ...

                T result = block.apply();
              
                boolean rollbackAll = false;
                // Get back our entity managers
                // Because people might have mess up with the current entity managers
                for (JPAContext jpaContext : get().values()) {
                    EntityManager m = jpaContext.entityManager;
                    EntityTransaction localTx = m.getTransaction();
                    // The resource transaction must be in progress in order to determine if it has been marked for rollback
                    if (localTx.isActive() && localTx.getRollbackOnly()) {
                        rollbackAll = true;
                    }
                }

                for (JPAContext jpaContext : get().values()) {
                    EntityManager m = jpaContext.entityManager;
                    boolean ro = jpaContext.readonly;
                    EntityTransaction localTx = m.getTransaction();
                    // transaction must be active to make some rollback or commit
                    if (localTx.isActive()) {
                        if (rollbackAll || ro) {
                            localTx.rollback();
                        } else {
                            localTx.commit();
                        }
                    }
                }
                return result;
            } catch (...) {
                ....
            } finally {
                ...
            }      
        } else {
            return block.apply();
        }
    }
    ...
}

再回到Invoker中,after中发出afterInvocation事件,onSuccess以及onInvocationSuccess事件。

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;
                    }
                });

                if(!withinFilterFctFound){
                    execute();
                }
                after();
                onSuccess();
            }
        } catch (Suspend e) {
            suspend(e);
            after();
        } catch (Throwable e) {
            onException(e);
        } finally {
            _finally();
        }
    }
    ...
}

play框架大体就处理结束。一个访问的旅程结束了。

© 著作权归作者所有

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

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

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

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

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

刀狂剑痴 ⋅ 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

打造自己的Android源码学习环境之四:下载Android源代码

打造自己的Android源码学习环境之四:下载Android源代码 下载android代码的全部指导来自:http://source.android.com/source/index.html。 如果你访问不了这个网址,可以看看这个链接。 注意...

u013553529 ⋅ 2017/02/05 ⋅ 0

Play框架拾遗之四:域模型与JPA支持

1、属性模拟 对于model,Play中字段都是public修饰符,但框架会自动生成setter与getter如: @Entity@Table(name="product ")public class Product extends BaseModel{ @Id public Long id; ......

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

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

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

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

Play源码深入之六:数据库与事务管理

由前面的文章大致知道,Play的事务由过滤器中处理,这里理一下Play框架与数据库相关的部分。 主要是play.db包中的DBPlugin/DB类,与play.db.jpa包中的JPAPlugin/JPA类有关,前者管理数据源,...

刀狂剑痴 ⋅ 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

【Android游戏开发十四】深入Animation,在SurfaceView中照样使用Android—Tween Animation!

李华明Himi 原创,转载务必在明显处注明: 转载自【黑米GameDev街区】 原文链接: http://www.himigame.com/android-game/331.html 很多童鞋说我的代码运行后,点击home或者back后会程序异常,...

迷途d书童 ⋅ 2012/03/19 ⋅ 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

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Java序列化和反序列化

1、什么是序列化和反序列化 序列化:把对象转换为字节序列的过程。 反序列化:把字节序列恢复成对象的过程。 2、被序列化的类需要实现serializable接口,只是为了标注该对象是可以被序列化的...

IT-Mamba ⋅ 3分钟前 ⋅ 0

流式构建原理

流式构建需要达到分钟级的数据更新频率,Kylin采用类似于Spark Streaming的做法,每隔数分钟进行一次微构建。这边的构建需要考虑到一个延迟因素,分布式网络存在延迟等因素,该时间段的数据有...

无精疯 ⋅ 4分钟前 ⋅ 0

在maven项目工程编写solr代码,需要的依赖

solrJ <dependency> <groupId>org.apache.solr</groupId> <artifactId>solr-solrj</artifactId> <version>6.6.2</version> </dependency> <dependency> <groupId>org.apache.httpcomponents<......

爱运动的小乌龟 ⋅ 10分钟前 ⋅ 0

Spring Cloud Config

Spring Cloud Config application.yml 和 bootstrap.yml 区别 加载顺序 bootstrap.yml 先加载 application.yml 后加载 bootstrap.yml 用于应用程序上下文的引导阶段。 bootstrap.yml 由父 Sp...

施长成 ⋅ 20分钟前 ⋅ 0

MapReduce V2——YARN调度

一、MapReduce的局限性 1、JobTracker的单点问题 2、TaskTracker的作业信息分配的过于简单,当有资源消耗较大的或者时间较长的Task分配在同一个节点上的时候,容易失败或者等待时间过长 3、作...

cjxcloud ⋅ 22分钟前 ⋅ 0

EOS踩坑--脆弱的数据库

安装EOS我就不在这赘述了,来唠唠EOS踩到的坑,跟着官方文档走,然后到了同步数据的时候,Ctrl+Z结束了之后,再次运行报错 root@ubuntu:~# nodeos -e -p eosio --plugin eosio::chain_api_pl...

开源首席鉴黄师 ⋅ 22分钟前 ⋅ 0

对于程序员的招聘问题,作为软件人的一些吐槽和建议

作为软件人,找工作有时候似乎挺苦逼的。 说真的,让我去掉前面这句中“似乎”二字吧。就是苦逼!很多人都曾抱怨处在招聘的一方很糟糕——我们没有任何可靠的方式来甄别会写代码并且写得好的...

老道士 ⋅ 37分钟前 ⋅ 0

Linux下MySQL表名不区分大小写的设置方法(抄袭别人的)

Linux下MySQL表名不区分大小写的设置方法 MySQL表名不区分大小写的设置方法 在用centox安装mysql后,把项目的数据库移植了过去,发现一些表的数据查不到,排查了一下问题,最后发现是表名的大...

随风而浮沉 ⋅ 46分钟前 ⋅ 0

ubuntu下安装宋体simsun

sudo cp simsun.ttc /usr/share/fonts cd /usr/share/fonts sudo chmod 644 simsun.ttc 更新字体缓存: 代码: sudo mkfontscale 代码: sudo mkfontdir 代码: sudo fc-cache -fsv 安装chrome扩......

wangxuwei ⋅ 47分钟前 ⋅ 0

利用 ssh 传输文件

Linux 下一般可以用 scp 命令通过 ssh 传送文件: #把服务器上的 /home/user/a.txt 发送到本机的 /var/www/local_dir 目录下scp username@servername:/home/user/a.txt /var/www/local_dir...

大灰狼时间 ⋅ 58分钟前 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部