Spring4.X+Quartz2.X无法自动注入bean问题

2024-05-08 14:38

本文主要是介绍Spring4.X+Quartz2.X无法自动注入bean问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Quartz是目前非常流行的任务框架,一般用来做定时任务。
但是在QuartzJobBean中无法使用注解自动注入bean。
需要达到的效果:

    @Resourceprivate  IAlumniService alumniService;

原因是因为Job对象的实例化过程是在Quartz中进行的,bean是在Spring容器当中的,那么如何将他们关联到一起呢?
Quartz提供了JobFactory接口,让我们可以自定义实现创建Job的逻辑。那么我们通过实现JobFactory 接口,在实例化Job以后,在通过ApplicationContext 将Job所需要的属性注入即可。
重写JobFactory

/*** Created by XFL.* time on 2016/10/4 23:13* description:自定义JobFactory以便在JobBean中可以获取Spring注解的bean*/
public class MyJobFactory extends AdaptableJobFactory {/*** 这个对象Spring会帮我们自动注入进来,也属于Spring技术范畴.*/private AutowireCapableBeanFactory capableBeanFactory;/*** 注入capableBeanFactory.* @param capableBeanFactory AutowireCapableBeanFactory*/@Autowiredpublic MyJobFactory(final AutowireCapableBeanFactory capableBeanFactory) {Assert.notNull(capableBeanFactory, "自动注入AutowireCapableBeanFactory失败");this.capableBeanFactory = capableBeanFactory;}/*** 重写该方法,以便在quartz中可以获取注解的bean.* @param bundle TriggerFiredBundle* @return 返回实例(Spring bean)* @throws Exception 异常*/protected final Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {//调用父类的方法Object jobInstance = super.createJobInstance(bundle);//进行注入,这属于Spring的技术,不清楚的可以查看Spring的API.capableBeanFactory.autowireBean(jobInstance);return jobInstance;}
}

Spring-quartz配置文件,这里只考虑单机部署,未考虑集群,分布式部署。如需要集群部署需要更改此文件,在bean quartzScheduler中需要加入datascore,quartz集群配置文件等等。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://www.springframework.org/schema/beans"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"><bean name="quartzScheduler"class="org.springframework.scheduling.quartz.SchedulerFactoryBean"><property name="jobFactory" ref="myJobFactory"/><property name="triggers"><list><ref bean="trigger" /></list></property></bean><!--任务--><bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"><property name="jobClass" value="com.jxufe.schedule.task.QuartzTestJobBean"/><property name="durability" value="true" /><property name="requestsRecovery" value="true" /></bean><!--触发器--><bean id="trigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"><property name="jobDetail" ref="jobDetail" /><property name="cronExpression" value="0 0/5 * * * ?" /></bean><bean id="myJobFactory" class="com.jxufe.schedule.task.MyJobFactory"/>
</beans>

任务

public class QuartzTestJobBean extends QuartzJobBean {/*** Log4j2 日志对象.*/private static final Logger logger = LogManager.getLogger(QuartzTestJobBean.class);/*** 注入alumniService.*/@Resourceprivate  IAlumniService alumniService;/*** 测试定时任务.* @param jobExecutionContext 定时任务* @throws JobExecutionException 抛出异常*/@Overrideprotected final void executeInternal(final JobExecutionContext jobExecutionContext) throws JobExecutionException {logger.info("执行定时任务QuartzTestJobBean");System.out.println("执行定时任务");//  SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);Map<String, Object> parameterMap = new HashMap<>();//获取beanif (alumniService != null) {List<Map<String, Object>> result = alumniService.findAlumni(parameterMap);if (result != null) {logger.info("获取的大小" + result.size());}}logger.info("执行定时任务完毕QuartzTestJobBean");}
}

还有一种解决办法是在任务中加入,使用这种方法可以不需要重写JobFactory

SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);

注意:以上方法如果使用构造函数注入,是仍然不行的
使用到的框架包
Spring基础包,SpringMVC框架包
spring-context-support,quartz,quartz-jobs

这篇关于Spring4.X+Quartz2.X无法自动注入bean问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/970597

相关文章

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

SQL Server跟踪自动统计信息更新实战指南

《SQLServer跟踪自动统计信息更新实战指南》本文详解SQLServer自动统计信息更新的跟踪方法,推荐使用扩展事件实时捕获更新操作及详细信息,同时结合系统视图快速检查统计信息状态,重点强调修... 目录SQL Server 如何跟踪自动统计信息更新:深入解析与实战指南 核心跟踪方法1️⃣ 利用系统目录

解决pandas无法读取csv文件数据的问题

《解决pandas无法读取csv文件数据的问题》本文讲述作者用Pandas读取CSV文件时因参数设置不当导致数据错位,通过调整delimiter和on_bad_lines参数最终解决问题,并强调正确参... 目录一、前言二、问题复现1. 问题2. 通过 on_bad_lines=‘warn’ 跳过异常数据3

解决RocketMQ的幂等性问题

《解决RocketMQ的幂等性问题》重复消费因调用链路长、消息发送超时或消费者故障导致,通过生产者消息查询、Redis缓存及消费者唯一主键可以确保幂等性,避免重复处理,本文主要介绍了解决RocketM... 目录造成重复消费的原因解决方法生产者端消费者端代码实现造成重复消费的原因当系统的调用链路比较长的时

深度解析Nginx日志分析与499状态码问题解决

《深度解析Nginx日志分析与499状态码问题解决》在Web服务器运维和性能优化过程中,Nginx日志是排查问题的重要依据,本文将围绕Nginx日志分析、499状态码的成因、排查方法及解决方案展开讨论... 目录前言1. Nginx日志基础1.1 Nginx日志存放位置1.2 Nginx日志格式2. 499

kkFileView启动报错:报错2003端口占用的问题及解决

《kkFileView启动报错:报错2003端口占用的问题及解决》kkFileView启动报错因office组件2003端口未关闭,解决:查杀占用端口的进程,终止Java进程,使用shutdown.s... 目录原因解决总结kkFileViewjavascript启动报错启动office组件失败,请检查of

Spring Security 单点登录与自动登录机制的实现原理

《SpringSecurity单点登录与自动登录机制的实现原理》本文探讨SpringSecurity实现单点登录(SSO)与自动登录机制,涵盖JWT跨系统认证、RememberMe持久化Token... 目录一、核心概念解析1.1 单点登录(SSO)1.2 自动登录(Remember Me)二、代码分析三、

MyBatis-Plus 自动赋值实体字段最佳实践指南

《MyBatis-Plus自动赋值实体字段最佳实践指南》MyBatis-Plus通过@TableField注解与填充策略,实现时间戳、用户信息、逻辑删除等字段的自动填充,减少手动赋值,提升开发效率与... 目录1. MyBATis-Plus 自动赋值概述1.1 适用场景1.2 自动填充的原理1.3 填充策略

Spring Bean初始化及@PostConstruc执行顺序示例详解

《SpringBean初始化及@PostConstruc执行顺序示例详解》本文给大家介绍SpringBean初始化及@PostConstruc执行顺序,本文通过实例代码给大家介绍的非常详细,对大家的... 目录1. Bean初始化执行顺序2. 成员变量初始化顺序2.1 普通Java类(非Spring环境)(

Java Spring的依赖注入理解及@Autowired用法示例详解

《JavaSpring的依赖注入理解及@Autowired用法示例详解》文章介绍了Spring依赖注入(DI)的概念、三种实现方式(构造器、Setter、字段注入),区分了@Autowired(注入... 目录一、什么是依赖注入(DI)?1. 定义2. 举个例子二、依赖注入的几种方式1. 构造器注入(Con