多个定时任务同时执行一个job类，怎么确保执行的数据不重复；

数据库中有100条数据，在一个配置文件里面，配置了10个定时任务，但是走的job类是同一个，在启动项目的时候，如何确保这同时跑的10个定时任务，不重复读取一条数据或者重复读取相同的几条数据，防止修改一条数据的时候，别的定时任务已经执行完成，这就造成了数据库重复添加数据；（加锁是不可能得因为造成死锁。）

            配置文件如下
            <?xml version="1.0" encoding="UTF-8"?>

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

<bean id="lastNum0" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="0" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum1" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="1" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum2" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="2" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum3" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="3" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum4" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="4" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum5" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="5" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum6" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="6" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum7" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="7" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum8" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="8" />
        </map>
    </constructor-arg>
</bean>
<bean id="lastNum9" class="org.quartz.JobDataMap">
    <constructor-arg>
        <map>
            <entry key="lastNum" value="9" />
        </map>
    </constructor-arg>
</bean>
<bean id="policyQuartzServiceImpl" class="cn.com.sinosoft.clarify.business.service.impl.quartz.PolicyQuartzServiceImpl"/>

<!--<bean id="PolicyJob0" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass" valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum0"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob1"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum1"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob2"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum2"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob3"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum3"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob4"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum4"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob5"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum5"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob6"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum6"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob7"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum7"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob8"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum8"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>

<bean id="PolicyJob9"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              valcn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_22ller"></property>
    <property name="jobDataMap">
        <ref bean="lastNum9"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-rpolicyQuartzServiceImplImpl"></entry>
        </map>
    </property>
</bean>-->
<bean id="PolicyJob10"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum0"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob11"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum1"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob12"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum2"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob13"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum3"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob14"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum4"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob15"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum5"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob16"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum6"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob17"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum7"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob18"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum8"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>
<bean id="PolicyJob19"
      class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
              value="cn.com.sinosoft.clarify.dispatch.quartzJob.PolicyQuartzJob_1"></property>
    <property name="jobDataMap">
        <ref bean="lastNum9"></ref>
    </property>
    <property name="jobDataAsMap">
        <map>
            <entry key="policyQuartzServiceimpl" value-ref="policyQuartzServiceImpl"></entry>
        </map>
    </property>
</bean>

<bean id="PolicyDateBean10" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob10"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean11" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob11"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean12" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob12"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean13" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob13"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean14" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob14"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean15" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob15"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean16" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob16"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean17" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob17"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean18" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob18"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean id="PolicyDateBean19" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="PolicyJob19"></property>
    <property name="cronExpression" value="0/1 * * * * ?"></property>
</bean>
<bean  class="org.springframework.scheduling.quartz.SchedulerFactoryBean" lazy-init="true" autowire="no">
    <property name="triggers">
        <list>
            <ref bean="PolicyDateBean10" />
            <ref bean="PolicyDateBean11" />
            <ref bean="PolicyDateBean12" />
            <ref bean="PolicyDateBean13" />
            <ref bean="PolicyDateBean14" />
            <ref bean="PolicyDateBean15" />
            <ref bean="PolicyDateBean16" />
            <ref bean="PolicyDateBean17" />
            <ref bean="PolicyDateBean18" />
            <ref bean="PolicyDateBean19" />
        </list>
    </property>
    <property name="configLocation" value="classpath:/quartz/quartz.properties" />
    <!--<property name="autoStartup" value="true" />-->
</bean>

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除
收藏举报

3条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
艾德 2018-10-18 13:01
关注
可以用数据库悲观锁，取10条没处理过的数据，select * from table where status=0 for update，取出10条同时锁住这10条

其实不建议启10个timer，应该是启一个timer，取出数据后分配线程来处理。

另外，用注解启timer了解一下，比写xml优雅点

解决 1
无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

SpringBoot + quartz中多个任务共用一个Job实现类的问题 big data hadoop java
2021-07-15 10:58

回答 1 已采纳写一个实现runnable接口的类 ,定义几个变量 ,根据不同的变量值执行不同的逻辑处理,可以由JOB统一处理
flink sql job 如何每天定时执行？ flink
2022-04-24 14:53

回答 2 已采纳这样好像不行，你可以换一种思路。写linux脚本，定时提交作业 Linux Crontab 定时任务 麻烦采纳一下，你的采纳，是对我最好的鼓励，谢谢！
xxl-job定时任务，迁移至另一套xxl-job java mysql 运维
2022-08-02 16:33

回答 3 已采纳迁移两个表的数据就行了，xxl_job_group 和 xxl_job_info。如果只是新增的定时任务的sql，只需要xxl_job_info表里把对应定时任务的数据复制过去就行。保证执行器的i
定时任务部署在多台服务器时如何避免重复执行
2023-12-27 09:57

