百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

springboot_quartz中的问题 springboot系统密码安全问题

yuyutoo 2024-11-01 15:55 4 浏览 0 评论

简介

1、为什么我们并没有对数据库进行操作,数据库中就有了quartz的数据?

2、 我们配置了threadCount为5,那么如果有5个任务还在执行的时候触发了第六个任务会怎么样?

3、如果任务刚执行完,把系统时间修改为任务触发时间之前,那相同时间还会再触发一次吗?

4、job实现类中无法依赖注入问题。


github:https://github.com/mzd123/springboot_quartz

问题一:

问题:为什么我们并没有对数据库进行操作,数据库中就有了quartz的数据?

解决:

前言: 我的第一反应是配置druid去监控一下他,但是并不起作用。。。有点尴尬!

1、打开我们maven引入的jar包,位置:org.quartz.impl.jdbcjobstore,我们可以看到:StdJDBCConstants和Constants。

2、打开可以看到所有的sql语句、表名字、表字段名。

3、看到这里是不是疑惑减了一半,至少能确定quartz底层自己在对数据库进行操作。

4、具体怎么操作的呢?为什么每次项目启动的时候都能执行quartz呢?

5、说实话,到这里思路就断了,但是quartz的配置文件中的org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX我一直没搞清楚他是干嘛的,网上说他是用于数据库存储定时任务信息,于是我找到了这个类。

6、发现这个类是继承JobStoreSupport,然后我打开了JobStoreSupport这个类。

7、如果是新增任务的话,是不是应该少不了JobDetail,于是我全文搜索JobDetail发现有一个storeJobAndTrigger()方法,字面的意思就是储存job和trigger,于是我在这打了个断点,掉了一下新增任务的接口,果然进来了。。。

8、这时候显然我已经控制不住我自己激动的情绪了,那是不是能找到其他操作quartz的方法呢(removeJob、pauseJob、resumeJob、triggerJob)???

9、removeJob:在controller中我们使用的是deleteJob这个方法,不过这并不影响,一层一层点一下就是调用了JobStoreSupport的removeJob方法

10、pauseJob、resumeJob这里就不截图了,都是能找的。

11、triggerJob这个方法表示立刻执行,但是在JobStoreSupport中并没有找到,后来整理了一下发型发现确实不应该找到,JobStoreSupport中都是直接操作数据库的,triggerJob是立刻执行一个任务,和数据库没有直接关系,我们从controller层中一直点下去可以发现他在QuartzScheduler这个类中。

12、其实上面中的所有方法都会进入一个StdJDBCDelegate类中来进行对数据库的操作,这个时候我们应该清楚了为什么配置文件中需要配置org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate

问题二:

问题:我们配置了threadCount为5,那么如果有5个任务还在执行的时候触发了第六个任务会怎么样?

解决:这个东西开始我是很疑惑的,但是可以做一个简单的实验,就是在任务中让线程睡眠一个长时间(大概3000秒吧),然后出发这个任务的时间设置为每隔20秒,这样就能看出到底会不会触发第六个任务了。

@Override

