码迷,mamicode.com
首页 > 其他好文 > 详细

struct2源码解读(9)之处理Action请求

时间:2015-11-17 06:54:27      阅读:191      评论:0      收藏:0      [点我收藏+]

标签:struct2 prepareoperations 处理action请求

struct2源码解读之处理Action请求

   我们前面讨论过了struct2的初始化,我们先来回顾下

 public void init(FilterConfig filterConfig) throws ServletException {
        InitOperations init = new InitOperations();
        try {
            FilterHostConfig config = new FilterHostConfig(filterConfig);
            init.initLogging(config);
            //解析配置文件,并返回一个封装了封装配置信息的Dispacher对象
            Dispatcher dispatcher = init.initDispatcher(config);
            init.initStaticContentLoader(config, dispatcher);
           //返回一个处理action请求的对象
           prepare = new PrepareOperations(filterConfig.getServletContext(), dispatcher);
           //返回一个执行action请求的对象
           execute = new ExecuteOperations(filterConfig.getServletContext(), dispatcher);
           //黑名单列表
	   this.excludedPatterns = init.buildExcludedPatternsList(dispatcher);

            postInit(dispatcher, filterConfig);
        } finally {
            init.cleanup();
        }
    }

    从上面可以看出,struct2的初始化其实就是封装配置文件信息到Disacher对象,然后根据这个对象实例化两个对象:一个是用来处理action请求的PrepareOperations对象;一个是用来执行action请求的

ExecuteOperations对象,当有request请求的时候,就会调用这两个对象的方法来处理和执行请求。我们知道,当客户端放送请求的时候,会执行过滤器的doFilter()方法。我们来看看,StrutsPrepareAndExecuteFilter的doFilter()方法。

   public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException, ServletException {

        HttpServletRequest request = (HttpServletRequest) req;
        HttpServletResponse response = (HttpServletResponse) res;
         //1.处理aciton请求
        try {
            
             //设置编码和本地化信息
            prepare.setEncodingAndLocale(request, response);
            //创建actionContext上下文
            prepare.createActionContext(request, response);
            //把dispacher添加到线程
            prepare.assignDispatcherToThread();
            //判断是否在黑名单内
if ( excludedPatterns != null && prepare.isUrlExcluded(request, excludedPatterns)) {
                            //在黑名单,跳过,转到下一个过滤器
				chain.doFilter(request, response);
	} else {
	    //处理request请求
	    request = prepare.wrapRequest(request);
	  ActionMapping mapping = prepare.findActionMapping(request, response, true);
	  //如果找不到这个action
	  if (mapping == null) {
	     //执行静态文件
	  boolean handled = execute.executeStaticResourceRequest(request, response);
		if (!handled) {
		       //如果找不到这个静态文件,跳过,转到下一个过滤器
			chain.doFilter(request, response);
		}
	  } else {
	       //2.找到action就执行action请求
		execute.executeAction(request, response, mapping);
		}
	  }
        } finally {
            prepare.cleanupRequest(request);
        }
    }

      初始化为我们准备了PrepareOperations对象和ExecuteOperations对象还有Dispacher,我们下面来看看struct2是如何利用这些对象处理action请求的。这里分两步,一步是处理aciton请求,包括解析url和找到action对应的方法;另一步是执行这个action的方法。


一、处理aciton请求(PrepareOperations对象)

     处理aciton请求,都是调用PrepareOperations对象的方法来进行处理。


1.1.设置编码和国际化信息  

prepare.setEncodingAndLocale(request, response);

   在PrepareOperations.setEncodingAndLocale()方法中调用了dispatcher.prepare()方法,在这个方法中设置了编码信息和国际化信息。

public void prepare(HttpServletRequest request, HttpServletResponse response) {
        String encoding = null;
        /**
         * @Inject(StrutsConstants.STRUTS_I18N_ENCODING)
         * public void setDefaultEncoding(String val) {
         *          defaultEncoding = val;
         *  }
         *编码为xml中STRUTS_I18N_ENCODING中设置的值,默认为utf-8
         */
    
        if (defaultEncoding != null) {
            encoding = defaultEncoding;
        }     
        Locale locale = null;
        /**
         * @Inject(value=StrutsConstants.STRUTS_LOCALE, required=false)
         *   public void setDefaultLocale(String val) {
         *   defaultLocale = val;
         *  }
         *国际化信息为STRUTS_LOCALE中设置的值,默认不设置
         */
        if (defaultLocale != null) {
        locale = LocalizedTextUtil.localeFromString(defaultLocale, request.getLocale());
        }
        if (encoding != null) {
            try {
            //设置编码
                request.setCharacterEncoding(encoding);
            } //异常信息
        }

        if (locale != null) {
        //设置国际化信息
            response.setLocale(locale);
        }
        if (paramsWorkaroundEnabled) {
            request.getParameter("foo"); 
        }
    }

   在初始化的时候,通过container.inject(this)对dispacher进行了依赖注入,defaultEncoding和defaultLocale都标有@inject注解,这两个值就在这个时候设置好了。前面解析配置文件的时候,把这些值以key-value封装到了propertyContainer对象中,因此依赖注入的时候,通过value=key找到这些值并进行赋值。