Crhy、Y的博客任务以源码方式维护在调度中心，支持通过Web IDE在线更新，实时编译和生效，原理：每个 “GLUE模式(Java)” 任务的代码，实际上是“一个继承自“IJobHandler”的实现类的类代码”，“执行器”接收到“调度中心”的...
WIN10任务计划程序，怎么设置每个月最后三天执行job sql 有问必答
2021-03-10 10:46

回答 2 已采纳第一种方法按照大月（31天）、小月（30）、特殊月（二月）建立3个触发器第二种自己写一个程序第三种改本地时间，延后3天时间。即大月29=1号，30=2号.......
spring 定时任务不执行 spring
2015-10-13 04:06

回答 4 已采纳看配置是没有问题的；或者你测试一下官方的这种方式：http://spring.io/guides/gs/scheduling-tasks/
java Quartz定时任务执行中出现初始化，之前任务消失 java
2021-01-26 20:01

回答 3 已采纳自己先复现呗，明显有个shutdown的过程，要么是debug，要么改一下日志级别！最好检查一下代码，是不是有显示调用shutdown的过程
java 定时任务重复执行,Springboot定时任务Scheduled重复执行操作
2021-04-17 06:35

Kalu丁的博客今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次，而我的cron表达式为 * 0/2 * * * * 。在源码调试的过程中，发现是我的定时任务执行过程太短导致的。于是我另外写了个简单的定时任务上述任务在启动...
spring + quartz 重启tomcat后已经执行过的job立即执行一次的原因？ java linux 有问必答
2021-06-29 15:03

回答 3 已采纳由于服务器重启后，quartz识别到有定时任务今天要执行的，如果超过执行时间会立刻执行的，它不会记录定时任务之前是否执行过，因为重启后是新的线程池了。你可以尝试设置DataStart的时候判断一下
Quartz定时任务，暂停问题 java
2022-01-07 17:06

回答 1 已采纳一旦执行了，必须执行完，没有中途停止的方法。如果一定有这种需求，建议使用xxl-job，用子任务的方式去做，可以做到分步任务，可以部分先完成，等待其他任务再一起去做。
请教一个关于Spring-task定时任务的问题
2018-08-16 01:20

回答 4 已采纳不知道你定时任务是多久执行一次，其次你得最好打印下生成后的字符数量，如果字符确实很长，而且任务执行频繁会耗费内存，问题不在于StringBuffer，而在于你怎么用，StringBuffer是可以循环
解决@Scheduled注解不能同时执行多个定时任务的问题
2021-11-19 15:35

weixing_2006的博客所以多个定时在没设置线程池的时候,其实是单线程执行的, 解决多个任务可以同时进行，在启动类里加上下面代码即可。 @Configuration public class ScheduledConfig { @Bean public TaskScheduler tas
在Java web中怎么提交一个spark job任务？ java spark
2018-11-06 15:11

回答 3 已采纳 spark使用命令行提交任务使用场景很窄，一般情况下提交任务、kill任务、查询任务执行状态都是使用http接口，在这种场景下你应该使用livy。你需要安装livy，才可以用，具体安装文档以及使用文档
job每小时执行一次 oracle_ORACLE 定时任务job
2020-12-20 17:53

weixin_39656435的博客 DBMS_JOB包对于任务队列提供了下面这些功能：提交并且执行一个任务、改变任务的执行参数以及删除或者临时挂起任务等。DBMS_JOB包是由ORACLE_HOME目录下的rdbms/admin子目录下的DBMSJOB.SQL和PRVTJOB.PLB 这两个脚本...
ElasticJob分布式调度，分布式多个微服务执行只需要执行一个定时任务，基本概念介绍（一）
2022-04-14 17:40

时间是一种解药的博客 ElasticJob分布式调度，分布式多个微服务执行只需要执行一个定时任务，基本概念介绍（一）
没有解决我的问题, 去提问

悬赏问题

¥30 python代码，帮调试
¥15 #MATLAB仿真#车辆换道路径规划
¥15 java 操作 elasticsearch 8.1 实现索引的重建
¥15 数据可视化Python
¥15 要给毕业设计添加扫码登录的功能！！有偿
¥15 kafka 分区副本增加会导致消息丢失或者不可用吗？
¥15 微信公众号自制会员卡没有收款渠道啊
¥100 Jenkins自动化部署—悬赏100元
¥15 关于#python#的问题：求帮写python代码
¥20 MATLAB画图图形出现上下震荡的线条

多个定时任务同时执行一个job类，怎么确保执行的数据不重复；

3条回答 默认 最新

悬赏问题

3条回答默认最新