三. JobDataMap 获取 ApplicationContext 对象
三.一 在 job.xml 创建 JobDetail 时注入属性 applicationContextJobDataKey
<!-- 定义 JobDetail, 所用的bean 为 JobDetailFactoryBean --> <bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"> <!-- 任务名 --> <property name="name" value="job1"></property> <!-- 组名 --> <property name="group" value="group1"></property> <!-- 关联任务 --> <property name="jobClass" value="com.yjl.job.MyJob"></property> <!-- 必须是true, 如果是false的话，当这个jobDetail没有被Trigger关联时，会删除 --> <property name="durability" value="true"></property> <!-- 还有一个重要的 applicationContextJobDataKey 属性，这是是很重要的。--> <property name="applicationContextJobDataKey" value="userJobDetail"></property> </bean>
在Spring 整合时，没有配置的那一个 applicationContextJobDataKey 属性。
设置一个普通的标识值， 为 userJobDetail.
三.二 工作任务中通过 JobDataMap 来获取 ServiceBean
public class MyJob extends QuartzJobBean{ //@Resource(name="userService") //private UserService userService; @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { //要做的事，是打印当前的时间 SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //格式化时间 String dateString=sdf.format(new Date()); System.out.println("备份数据库的时间是:"+dateString); User user=new User(); user.setName("两个蝴蝶飞"); user.setAge(24); user.setSex("男"); user.setDescription("一个希望得到快乐的程序员"); //从 JobDataMap 里面获取ApplicationContext ApplicationContext applicationContext= (ApplicationContext) context.getJobDetail(). getJobDataMap().get("userJobDetail"); // //可以通过 context 对象来获取一些重要信息 UserService userService=applicationContext.getBean("userService",UserService.class); userService.addUser(user); System.out.println("添加成功"); } }
三.三 运行测试类 JobTest ,看控制台
查看一下数据库，
数据插入成功。
注意，运行了五次。
另外，一定要保证 配置的JobDetail的 applicationContextJobDataKey 属性与 JobDataMap 里面的key 一致，否则，获取不到。
四. 创建工厂类，获取全局 ApplicationContext 对象
要想取得 Service Bean, 都是通过 ApplicationContext 对象进行获取的， 如果在程序运行时，就获取保存了 ApplicationContext的信息，是否就可以取得任意的bean对象了?
四.一 创建工具类， 实现 ApplicationContextAware 接口
四.一.一 ApplicationContextAware 接口定义
package org.springframework.context; import org.springframework.beans.BeansException; import org.springframework.beans.factory.Aware; public interface ApplicationContextAware extends Aware { void setApplicationContext(ApplicationContext applicationContext) throws BeansException; }
只有一个 赋值的方法。
四.一.二 创建工具类 ApplicationContextUtils
package com.yjl.utils; import org.springframework.beans.BeansException; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; /** * * @author 两个蝴蝶飞 * 获取ApplicationContext 对象的工具类 * */ public class ApplicationContextUtils implements ApplicationContextAware{ //定义成静态的 private static ApplicationContext applicationContext; @Override public void setApplicationContext(ApplicationContext ac) throws BeansException { // TODO 自动生成的方法存根 applicationContext=ac; } //获取 public static ApplicationContext getApplicationContext() { return applicationContext; } //根据bean的id名称，获取相应的对象 public static Object getBean(String beanName){ return applicationContext.getBean(beanName); } //根据bean的id名称，获取相应的对象 public static <T> T getBean(String beanName,Class<T> clazz){ return applicationContext.getBean(beanName,clazz); } }
四.二 将工具Bean 放置到 配置文件里面，设置立即启动
放置到 spring的配置文件里面， 这儿放置到 applicationContext-bean.xml 里面
<!-- 设置bean --> <bean id="applicationContext" class="com.yjl.utils.ApplicationContextUtils" lazy-init="false"></bean> <context:component-scan base-package="com.yjl.service"></context:component-scan>
这样，这个工具类就可以使用了。
四.三 通过工具类获取 Service Bean
设置保存信息为 岳泽霖的信息。
package com.yjl.job; import java.text.SimpleDateFormat; import java.util.Date; import javax.annotation.Resource; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.scheduling.quartz.QuartzJobBean; import com.yjl.pojo.User; import com.yjl.service.UserService; import com.yjl.service.impl.UserServiceImpl; import com.yjl.utils.ApplicationContextUtils; public class MyJob extends QuartzJobBean{ //@Resource(name="userService") //private UserService userService; @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { //要做的事，是打印当前的时间 SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //格式化时间 String dateString=sdf.format(new Date()); System.out.println("备份数据库的时间是:"+dateString); User user=new User(); user.setName("岳泽霖"); user.setAge(24); user.setSex("男"); user.setDescription("一个不快乐的思考者"); /* * // 第一种方式实现 * ApplicationContext applicationContext= (ApplicationContext) context.getJobDetail() * * .getJobDataMap().get("userJobDetail"); //可以通过 context 对象来获取一些重要信息 UserService userService=applicationContext.getBean("userService",UserService.class); */ //第二种方式实现 UserService userService= (UserService) ApplicationContextUtils.getBean("userService"); //UserService userService= ApplicationContextUtils.getBean("userService",UserService.class); userService.addUser(user); System.out.println("添加成功"); } }
四.四 测试文件运行
查看数据库:
注意，运行了四次。
四.五 服务器运行
启动服务器时，也是正常插入数据的,与测试类测试一样。
这两种方式生成 Service Bean 都 可以。
四.六 注入 UserMapper
如果想在任务中注入UserMapper对象，与注入 UserService对象类似:
//第一种方式 ApplicationContext applicationContext= (ApplicationContext) context.getJobDetail() .getJobDataMap().get("userJobDetail"); //可以通过 context 对象来获取一些重要信息 UserMapper userMapper=applicationContext.getBean("userMapper",UserMapper.class); //第二种方式实现 //UserMapper userMapper= (UserMapper) ApplicationContextUtils.getBean("userMapper"); //UserMapper userMapper= ApplicationContextUtils.getBean("userMapper",UserMapper.class); userMapper.insert(user);