1.2.创建actionContext上下文

prepare.createActionContext(request, response);

   actionContext,顾名思义,指的是action请求的环境

 public ActionContext createActionContext(HttpServletRequest request, HttpServletResponse response) {
        ActionContext ctx;
        //计数器,初始值为1,一次请求+1,请求执行完后保存到request的CLEANUP_RECURSION_COUNTER变量中
        Integer counter = 1;
        Integer oldCounter = (Integer) request.getAttribute(CLEANUP_RECURSION_COUNTER);
        if (oldCounter != null) {
            counter = oldCounter + 1;
        }
        //从线程变量ThreadLocal中取出ActionContext 
        ActionContext oldContext = ActionContext.getContext();
        if (oldContext != null) {
            // detected existing context, so we are probably in a forward
        ctx = new ActionContext(new HashMap<String, Object>(oldContext.getContextMap()));
        } else {
            //实例化一个值栈对象
            ValueStack stack = dispatcher.getContainer().getInstance(ValueStackFactory.class).createValueStack();
            stack.getContext().putAll(dispatcher.createContextMap(request, response, null, servletContext));
            ctx = new ActionContext(stack.getContext());
        }
        //保存计数器的值
        request.setAttribute(CLEANUP_RECURSION_COUNTER, counter);
        //把actionContext保存到线程变量ThreadLocal中
        ActionContext.setContext(ctx);
        return ctx;
    }

   actionContext是一个Theadloacl类型,因此每个请求都是线程安全的。通过get()和set()对这个变量进行存取值。在创建actionContext的过程中,实例化了一个valueStack值栈对象。通过 dispatcher.getContainer()获得Container,然后通过Container.getInstance()取出容器中的对象,这个ValueStackFactory在strcut2-default.xml中就已配置好了。

<bean type="com.opensymphony.xwork2.util.ValueStackFactory" name="struts" class="com.opensymphony.xwork2.ognl.OgnlValueStackFactory" />

  查看OgnlValueStackFactory对象的createValueStack()方法

 public ValueStack createValueStack() {
         //实例化一个ValueStack对象 
        ValueStack stack = new OgnlValueStack(xworkConverter, compoundRootAccessor, textProvider, allowStaticMethodAccess);
        //对valuestack依赖注入
        container.inject(stack);
        //把container以一个map的形式保存到valuestack的context 属性中
        stack.getContext().put(ActionContext.CONTAINER, container);
        return stack;
    }

    值栈的context其实就是一个map,除了把container放进这个map中

dispatcher.createContextMap(request, response, null, servletContext)

   这句话也把request,response,servletContext,application,session,params也放进了context这个map中.由此看出,struct2把所有值都放进了值栈valueStack.context中,而context是actionContext的一个属性,因此这个actionContext就涵盖了struct2运行所需的值,也就搭起了struct2的运行环境。


1.3.添加到线程

 prepare.assignDispatcherToThread();

   这句话,其实是把dispacher设置到一个线程变量ThreadLoacl<dispacher>中

 private static ThreadLocal<Dispatcher> instance = new ThreadLocal<Dispatcher>();
 public static void setInstance(Dispatcher instance) {
        Dispatcher.instance.set(instance);
    }


1.4.判断是否是黑名单

if ( excludedPatterns != null && prepare.isUrlExcluded(request, excludedPatterns)) {
    //如果设置了黑名单而且在请求在黑名单内,跳过,执行下一个过滤器
	chain.doFilter(request, response);
} else {
   //如果没设置黑名单或者是不在黑名单内,处理aciton请求
	
}

    这个excludedPatterns是一个list<Pattern>集合,是一个正则表达式经编译后的表现模式.在struct2初始化的时候,我们对这个值进行设定

this.excludedPatterns = init.buildExcludedPatternsList(dispatcher);

    而这个黑名单,来源于我们在strcuts.xml文件中对struts.action.excludePattern的配置

