- 浏览: 506354 次
- 性别:
- 来自: 深圳
文章分类
- 全部博客 (200)
- java基础 (30)
- ajax (19)
- 乱写 (5)
- groovy (2)
- db (8)
- gwt (0)
- jee (2)
- 我关注的开源 (1)
- RIA AIR (1)
- spring (11)
- lucene (0)
- 工具 (10)
- 百科 (2)
- linux (6)
- android (40)
- 移动开发 (21)
- 代码片断 (15)
- tomcat (1)
- css (1)
- html5 (2)
- jquery (2)
- playframework (3)
- web (2)
- nio (3)
- design (1)
- nosql (3)
- 日志 (12)
- mysql (4)
- 图表 (1)
- python (3)
- ruby (1)
- git (0)
- hibernate (1)
- springboot (1)
- guava (1)
- mybatis (0)
- 工作问题 (3)
- php (1)
最新评论
-
linzm1990:
踩了很多坑啊。。。。
hibernate @Nofound 与@ManyToOne fetch lazy的问题 -
Ccccrrrrrr:
...
转: Spring boot 文件上传 -
rmzdb:
兄弟,你这个东西,在ie内核的浏览器,貌似不识别 文件名
工作问题:http下载文件,中文文件名在firefox下乱码问题 -
107x:
问题解决了,谢谢!
工作问题:http下载文件,中文文件名在firefox下乱码问题 -
klxqljq:
额鹅鹅鹅
android布局实现头尾固定, 中间多余内容可以滚动
转自:http://sundoctor.iteye.com/blog/480405
在《Quartz 任务监控管理 (1)》http://www.iteye.com/topic/441951?page=1
中,我们知道实现的因难是Job持久化需要序列化,主要是以处下三个问题:
一、
org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean
报 java.io.NotSerializableException异常,需要自己实现QuartzJobBean。
二、dao必须要实现序列化接口,Hibernate dao不能直接继承自HibernateDaoSupport,因为HibernateDaoSupport没有实现序列化接口,只能通过SessionFactory构造HibernateTemplate。
三、当库里己存在Trigger,应用启动时会从库里加载己存在Trigger,会报
java.io.InvalidObjectException: Could not find a SessionFactory named:
null等SessionFactory等相关异常。因为应用每次启动的得到的SessionFactory实例是不一样的,当从库里取到的Job进行反
序列化时,Job里包含的SessionFactory与当前的SessionFactory不一致,所以为null。当时解决这问题采用了一个比较笨的
方法,在SchedulerServiceImpl增加一个初始化方法
@PostConstruct public void init() throws SchedulerException{ logger.info("init start...................."); scheduler.addJob(jobDetail, true); logger.info("init end......................."); }
并且增加
<property name="startupDelay" value="60"/>
让QuartzScheduler延时启动,为了保证init()先执行,init()是更新Job,其实只是为了更新当前的 SessionFactory到Job中,保持Job里的SessionFactory与当前SessionFactory一致。我后来发现解决这个问题 还有一个更好的方法,在org.springframework.scheduling.quartz.SchedulerFactoryBean是可配 置的
<property name="overwriteExistingJobs" value="true"/> <property name="jobDetails" > <list> <ref bean="jobDetail"/> </list> </property>
这样就可以达到与init一样的效果。
这三个问题,经过研究探索,现在都己经不是问题了。下面我简单说说这个三个问题的解决办法。
第一个问题:org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean报NotSerializableException异常,这个 spring bug 己经在http://jira.springframework.org/browse/SPR-3797
找到解决方案,上面有牛人修改过的MethodInvokingJobDetailFactoryBean.java,详细源码请可以参考附件。哇塞,又可以POJO了。
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN" "http://www.springframework.org/dtd/spring-beans-2.0.dtd"> <beans> <bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="dataSource" ref="dataSource"/> <property name="applicationContextSchedulerContextKey" value="applicationContextKey"/> <property name="configLocation" value="classpath:quartz.properties"/> <!--这个是必须的,QuartzScheduler 延时启动,应用启动完后 QuartzScheduler 再启动--> <property name="startupDelay" value="30"/> <!--这个是可选,QuartzScheduler 启动时更新己存在的Job,这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了--> <property name="overwriteExistingJobs" value="true"/> <property name="jobDetails" > <list> <ref bean="jobDetail"/> </list> </property> </bean> <bean id="jobDetail" class="frameworkx.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <!--shouldRecover属性为true,则当Quartz服务被中止后,再次启动任务时会尝试恢复执行之前未完成的所有任务--> <property name="shouldRecover" value="true"/> <property name="targetObject" ref="customerService"/> <property name="targetMethod" value="testMethod1"/> </bean> </beans>
注意 <bean id="jobDetail"
class="frameworkx.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"&
gt;是修改过的MethodInvokingJobDetailFactoryBean。
第三个问题:从SchedulerServiceImpl 中去掉不需要的init() 方法,不用在SchedulerServiceImpl初始化后更新jobDeail。
@PostConstruct public void init() throws SchedulerException{ logger.info("init start...................."); scheduler.addJob(jobDetail, true); logger.info("init end......................."); }
第二个问题与第三个是互相关联的,我想到要解决这两个问题的一个方案是Job中不要包含SessionFactory就没一切OK了, 因为SessionFactory是hibernate dao的属性,而hibernate dao是SimpleService的属性,因此SimpleService不能有任何hibernate dao属性了。如此SimpleService业务方法里需要的hibernate dao又如何获取呢?对 spring 的了解,我们知道可以通过ApplicationContext获取到任何spring bean,但是在这里ApplicationContext又怎么获取呢? ... 查看org.springframework.web.context.ContextLoaderListener找到 org.springframework.web.context.ContextLoader.getCurrentWebApplicationContext() 可以获取到ApplicationContext,增加一个SpringBeanService类,实现序列化接口,通过 SpringBeanService可以获取到web己经加载的spring bean
package com.sundoctor.example.service; import java.io.Serializable; import org.springframework.context.ApplicationContext; import org.springframework.stereotype.Service; import org.springframework.web.context.ContextLoader; @SuppressWarnings("unchecked") @Service("springBeanService") public class SpringBeanService implements Serializable{ private static final long serialVersionUID = -2228376078979553838L; public <T> T getBean(Class<T> clazz,String beanName){ ApplicationContext context = ContextLoader.getCurrentWebApplicationContext(); return (T)context.getBean(beanName); } }
因为Hibernate Dao不再持久到Job中,所在不再需要实现序列化接口,可以继承HibernateDaoSupport,当然也可以不继承,可以根据自己喜好的方式编写,不再有任何限制
package com.sundoctor.example.dao; import org.hibernate.Session; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.orm.hibernate3.HibernateCallback; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import org.springframework.stereotype.Repository; import com.sundoctor.example.model.Customer; import com.sundoctor.example.service.CustomerService; @Repository("customerDao") public class CustomerHibernateDao extends HibernateDaoSupport { private static final Logger logger = LoggerFactory.getLogger(CustomerService.class); public Customer getCustomer2() { return (Customer) this.getHibernateTemplate().execute(new HibernateCallback() { public Object doInHibernate(Session session) { Customer customer = (Customer) session.createQuery("from Customer where id = 1").uniqueResult(); logger.info("Customer2={}", customer); return customer; } }); } public Customer getCustomer1() { Customer customer = (Customer) this.getHibernateTemplate().get(Customer.class, 1); logger.info("Customer1={}", customer); return customer; } }
因为hibernate dao 不再实现序列化接口和继承自HibernateDaoSupport,不能再注入到业务类中了。在业务类中注入以上的 SpringBeanService,业务方法需要的hibernate dao通过以上的SpringBeanService.getBean获取
package com.sundoctor.example.service; import java.io.Serializable; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Service; import com.sundoctor.example.dao.CustomerHibernateDao; import com.sundoctor.example.model.Customer; @Service("customerService") public class CustomerService implements Serializable { private static final long serialVersionUID = -6857596724821490041L; private static final Logger logger = LoggerFactory.getLogger(CustomerService.class); private SpringBeanService springBeanService; @Autowired public void setSpringBeanService(@Qualifier("springBeanService") SpringBeanService springBeanService) { this.springBeanService = springBeanService; } public void testMethod1() { // 这里执行定时调度业务 CustomerHibernateDao customerDao =springBeanService.getBean(CustomerHibernateDao.class,"customerDao"); Customer customer = customerDao.getCustomer1(); logger.info("AAAA:{}", customer); } public void testMethod2() { // 这里执行定时调度业务 CustomerHibernateDao customerDao =springBeanService.getBean(CustomerHibernateDao.class,"customerDao"); Customer customer = customerDao.getCustomer2(); logger.info("BBBB:{}", customer); }
以上代码中hibernate dao 获取方法:
CustomerHibernateDao customerDao =springBeanService.getBean(CustomerHibernateDao.class,"customerDao")获取方法;
三个主要问题就这样解决了。
附件中的其它源码介绍可以参考《Quartz 在 Spring 中如何动态配置时间》http://www.iteye.com/topic/399980?page=1
和《Quartz任务监控管理 (1)》http://www.iteye.com/topic/441951?page=1
。
- quartzMonitor2.part3.rar (3.5 MB)
- 下载次数: 111
- quartzMonitor2.part2.rar (4.8 MB)
- 下载次数: 105
- quartzMonitor2.part1.rar (4.8 MB)
- 下载次数: 125
发表评论
-
浅谈 SpringMVC 数据绑定
2014-10-16 17:20 1114转自: http://senton.iteye.com/blo ... -
转: 当spring 容器初始化完成后执行某个方法
2014-05-05 14:09 1807转自: http://www.cnblogs.com/roll ... -
Quartz scheduler plugins – hidden treasure
2014-02-21 11:10 1744Although briefly described in t ... -
Configuring Quartz with JDBCJobStore in Spring
2014-02-21 10:57 1028I am starting a little series a ... -
Quartz任务监控管理
2009-11-04 12:18 5883转自 http://sundoctor.iteye.com/b ... -
Quartz 在 Spring 中如何动态配置时间
2009-11-04 12:06 3206转自: http://www.iteye.com/topic/ ... -
Quartz在Spring中动态设置cronExpression(自己写类从数据库里读取)
2009-11-04 11:39 4992什么是动态定时任务? 是由客户制定生成的,服务端只知道该去 ... -
Spring邮件发送
2009-11-04 08:21 36991、单例模式(单发,群 ... -
spring源码解读系列(收集)
2009-09-22 09:04 1462对org.springframework.beans.Cach ... -
如何在基于注解风格的Spring-MVC中使用拦截器
2009-09-22 08:27 4798转自 http://www.blogjava.net/ate ...
相关推荐
2. **从数据库中获取定时任务**:Quartz允许将任务和触发器的信息存储在数据库中,这可以通过实现`SchedulerFactoryBean`的`overwriteExistingJobs`属性为`false`来实现。这样,当Quartz启动时,它会从数据库中读取...
2、定时任务(xxl-job)(XXL-JOB是一个分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线,开箱即用。) 3、SpringCloudSchedule定时任务(使用...
spring-boot 2.0.2 数据库配置定时任务。spring-boot 2.0.2.RELEASE,将定时任务配置在数据库,启动项目的时候,用mybatis读取数据库,实例化对象,并设定定时任务。如果需要新增,减少,修改定时任务,仅需要修改...
DirectShow被广泛用于开发多媒体应用程序,它提供了丰富的API接口,可以处理视频捕获、播放、编辑等多种任务。在VB6中调用Quartz.dll,可以利用其强大的视频处理能力,为应用程序添加高级的视频播放特性。 该示例...
### Quart-Z 两次执行问题详解 #### 一、问题背景及概述 ...此外,还可以利用Spring Profiles来更好地管理不同环境下的配置差异。通过采取这些措施,可以有效地避免定时任务的重复执行问题,确保系统的稳定性和效率。
postgres quatrz初始化sql脚本文件、pg、quartz、qrtz_开头的表 配置文件需求修改 #org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate org.quartz.jobStore....
利用VB开放自定义播放器,基于系统Quatrz.dll的接口将媒体显示到指定的控件容器中,比如PictureBox,实现播放的基本功能,播放,暂停,停止,音量,平衡,进度,媒体的总时间和进度时间……感兴趣的VB发烧友可以下载...