如何在Quartz作业中执行Struts 2 Action。如何获得集装箱？

Question

我想从Quartz工作内部执行一个Struts2 Action - 从任何不是处理HTTP请求的上下文中推广。

我从这里开始http://struts.apache.org/2.0.6/docs/how-can-we-schedule-quartz-jobs.html但文件似乎已经过时了。

我相信，（但我可能是错的）我煮下来到需要获得容器对象：

import java.util.HashMap; 
import com.opensymphony.xwork2.ActionProxy; 
import com.opensymphony.xwork2.DefaultActionProxyFactory; 

... 

HashMap ctx = new HashMap(); 
DefaultActionProxyFactory factory= new DefaultActionProxyFactory(); 
factory.setContainer(HOW DO I GET THE CONTAINER??); 
ActionProxy proxy = factory.createActionProxy("", "scheduled/myjob", ctx); 

一个解决方案是发出一个HTTP请求（通过TCP）对本地主机。我宁愿避免这种情况。

Answer 1

我有些担心提供这个答案的内容可能会鼓励一些人去做，但是作为一个概念的证明，并且实际上为任何人提供了一个解决方案，无论出于什么原因（也许他们正在继承一些应用程序，是否需要？），需要在正常请求上下文之外执行Struts2操作。

但是，这里是原始（它是作为一个起点，而不是一个最优的实现），但工作，解决方法：

首先，这三个类添加到一个名为com.stackoverflow.struts2包。石英：

一个简单的工作，只是要求对于给定的工作方面的代理，并执行它：

package com.stackoverflow.struts2.quartz; 

import org.quartz.Job; 
import org.quartz.JobExecutionContext; 
import org.quartz.JobExecutionException; 

public class ActionJob implements Job { 

    @Override 
    public void execute(JobExecutionContext context) throws JobExecutionException { 

     try { 
      QuartzActionProxyFactory.getActionProxy(context).execute(); 
     } catch (Exception e) { 
      e.printStackTrace(); 
      throw new JobExecutionException(e); 
     } 

    } 

} 

一些常数绕过动作细节：

package com.stackoverflow.struts2.quartz; 

public class QuartzActionConstants { 

    public static final String NAMESPACE = "struts.action.namespace"; 
    public static final String NAME = "struts.action.name"; 
    public static final String METHOD = "struts.action.method"; 

} 

，可以静态地从ActionJob访问自定义ActionProxyFactory：

package com.stackoverflow.struts2.quartz; 

import java.util.HashMap; 
import java.util.Map; 

import org.apache.struts2.impl.StrutsActionProxyFactory; 
import org.quartz.JobExecutionContext; 
import org.quartz.JobExecutionException; 

import com.opensymphony.xwork2.ActionContext; 
import com.opensymphony.xwork2.ActionProxy; 
import com.opensymphony.xwork2.ActionProxyFactory; 

public class QuartzActionProxyFactory extends StrutsActionProxyFactory { 

    private static ActionProxyFactory actionProxyFactory; 

    public QuartzActionProxyFactory() { 
     actionProxyFactory = this; 
    } 

    public static ActionProxy getActionProxy(JobExecutionContext context) throws JobExecutionException { 

     ActionProxy actionProxy = null; 

     try { 
      @SuppressWarnings("unchecked") 
      Map<String, Object> actionParams = context.getJobDetail().getJobDataMap(); 
      Map<String, Object> actionContext = new HashMap<String, Object>(); 
      actionContext.put(ActionContext.PARAMETERS, actionParams); 

      actionProxy = actionProxyFactory.createActionProxy(
        (String) actionParams.get(QuartzActionConstants.NAMESPACE), 
        (String) actionParams.get(QuartzActionConstants.NAME), 
        (String) actionParams.get(QuartzActionConstants.METHOD), 
        actionContext, 
        false, //set to false to prevent execution of result, set to true if this is desired 
        false); 

     } catch (Exception e) { 
      throw new JobExecutionException(e); 
     } 

     return actionProxy; 
    } 

} 

然后，在你的struts.xml中，添加：

<bean name="quartz" type="com.opensymphony.xwork2.ActionProxyFactory" class="com.stackoverflow.struts2.quartz.QuartzActionProxyFactory"/> 
<constant name="struts.actionProxyFactory" value="quartz"/> 

然后你就可以安排动作执行一些简单的代码：

SchedulerFactory sf = new StdSchedulerFactory(); 
Scheduler scheduler = sf.getScheduler(); 
scheduler.start(); 
JobDetail jobDetail = new JobDetail("someActionJob", Scheduler.DEFAULT_GROUP, ActionJob.class); 

@SuppressWarnings("unchecked") 
Map<String, Object> jobContext = jobDetail.getJobDataMap(); 
jobContext.put(QuartzActionConstants.NAMESPACE, "/the/action/namespace"); 
jobContext.put(QuartzActionConstants.NAME, "theActionName"); 
jobContext.put(QuartzActionConstants.METHOD, "theActionMethod"); 

Trigger trigger = new SimpleTrigger("actionJobTrigger", Scheduler.DEFAULT_GROUP, new Date(), null, SimpleTrigger.REPEAT_INDEFINITELY, 1000L); 
scheduler.deleteJob("someActionJob", Scheduler.DEFAULT_GROUP); 
scheduler.scheduleJob(jobDetail, trigger); 

就是这样。这段代码将导致无限期地每秒执行一次该操作，拦截器将全部触发并且依赖关系将被注入。当然，依赖于Servlet对象（如HttpServletRequest）的任何逻辑或拦截器都无法正常运行，但是无论如何，将这些操作安排在servlet上下文之外没有任何意义。

Answer 2

你不需要HttpServletRequest来在freemarker中格式化电子邮件。看到下面的答案。

Create multi-part message in MIME format Freemarker template via Spring 3 JavaMail

用于发送邮件，使用了Spring可以注入邮件组件添加到您的石英工作。即使有RequestContextHolder类来检索HttpServlet请求，您也不会从Quartz作业获得HttpServletRequest。