public List<Pattern> buildExcludedPatternsList( Dispatcher dispatcher ) {
         //获得struts.action.excludePattern的值
        return buildExcludedPatternsList(dispatcher.getContainer().getInstance(String.class, StrutsConstants.STRUTS_ACTION_EXCLUDE_PATTERN));
    }

   dispatcher.getContainer()获得Container,然后通过Container.getInstance()取出容器中的struts.action.excludePattern,这个在我们解析*.xml的时候已封装好。然后把这个值进一步封装到list<Pattern> 中

 private List<Pattern> buildExcludedPatternsList( String patterns ) {
        if (null != patterns && patterns.trim().length() != 0) {
            List<Pattern> list = new ArrayList<Pattern>();
            //以逗号分隔
            String[] tokens = patterns.split(",");
            //循环遍历
            for ( String token : tokens ) {
                  //编译一个正规表达式,并把编译结果添加到一个list集合中
                list.add(Pattern.compile(token.trim()));
            }
            return Collections.unmodifiableList(list);
        } else {
            return null;
        }
    }

    如果设置了黑名单,把黑名单填加到一个list集合中后,PrepareOperations提供了一个isUrlExcluded()方法来对黑名单进行筛选

public boolean isUrlExcluded( HttpServletRequest request, List<Pattern> excludedPatterns ) {     //如果设置了黑名单
        if (excludedPatterns != null) {
           //获得请求url
            String uri = getUri(request);
            //循环遍历
            for ( Pattern pattern : excludedPatterns ) {
                //pattern.matcher(uri)生成一个给定命名的Matcher对象,调用该对象的matches()方法进行匹配检测,只有整个目标字符串完全匹配时才返回真值
                if (pattern.matcher(uri).matches()) {
                    return true;
                }
            }
        }
        return false;
    }


1.5.处理request请求

   如果通过了黑名单的匹配检测,则处理request请求

request = prepare.wrapRequest(request);

   我们知道,普通的request请求和文件上传时的request请求时的request请求类型是不一样的,这一步就是对不同类型的request请求,进行封装

   public HttpServletRequest wrapRequest(HttpServletRequest request, ServletContext servletContext) throws IOException {
        // 默认为StrutsRequestWrapper类型
        if (request instanceof StrutsRequestWrapper) {
            return request;
        }
        //获得request请求的类型
        String content_type = request.getContentType();
        //如果request类型不为空且为multipart/form-data类型
        if (content_type != null && content_type.indexOf("multipart/form-data") != -1) {
            MultiPartRequest mpr = null;
            //check for alternate implementations of MultiPartRequest
        Set<String> multiNames = getContainer().getInstanceNames(MultiPartRequest.class);
            if (multiNames != null) {
                for (String multiName : multiNames) {
                    if (multiName.equals(multipartHandlerName)) {
                     mpr = getContainer().getInstance(MultiPartRequest.class, multiName);
                    }
                }
            }
            if (mpr == null ) {
                mpr = getContainer().getInstance(MultiPartRequest.class);
            }
            //把request封装成MultiPartRequestWrapper对象
        request = new MultiPartRequestWrapper(mpr, request, getSaveDir(servletContext));
        } else {
           //其它的封装成StrutsRequestWrapper对象
            request = new StrutsRequestWrapper(request);
        }

        return request;
    }


1.6.处理action请求


ActionMapping mapping = prepare.findActionMapping(request, response, true);

  当前面设置好编码和黑名单都检测通过后,就开始要处理action请求了,处理action请求,其实就是

把url信息封装到一个actionMapping对象。

