velocitycontroller2.java

这是我自己开发的一个MVC框架

package dark.web.frame.velocity.controller.bak;

/**
 * <p>Title:            支持Velocity的控制器</p>
 * <p>Description:      根据org.apache.velocity.servlet.VelocityServlet进行修改，
 * 						从而将Velocity整合进dwf框架</p>
 * <p>Copyright:        Copyright (c) 2005</p>
 * <p>Company:          DIS</p>
 * <p>Create Time:      2005-2-28 16:24:43</p>
 * @author             <a href="mailto:[e-mail]">darkhe</a>
 * @version            1.0
 */

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import dark.web.frame.Controller;
import dark.web.frame.controller.FrontController;
import dark.web.frame.velocity.command.VelocityCommand;
import dark.web.frame.velocity.form.VelocityForm;
import dark.web.frame.velocity.page.UnknownVelocityPage;
import dark.web.frame.velocity.page.VelocityPage;

import org.apache.velocity.app.Velocity;
import org.apache.velocity.runtime.RuntimeSingleton;
import org.apache.velocity.util.SimplePool;

public abstract class VelocityController2
	extends FrontController
	implements Controller
{
	/**
	 * The context key for the HTTP request object.
	 */
	public static final String REQUEST = "req";

	/**
	 * The context key for the HTTP response object.
	 */
	public static final String RESPONSE = "res";

	/**
	 * The HTTP content type context key.
	 */
	public static final String CONTENT_TYPE = "default.contentType";

	/**
	 *  The default content type for the response
	 */
	public static final String DEFAULT_CONTENT_TYPE = "text/html";

	/**
	 *  Encoding for the output stream
	 */
	public static final String DEFAULT_OUTPUT_ENCODING = "ISO-8859-1";

	/**
	 * The default content type, itself defaulting to {@link
	 * #DEFAULT_CONTENT_TYPE} if not configured.
	 */
	public static String defaultContentType;

	/**
	 * This is the string that is looked for when getInitParameter is
	 * called (<code>org.apache.velocity.properties</code>).
	 */
	protected static final String INIT_PROPS_KEY =
		"org.apache.velocity.properties";

	/**
	 * Cache of writers
	 */

	public static SimplePool writerPool = new SimplePool(40);

	/**
	 * Velocity配置文件路径，default设定为CLASSPATH根目录下的velocity.properties
	 */
	public static final String PROPS_FILE = "/velocity.properties";

	/**
	 * 初始化Velocity引擎
	 */
	private void initVelocity()
	{
		try
		{
			InputStream is =
				VelocityController2.class.getResourceAsStream(PROPS_FILE);

			Properties p = new Properties();

			p.load(is);
			/*
			 *  now, lets get the two elements we care about, the 
			 *  template path and the log, and fix those from relative
			 *  to the webapp root, to absolute on the filesystem, which is
			 *  what velocity needs
			 */

			String path = p.getProperty("file.resource.loader.path");

			if (path != null)
			{
				path = getServletContext().getRealPath(path);
				log.info("file.resource.loader.path=" + path);

				p.setProperty("file.resource.loader.path", path);
			}

			path = p.getProperty("runtime.log");

			if (path != null)
			{
				path = getServletContext().getRealPath(path);
				log.info("runtime.log=" + path);

				p.setProperty("runtime.log", path);
			}

			Velocity.init(p);

			log.info("初始化Velocity引擎成功......");
		}
		catch (IOException e)
		{
			log.error("初始化Velocity引擎出错", e);
		}
		catch (Exception e)
		{
			log.error("初始化Velocity引擎出错", e);
		}

		/*
		 *  Now that Velocity is initialized, cache some config.
		 */
		defaultContentType =
			RuntimeSingleton.getString(CONTENT_TYPE, DEFAULT_CONTENT_TYPE);

	}

	/**
	 * 
	 * @param request
	 * @param response
	 * @throws ServletException
	 * @throws IOException
	 * @see dark.web.frame.Controller#doRequest(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
	 */
	public void doRequest(
		HttpServletRequest request,
		HttpServletResponse response)
		throws ServletException, IOException
	{
		// 获取page.postfix和command.postfix
		// 从而根据用户的请求后缀的不同调用页面处理程序或者命令处理程序
		String page_postfix = configuration.getString("page.postfix");
		String command_postfix = configuration.getString("command.postfix");

		if (page_postfix.equals(getRequestPostfix(request)))
			// 调用页面处理程序		
		{

			String uri = request.getRequestURI();

			VelocityPage page = getVelocityPage((HttpServletRequest) request);

			// 初始化页面类
			page.init(
				getServletContext(),
				getServletConfig(),
				request,
				response);

			// 设置velocity模版
			page.setTarget(uri);

			// 检证页面类的执行权限
			if (page.isAuthentic())
			{
				// 执行真实的商业逻辑
				page.process();
			}
		}
		else if (command_postfix.equals(getRequestPostfix(request)))
			// 调用命令处理程序		
		{
			// 如果要求做表单验证，则处理之
			if (isValidate(request))
			{

				String input = getInput(request);

				// 如果用户没有指定请求转发路径，则指定default value
				if (input.equals(""))
				{
					input = configuration.getString("default.input");

					log.warn(
						"dont't specify parameter $INPUT, use default.input:"
							+ input);
					request.setAttribute(
						"$WARM",
						"dont't specify parameter $INPUT, use default.input"
							+ input);
				}

				VelocityForm form = getVelocityForm(request);

				// 初始化表单验证类
				form.init(getServletContext(), request, response, getMessage());

				// 设置当前表单验证的用户请求转发路径
				form.setInput(input);

				// 检证表单验证类的执行权限
				if (form.isAuthentic())
				{
					// 执行实际的验证操作
					form.validate(request, response);

					if (!form.isPass())
					{
						// 如果isPass()返回false，
						// 则说明验证出表单错误，
						// 立即停止程序处理
						//log.debug("表单验证失败");													
						return;
					}
					//log.debug("表单验证成功");
					//log.debug("form.isPass()=" + form.isPass());	
				}
			}

			String target = getTarget(request);

			// 如果用户没有指定请求转发路径，则指定default value
			if (target.equals(""))
			{
				target = configuration.getString("default.target");

				log.warn(
					"don't specify paramter $TARGER, use default.target:"
						+ target);
				request.setAttribute(
					"$WARM",
					"don't specify paramter $TARGER, use default.target:"
						+ target);
			}

			VelocityCommand command = getVelocityCommand(request);

			// 初始化命令类
			command.init(
				getServletContext(),
				getServletConfig(),
				request,
				response);

			// 设置当前命令的用户请求转发路径
			command.setTarget(target);

			// 检证命令类的执行权限
			if (command.isAuthentic())
			{
				// 执行真实的商业逻辑
				command.process();
			}
		}

	}

	/**
	 * @throws javax.servlet.ServletException
	 * @see javax.servlet.GenericServlet#init()
	 */
	public void init() throws ServletException
	{
		super.init();
		initVelocity();
	}

	/**
	 * @param request
	 * @return
	 */
	protected VelocityForm getVelocityForm(HttpServletRequest request)
		throws ServletException
	{
		try
		{
			return (VelocityForm) getFormClass(request).newInstance();
		}
		catch (Exception e)
		{
			throw new ServletException(e);
		}
	}

	/**	
	 * @param req
	 * @return
	 */
	protected VelocityCommand getVelocityCommand(HttpServletRequest request)
		throws ServletException
	{
		try
		{
			return (VelocityCommand) getCommandClass(request).newInstance();
		}
		catch (Exception e)
		{
			throw new ServletException(e);
		}
	}

	/**
	 * @param request
	 * @return
	 */
	protected VelocityPage getVelocityPage(HttpServletRequest request)
		throws ServletException
	{
		try
		{
			return (VelocityPage) getVelocityPageClass(request).newInstance();
		}
		catch (Exception e)
		{
			throw new ServletException(e);
		}
	}

	/**
	 * 通过类名串值到得类对象
	 * @param req
	 */
	protected Class getVelocityPageClass(HttpServletRequest request)
	{
		Class result = null;

		String cp = configuration.getString("page.package");

		String pageName = getPageName(request);
		String pageClassName = cp + "." + pageName;

		try
		{
			result = Class.forName(pageClassName);
		}
		catch (ClassNotFoundException e)
		{
			log.info(
				"class:"
					+ pageClassName
					+ " not found, return UnknownVelocityPage.class");
			result = UnknownVelocityPage.class;
		}

		return result;
	}
}