ssh + mysql + quartz - ITeye问答

0 0

ssh + mysql + quartz5

我有一个方法，方法为addUser(int id),而且这个方法同时带有一个参数，当用户登录系统后，就调用这个方法，触发这个方法之后每隔5分钟就自动调用这个方法，直到这个用户退出系统（特别声明的是这个方法每隔5分钟就执行一次，但是不能够影响到其它的操作），想问大家一下如果要想使用quartz来完成这样的功能，我应该怎么来实现啊？？如果不使用quartz来完成，那有没有更好的方法能够完成我这个功能啊？？谢谢大家了！！

问题补充：

songfantasy 写道

我之前总结的东东，看看能不能用上吧。

首先感谢你给我的回答，这样好像不能满足我的要求，我自己写了一个，可是在运行时总是报一个空指针异常，不知道是为什么？？
我代码如下：
java代码：
public class UserTagImpl implements UserTagService, Job {
private TUserTagDAO userTagDao = new TUserTagDAO();

private TUserDynamicsDAO userDynamicsDao = new TUserDynamicsDAO();

private TObjectDAO objectDao = new TObjectDAO();

private TUserObjectsDAO userObjectsDao = new TUserObjectsDAO();

private TObjectSubscriberDAO objectSubscriberDao = null;

private TObjectTagDAO objectTagDao = new TObjectTagDAO();
public void execute(JobExecutionContext context)
throws JobExecutionException {
try {
JobDataMap dataMap = context.getJobDetail().getJobDataMap();
String userid = dataMap.getString("userid");
System.out.println(userid + "aa");
this.addUserObjectAndObject(Integer.parseInt(userid));
} catch (Exception e) {
e.printStackTrace();
}
}}
本来开始时依赖注入的，可是总是报空指针异常，所以我就弄成了实例化
在action中的代码：
public ActionForward login(ActionMapping mapping, ActionForm form,
HttpServletRequest request, HttpServletResponse response) {
UserForm userForm = (UserForm) form;
List list = this.userService.userLogin(userForm.getUser());
TUser user = null;
for (int i = 0; i < list.size(); i++) {
user = (TUser) list.get(i);
}
System.out.println(list.size());
if (user != null) {
//完成商品的推送的功能
try {
startClock(user.getUId()+"");
} catch (Exception e) {
e.printStackTrace();
}

}
return mapping.findForward("success");
}
private void startClock(String userid) throws Exception
{
System.out.println("ok");
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
Date runTime = TriggerUtils.getNextGivenMinuteDate(new Date(), 1);
JobDetail job = new JobDetail(userid,null,UserTagImpl.class);
//CronExpression con = new CronExpression("0 0 5 * * ?");
job.getJobDataMap().put("userid",userid);
//Trigger trigger = TriggerUtils.makeDailyTrigger(0, 0);
Trigger trigger = new CronTrigger(userid,null,"0 0/1 0/1 * * ?");
//trigger.setName(userid);
sched.scheduleJob(job, trigger);
sched.start();
System.out.println("ok");
System.out.println(userid);
}
}
报错内容为：

java.lang.NullPointerException
at com.smenu.struts.dao.TUserDynamicsDAO.getOneTUserDynamicByUId(TUserDynamicsDAO.java:230)
at com.smenu.struts.impl.UserTagImpl.getOneTUserDynamicByUId(UserTagImpl.java:281)
at com.smenu.struts.impl.UserTagImpl.addUserObjectAndObject(UserTagImpl.java:145)
at com.smenu.struts.impl.UserTagImpl.execute(UserTagImpl.java:299)
at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
请求大哥帮忙？

问题补充：这个报错的方法应该是不会有问题的，因为我在别的地方还使用了这个方法，所以不知道这是为什么？为什么会出现这样的错误？

Web综合

2010年9月16日 16:46

zhouqiubo
25
0 0 0

4个答案按时间排序按投票排序

0 0

我之前总结的东东，看看能不能用上吧。

2010年9月16日 19:15

songfantasy
728
0 0 1

添加评论

0 0