public ActionMapping findActionMapping(HttpServletRequest request, HttpServletResponse response, boolean forceLookup) {
        //因为封装后的ActionMapping对象,最后会保存到request的STRUTS_ACTION_MAPPING_KEY变量中,因此在封装前要先判断
        ActionMapping mapping = (ActionMapping) request.getAttribute(STRUTS_ACTION_MAPPING_KEY);
        if (mapping == null || forceLookup) {
            try {
               //获得ActionMapper对象,调用其getMapping()方法封装url信息
                mapping = dispatcher.getContainer().getInstance(ActionMapper.class).getMapping(request, dispatcher.getConfigurationManager());
                 
                if (mapping != null) {
                 //mapping值不为空时,设置到request的STRUTS_ACTION_MAPPING_KEY变量中
                    request.setAttribute(STRUTS_ACTION_MAPPING_KEY, mapping);
                }
            } //异常信息
            }
        }

        return mapping;
    }

    特别注意,ActionMapper是一个操作者,而ActionMapping是一个保存信息的对象,通过ActionMapper.getMapping()方法,获得一个ActionMapping对象

  public ActionMapping getMapping(HttpServletRequest request,
            ConfigurationManager configManager) {
        ActionMapping mapping = new ActionMapping();
        //获得uri,如url="http:\\localhost:8080\playwell\back\login.action",则uri为"playwell\back\login.action?id=1!method"
        String uri = getUri(request);
        //以分号分割
        int indexOfSemicolon = uri.indexOf(";");
        //如果有分号,全第一个分号前面的,否则的话,取原值
        uri = (indexOfSemicolon > -1) ? uri.substring(0, indexOfSemicolon) : uri;
        //删除后缀,extension默认为aciton和"",如果为空,找最后一个“.”,找不到这个点才返回原值,如果是action,判断uri是否endwith action,是的话,取“.”前面的值,然后mapping.setExtension();
        uri = dropExtension(uri, mapping);
        if (uri == null) {
            return null;
        }
        /*
         *
         *设置命名空间和action名。这里对url作逻辑判断,分离出命名空间和action名
         * mapping.setNamespace(namespace);
         * mapping.setName(name);
         *
         */
        parseNameAndNamespace(uri, mapping, configManager);
        //处理params
        handleSpecialParameters(request, mapping);

        if (mapping.getName() == null) {
            return null;
        }
        //mapping.setMethod(),处理!method
        parseActionName(mapping);

        return mapping;
    }

   这一步主要是对url进行解析工作,把url的每一个字段分割出来,并封装到actionMapping对象中,大多都是字符串操作,在这就不过多叙述了,下面附上actionMapping的部分代码以加深大家对这一步操作的理解

public class ActionMapping {

    private String name;  //记录action名
    private String namespace; //记录命名空间
    private String method; //记录!method
    private String extension; //记录后缀
    private Map<String, Object> params;
    private Result result;
    
 }

二、执行action请求

    解析完url,把url封装到actionMapping对象中后,就开始执行action请求。这里又为分actionMapping为空和actionMapping不为空两种情况。什么情况下actionMapping为空呢?我们看回actionMapping的封装过程

        if (uri == null) {
            return null;
        }
        if (mapping.getName() == null) {
            return null;
        }

    当uri地址为空或者是actionname为空时返回一个空的actionMapping对象

2.1.找不到action

    当返回一个空的actionMapping对象时,struct2会寻找静态资源,如果连静态文件都找不到,则会调过当前过滤器,去到下一个过滤器

if (mapping == null) {
            //执行静态资源
	boolean handled = execute.executeStaticResourceRequest(request, response);
	if (!handled) {
	       //跳到下一个过滤器
		chain.doFilter(request, response);
	}
}

    在这个过程中,struct2会加载哪些静态资源呢?

public boolean executeStaticResourceRequest(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
        
        String resourcePath = RequestUtils.getServletPath(request);

        if ("".equals(resourcePath) && null != request.getPathInfo()) {
            resourcePath = request.getPathInfo();
        }
          //取得StaticContentLoader对象
        StaticContentLoader staticResourceLoader = dispatcher.getContainer().getInstance(StaticContentLoader.class);
        if (staticResourceLoader.canHandle(resourcePath)) {
            staticResourceLoader.findStaticResource(resourcePath, request, response);
            //加载静态资源,否则的话抛出404错误。response.sendError(HttpServletResponse.SC_NOT_FOUND);
            return true;

        } else {
            // 给跳到下一个过滤器设置标志
            return false;
        }
    }

     canHandle里面表明,以/structs或者是/static开头的url的静态资源才会被加载。

 public boolean canHandle(String resourcePath) {
        return serveStatic && (resourcePath.startsWith("/struts") || resourcePath.startsWith("/static"));
    }

    

2.2.找到action

    找到action后就开始正常执行action请求。这个在下篇博文继续探讨。


三、总结

   本篇博文探讨了strcut2是如何处理action请求的:利用PrepareOperations对象的方法,设置了编码信息和本地化信息,设置了action的上下文actionContext,并处理了黑名单信息,最后封装了url信息到 actionMapping对象,利用actionMapping对象的去执行相应的请求,如actionMapping为空时就尝试去加载静态资源,不为空就取执行相应的操作。


本文出自 “总有贱人想害朕。” 博客,请务必保留此出处http://yoyanda.blog.51cto.com/9675421/1713317

struct2源码解读(9)之处理Action请求

标签:struct2 prepareoperations 处理action请求

原文地址:http://yoyanda.blog.51cto.com/9675421/1713317

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!