public void execute(JobExecutionContext context) throws JobExecutionException {

System.out.println("任务执行成功");

try {

Thread.sleep(3000000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

结论: 是不会的,我们看 qrtz_fired_triggers (这张表表示正在执行的任务),一直都是5条记录。

问题三:

问题:如果任务刚执行完,把系统时间修改为任务触发时间之前,那相同时间还会再触发一次吗?

解决:这个是不会的,因为quartz每次执行之后会返回下次执行的时间,如果执行过的时间点是不会再执行了,他的唯一标准是从1970开始计算到下次执行时间点的毫秒数。我们可以打开 qrtz_triggers ,看到有一个 NEXT_FIRE_TIME 这个字段。http://tool.chinaz.com/Tools/unixtime.aspx 根据Unix时间转化工具转化之后,是北京时间2018/8/10 15:56:36

问题四:

问题: job实现类中无法依赖注入问题。

描述:在现实开发中显然不是只要输出aaa什么的就行了,肯定需要调用service层中的什么方法,这个时候我们就需要在job的具体实现类中注入一个service实例对象,但是我们惊奇的发现永远都注入不进来(其实也不能说是惊奇,spring理解不错的小伙伴应该早就知道,job的实现类都不受spring管理,那么在想注入spring容器中的对象是不可能的!)

解决:很明显就是让job的实现类受spring管理就行了!!!

1、增加一个配置类: SpringJobFactory继承AdaptableJobFactory,重写createJobInstance方法。

@Component

public class SpringJobFactory extends AdaptableJobFactory {

@Autowired

private AutowireCapableBeanFactory capableBeanFactory;

@Override

protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {

// 调用父类的方法

Object jobInstance = super.createJobInstance(bundle);

// 进行注入

capableBeanFactory.autowireBean(jobInstance);

return jobInstance;

}

}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14

2、修改上篇文章中的SchedulerConfig配置类

@Autowired

private SpringJobFactory springJobFactory;

@Bean(name = "SchedulerFactory")

public SchedulerFactoryBean schedulerFactoryBean() throws IOException {

SchedulerFactoryBean factory = new SchedulerFactoryBean();

factory.setAutoStartup(true);

factory.setStartupDelay(5);//延时5秒启动

factory.setQuartzProperties(quartzProperties());

factory.setJobFactory(springJobFactory);

return factory;

}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11

3、在job实现类中注入service,并调用方法

public class TestJob implements Job, Serializable {

private static final long serialVersionUID = 1L;

@Autowired

private JobService jobService;

@Override

public void execute(JobExecutionContext context) throws JobExecutionException {

jobService.doTest();

System.out.println("任务执行成功");

}

}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10

@Service

public class JobService {

@Autowired

private JobMapping testMapping;

public void doTest() {

System.out.println("aaaa");

}

public List<QuartzBean> listQuartzBean(String name) {

  • return testMapping.listQuartzBean(na

  • 9
  • 10
  • 11
  • 12

4、实验结果: service注入成功了,并执行了方法。

相关推荐

【Socket】解决UDP丢包问题

一、介绍UDP是一种不可靠的、无连接的、基于数据报的传输层协议。相比于TCP就比较简单,像写信一样,直接打包丢过去,就不用管了,而不用TCP这样的反复确认。所以UDP的优势就是速度快,开销小。但是随之...

深入学习IO多路复用select/poll/epoll实现原理

Linux服务器处理网络请求有三种机制,select、poll、epoll,本文打算深入学习下其实现原理。0.结论...

25-1-Python网络编程-基础概念

1-网络编程基础概念1-1-基本概念1-2-OSI七层网络模型OSI(开放系统互联)七层网络模型是国际标准化组织(ISO)提出的网络通信分层架构,用于描述计算机网络中数据传输的过程。...

Java NIO多路复用机制

NIO多路复用机制JavaNIO(Non-blockingI/O或NewI/O)是Java提供的用于执行非阻塞I/O操作的API,它极大地增强了Java在处理网络通信和文件系统访问方面的能力。N...

Python 网络编程完全指南:从零开始掌握 Socket 和网络工具

Python网络编程完全指南:从零开始掌握Socket和网络工具在现代应用开发中,网络编程是不可或缺的技能。Python提供了一系列高效的工具和库来处理网络通信、数据传输和协议操作。本指南将从...

Rust中的UDP编程:高效网络通信的实践指南

在实时性要求高、允许少量数据丢失的场景中,UDP(用户数据报协议)凭借其无连接、低延迟的特性成为理想选择。Rust语言凭借内存安全和高性能的特点,为UDP网络编程提供了强大的工具支持。本文将深入探讨如...

Python 网络编程的基础复习:理解Socket的作用

计算机网络的组成部分在逻辑上可以划分为这样的结构五层网络体系应用层:应用层是网络协议的最高层,解决的是具体应用问题...

25-2-Python网络编程-TCP 编程示例

2-TCP编程示例应用程序通常通过“套接字”(socket)向网络发出请求或者应答网络请求,使主机间或者一台计算机上的进程间可以通信。Python语言提供了两种访问网络服务的功能。...

linux下C++ socket网络编程——即时通信系统(含源码)

一:项目内容本项目使用C++实现一个具备服务器端和客户端即时通信且具有私聊功能的聊天室。目的是学习C++网络开发的基本概念,同时也可以熟悉下Linux下的C++程序编译和简单MakeFile编写二:需...

Python快速入门教程7:循环语句

一、循环语句简介循环语句用于重复执行一段代码块,直到满足特定条件为止。Python支持两种主要的循环结构:for循环和while循环。...

10分钟学会Socket通讯,学不会你打我

Socket通讯是软硬件直接常用的一种通讯方式,分为TCP和UDP通讯。在我的职业生涯中,有且仅用过一次UDP通讯。而TCP通讯系统却经常写,正好今天写了一个TCP通讯的软件。总结一下内容软件使用C#...

Python 高级编程之网络编程 Socket(六)

一、概述Python网络编程是指使用Python语言编写的网络应用程序。这种编程涉及到网络通信、套接字编程、协议解析等多种方面的知识。...

linux网络编程Socket之RST详解

产生RST的三个条件:1.目的地为某端口的SYN到达,然而该端口上没有正在监听的服务器;2.TCP想取消一个已有的连接;3.TCP接收到一个根本不存在的连接上的分节;现在模拟上面的三种情况:cl...

ABB机器人编程实用技巧,多项案例

...

Python中实现Socket通讯(附详细代码)

套接字(socket)是一种在计算机网络中进行进程间通信的方法,它允许不同主机上的程序通过网络相互通信。套接字是网络编程的基础,几乎所有的网络应用程序都使用某种形式的套接字来实现网络功能。套接字可以用...

取消回复欢迎 发表评论: