文档章节

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

奋斗到天明
 奋斗到天明
发布于 2015/08/27 18:12
字数 1144
阅读 381
收藏 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;
        Transaction