Spring+Quartz(一)

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

Quartz是一个非常优秀的任务调度引擎,详情请见官网:http://www.quartz-scheduler.org/

而Spring很好地集成了Quartz,为企业级的任务调度提供了方便。

 

下面先看一个实现了Job接口的任务HelloWorldJob:

Java代码

package com.springQuartz.example;

import java.util.Map;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class HelloWorldJob implements Job{

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        
        Map properties = context.getMergedJobDataMap();
        
        System.out.println("Hello World!");
        System.out.println("Previous Fire Time: "+context.getPreviousFireTime());//上次触发任务的时间
        System.out.println("Current Fire Time: "+context.getFireTime());//当然触发时间
        System.out.println("Next Fire Time: "+context.getNextFireTime());//下次触发时间
        
        System.out.println(properties.get("message"));
        System.out.println();
    }
    
}

 

这个Job输出"HelloWorld",同时输出上次、本次及下次触发的时间。

 

我们看一下在applicationContext.xml中的配置:

Xml代码

<bean id="job" class="org.springframework.scheduling.quartz.JobDetailBean">
    <property name="jobClass" value="com.springQuartz.example.HelloWorldJob"/>
    <property name="jobDataAsMap">
         <map>
            <entry key="triggerMessage" value="Job Message In JobDetail"/> <!--设置JobDetail中的值-->
         </map>
    </property>
</bean>
    
<bean id="trigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
    <property name="jobDetail" ref="job"/> <!--触发的job引用-->
    <property name="startDelay" value="1000"/> <!--设置延迟1秒后运行-->
    <property name="repeatInterval" value="10000"/> <!--设置每10秒触发一次-->
    <property name="jobDataAsMap">
          <map>
          <entry key="triggerMessage" value="Job Message From Trigger"/> <!--设置Trigger中的值-->
          </map>
    </property>
</bean>

<bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="triggers">
        <list>
            <ref local="trigger"/>    
        </list>
    </property>
</bean>

 

我们将HelloWorldJob实现成JobDetailBean类,并配置触发器simpleTriggerBean

 

最后我们的测试类:

Java代码

package com.springQuartz.test;

import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Test {
    public static void main(String args[]){
        BeanFactory factory = new ClassPathXmlApplicationContext("applicationContext.xml");
    }
}

 

运行结果如下:

运行结果代码

2011-01-16 20:48:18,437 INFO - Starting Quartz Scheduler now
Hello World!
Previous Fire Time: null
Current Fire Time: Sun Jan 16 20:48:19 CST 2011
Next Fire Time: Sun Jan 16 20:48:29 CST 2011
Job Message From Trigger

Hello World!
Previous Fire Time: Sun Jan 16 20:48:19 CST 2011
Current Fire Time: Sun Jan 16 20:48:29 CST 2011
Next Fire Time: Sun Jan 16 20:48:39 CST 2011
Job Message From Trigger

  1.  

下面说明几点:

1)首次触发是输出的Previous Fire Time为null

2)jobDataAsMap的说明:在HelloWorldJob.java中getMergedJobDataMap是JobDetail和 Trigger上的JobDataMap的合并,两者数据如果冲突,则Trigger上的数据将覆盖JobDetail中的。运行结果也证明了,我们在 Job中设置的值没有输出,而输出了"Job Message From Trigger"。

3)我们看到HelloWorldJob实现了Job接口,代码上依赖了Quartz的接口

 

下面我们讨论另外一种更普遍的,去除接口依赖的实现

 

主要的applicationContext.xml文件的配置

Xml代码

<bean id="jobService" class="com.springQuartz.service.JobServiceImpl">
</bean>
    
<bean id="invokeJob" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject">
        <ref bean="jobService" /> <!--目标Job-->
    </property>
    <property name="targetMethod">
        <value>JobServiceImpl中的特定方法</value> <!--目标方法-->
    </property>
    <property name="concurrent">
        <value>false</value> <!--设置是否同步-->
    </property>
</bean>
    
<bean id="jobServiceCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="invokeJob" />
    <property name="cronExpression" value="5/10 * * * * ?" />
</bean>

<bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="triggers">
        <list>
            <ref local="jobServiceCronTrigger"/>
        </list>
    </property>
</bean>

 

 

 

1)首先我们配置具体的Job信息--JobServiceImpl,这个类可以不实现Quartz中的Job接口

2)最主要的MethodInvokingJobDetailFactoryBean,可以使得1)可行

3)相对于上面的例子,我们使用CronTriggerBean实现trigger,实现更灵活的时间配置

4)默认情况下,Quartz Jobs是无状态的,可能导致jobs之间互相的影响。如果你为相同的JobDetail 指定两个Trigger, 很可能当第一个job完成之前,第二个job就开始了。如果JobDetail 对象实现了Stateful 接口,就不会发生这样的事情。 第二个job将不会在第一个job完成之前开始。为了使得jobs不并发运行,设置MethodInvokingJobDetailFactoryBean 中的concurrent 标记为false

 

转载于:https://my.oschina.net/u/2365087/blog/690264

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/543092.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python struct pack解析_Python struct 详解

最近在学习python网络编程这一块&#xff0c;在写简单的socket通信代码时&#xff0c;遇到了struct这个模块的使用&#xff0c;当时不太清楚这到底有和作用&#xff0c;后来查阅了相关资料大概了解了&#xff0c;在这里做一下简单的总结。了解c语言的人&#xff0c;一定会知道s…

linux sudo 版本,Linu下如何升级当前sudo版本

Sudo 的全称是“superuserdo”&#xff0c;它是Linux系统管理指令&#xff0c;允许用户在不需要切换环境的前提下以其它用户的权限运行应用程序或命令&#xff0c;通常是以 root 用户身份运行命令&#xff0c;以减少 root 用户的登录和管理时间&#xff0c;同时提高安全性。该漏…

LaTeX技巧205:使用split输入多行公式技巧

我们在输入多行公式的时候&#xff0c;split&#xff0c;array&#xff0c;multiline&#xff0c;align&#xff0c;aligned等等都是我们可以选用的环境&#xff0c;这里介绍split的使用方法。演示效果图&#xff1a;演示代码&#xff1a;\documentclass{article}\pagestyle{em…

python改变列的数据类型_python – Pandas:更改列的数据类型

您可以使用pd.to_numeric(在版本0.17中引入)将列或Series转换为数字类型。该函数还可以使用apply应用于DataFrame的多个列。重要的是&#xff0c;该函数还接受一个错误关键字参数&#xff0c;它允许您强制非数字值为NaN&#xff0c;或者简单地忽略包含这些值的列。示例使用如下…

linux纯内核直接用吗,Linux:为啥内核有的变量没有初始化就敢直接使用?

一、问题为啥内核有的变量没有初始化就敢直接使用&#xff1f;二、分析看上图&#xff0c;其中的5747行的变量nid的确没有定义&#xff0c;就直接使用了&#xff0c;这么做没有问题吗&#xff1f;其实大家仔细看一下&#xff0c;5765行是一个宏&#xff0c;到内核源码去找该宏的…

mysql主从复制实践之单数据库多实例

1.主从复制数据库实战环境准备MySQL主从复制实践对环境的要求比较简单&#xff0c;可以是单机单数据库多实例的环境&#xff0c;也可以是两台服务器之间&#xff0c;每台服务器都部署一个独立的数据库的环境。本文以单机数据库多实例的环境进行实践。2.主从复制服务器角色定义序…

sdr 软件_【火腿专题】购买软件定义无线电(SDR)还是传统无线电台?追求欲望无止境...

软件定义无线电与传统无线电选择作者&#xff1a;Onno VK6FLAB有一段时间&#xff0c;我一直在解释软件无线电(SDR)的一些内部工作方式是如何运作的&#xff0c;以便深入了解原因和方法的细节。这种探索是在一个新世界的背景下进行的&#xff0c;在这个世界里&#xff0c;有无数…

linux文本运行层次,Linux基础知识之---文件系统层级结构

#Linux基础知识之---文件系统层级结构(Linux系统)[基础知识&#xff0c;文件系统&#xff0c;层级结构&#xff0c;FHS]一切皆文件&#xff1a; 在Linux中&#xff0c;无论是目录、配置、cpu、内存、键盘、鼠标、或者运行中的系统及内核、甚至临时缓存也都有对应的文件。“一切…

python的format函数如何理解_python format函数的使用

转载自&#xff1a;http://www.cnblogs.com/kaituorensheng/p/5709970.htmlpython自2.6后&#xff0c;新增了一种格式化字符串函数str.format()&#xff0c;威力十足&#xff0c;可以替换掉原来的%注&#xff1a;以下操作版本是python2.7映射示例语法通过{} 和 : 替换 %通过位…

Linux查询root环境变量,linux环境变量和查看方法