B、使用SimpleTriggerBean类只能做简单Job与Job之间的执行周期指定，如果需要在指定时间执行，可以使用CronTriggerBean类。
1、修改ApplicationContext.xml
<!-- 在任务的周期指定上，使用cronTriggerBean类来指定。排定Job用SchedulerFactoryBean类。-->
	<bean id="cronTriggerBean"
		 class="org.springframework.scheduling.quartz.CronTriggerBean">
		  <property name="jobDetail" ref="jobDetailBean"></property>
          <property name="cronExpression" value="0 37-38 15 * * ?"/>
	</bean>

	<bean id="scheduledFactoryBean"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref bean="cronTriggerBean" />
			</list>
		</property>
	</bean>
注意：CronTriggerBean的cronExpression属性指定格式：至少6个时间元素，上面表示每天的15：37-38分执行1次任务。
时间元素（按照顺序）：
秒（0-59）：
分（0-59）：
小时（0-23）：
每月第几天（1-31）：
月（1-12或JAN-DEC）：
每星期第几天（1-7或SUN-SAT）：
年(1970-2099)：
其中:不用设置的用”?”.
(1)	每月第几天和每星期第几天是互斥的，两个只能设置1个。如果有好几个时间点，可以使用”,”符号，例如：”0 0 10,12,14 * * ?”表示每天的10时，12时，14时执行Job.
(2)	对于连续时间可以使用”-”符号。例如：”0 10,12,14 1-15 * ?”表示每月的1到15日10时，12时，14时执行Job.
(3)	时间格式的年可以不用制定。例如”0 0 10,12,14 ? MON 2006”表示2006年每星期一的10时，12时，14时执行Job.

2010年9月16日 19:14

songfantasy
728
0 0 1

添加评论

0 0

Spring中整合Quartz
A	、简单的Trigger定时任务，功能和Timer一样
1、JobData.java  进行业务逻辑处理的类 
public class JobData
{
    public String getData()
    {
        //业务逻辑处理
        return "我的数据"+ new Date().toString();
    }
}
2、MyQuartz.java  定义job类
public class MyQuartz extends QuartzJobBean
{
    private JobData jobData;
    
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException
    {
        System.out.println(jobData.getData() +"is executed");
    }
    public JobData getJobData()
    {
        return jobData;
    }
    public void setJobData(JobData jobData)
    {
        this.jobData = jobData;
    }
}
3、	ApplicationContext.xml
<!-- use Quartz -->
	<bean id="jobData" class="com.huawei.esop.JobData"></bean>

	<bean id="jobDetailBean"
		class="org.springframework.scheduling.quartz.JobDetailBean">
		<property name="jobClass"
			value="com.huawei.esop.MyQuartz">
		</property>
		<!-- Job所需的数据可以在jobDataAsMap属性中设置 -->
		<property name="jobDataAsMap">
			<map>
				<entry key="jobData" value-ref="jobData"></entry>
			</map>
		</property>
	</bean>
	<!-- 在任务的周期指定上，使用SimpleTriggerBean类来指定。排定Job用SchedulerFactoryBean类。-->
	<bean id="simpleTriggerBean"
		class="org.springframework.scheduling.quartz.SimpleTriggerBean">
		<property name="jobDetail" ref="jobDetailBean"></property>
		<!-- 执行周期 -->
		<property name="repeatInterval" value="2000"></property>
		<!-- 开始延时 -->
		<property name="startDelay" value="1000"></property>
	</bean>

	<bean id="scheduledFactoryBean"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref bean="simpleTriggerBean" />
			</list>
		</property>
	</bean>
4、	编写测试类
public class TestQuartzDemo
{

    public static void main(String[] args)
    {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationcontext.xml");
        System.out.println("启动任务");
        Scheduler scheduler= (Scheduler)context.getBean("scheduledFactoryBean");
        try 
        {
            scheduler.start();
        } 
        catch (SchedulerException e) 
        {
            e.printStackTrace();
            
        }
    }
}

2010年9月16日 19:14

songfantasy
728
0 0 1