如何在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。