linux环境变量和查看方法1. 显示环境变量HOME[rootlocalhost ~]# echo $HOME/root2. 设置一个新的环境变量hello[rootlocalhost ~]# export HELLO"hello world"[rootlocalhost ~]# echo $HELLOhello world附&#xff1a;修改已存在的环境变量[rootlocalhost ~]# HELL…

服务器搭建-Linux基础知识

服务器搭建还是需要一些Linux知识的&#xff0c;这节就聊点基础的。 文件权限操作 查看权限 Linux中每个文件对每个用户来说都有对应的权限&#xff0c;在任一路径中输入ll就可以查看这些信息&#xff1a; rootip-*** /usr/local # ll total 32K drwxr-xr-x 2 root root 4.0K J…

seo从入门到精通_从入门到精通,新人必看的3本书SEO书籍

SEO入门书本引荐&#xff1a;从入门到通晓&#xff0c;新人必看的3本书在这个网上学习泛滥的年代&#xff0c;很多人都习气在网络上找教程学习&#xff0c;无论上视频教程&#xff0c;学习论坛&#xff0c;或是网上课堂等等。但也有些人仍是更习气看书学习的&#xff0c;很多人…

linux firefox 脚本,linux下调整firefox的有用设置(高分辨率下需要)

注&#xff1a;自己一般比较喜欢opensuse&#xff0c;所以以下所说皆是在opensuse下的做法&#xff0c;在其他发行版下应该也差不多firefox69 默认禁用了userchrome.css,需要把about:config 中的选项toolkit.legacyUserProfileCustomizations.stylesheets设置为true界面字体大小…

读懂python代码_Python面试|一文让你读懂if __name__==’__main__’的含义

程序入口对于很多编程语言来说&#xff0c;程序都必须要有一个入口&#xff0c;比如 C&#xff0c;C&#xff0c;以及完全面向对象的编程语言 Java&#xff0c;C# 等。如果你接触过这些语言&#xff0c;对于程序入口这个概念应该很好理解&#xff0c;C 和 C 都需要有一个 main …

C语言程序设计第三节课作业

1 指针是一个存储计算机内存地址的变量。从指针指向的内存读取数据称作指针的取值。指针可以指向某些具体类型的变量地址&#xff0c;例如int、long和double。指针也可以是void类型、NULL指针和未初始化指针。根据出现的位置不同&#xff0c;操作符 * 既可以用来声明一个指针变…

linux netcat测试udp端口,使用nc(netcat)测试udp协议与端口连通性

[v1.10]connect to somewhere: netcat [-options] hostname port[s] [ports] …listen for inbound: netcat -l -p port [-options] [hostname] [port]options:-g gateway source-routing hop point[s], up to 8-G num source-routing pointer: 4, 8, 12, …-h this cruft-i se…

Hession矩阵与牛顿迭代法

1、求解方程。 并不是所有的方程都有求根公式&#xff0c;或者求根公式很复杂&#xff0c;导致求解困难。利用牛顿法&#xff0c;可以迭代求解。 原理是利用泰勒公式&#xff0c;在x0处展开&#xff0c;且展开到一阶&#xff0c;即f(x) f(x0)(x&#xff0d;x0)f(x0) 求解方程f…

抽象工厂模式_设计模式——抽象工厂模式

阅读目录使用频率&#xff1a;★★★★★一、什么是抽象工厂模式二、补充说明三、角色四、例子使用频率&#xff1a;★★★★★一、什么是抽象工厂模式就是对一组具有相同主题的工厂进行封装(维基百科解释的很到位)&#xff1b;例如&#xff1a;生产一台PC机&#xff0c;使用工…

Linux启动和退出系统的方法,实验二 Linux的启动与关闭

实验二 Linux的启动与关闭一、实验目的(1)掌握linux操作系统正确的启动与关闭方法&#xff1b;(2)理解系统运行级的概念&#xff0c;掌握查看和设置的方法&#xff1b;(3)理解系统运行级服务的概念&#xff0c;掌握查看、开启和关闭的方法&#xff1b;(4)理解LILO和GRUB的原理&…

linux需要什么基础,学linux需要什么基础?

近几年来&#xff0c;随着计算机网络的发展&#xff0c;越来越多的人学习 linux。对于想要从事运维工作或者从事智能开发方面的同学来说&#xff0c;学习 linux 是必要的。linux 的学习并不简单&#xff0c;那么这篇文章 w3cschool 小编来告诉你&#xff0c;学 linux 需要什么基…