快捷導(dǎo)航

解決@Scheduled定時(shí)器使用@Thransactional事物問題

更新時(shí)間：2024年08月22日 10:21:38 作者：墨止戈

這篇文章主要介紹了解決@Scheduled定時(shí)器使用@Thransactional事物問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

@Scheduled定時(shí)器使用@Thransactional問題

最近遇到一個(gè)非常棘手的問題

當(dāng)jpa使用update/delete時(shí)如果不添加@Thransactional會(huì)報(bào)

Executing an update/delete query;

nested exception is javax.persistence.TransactionRequiredException: Executing anupdate/delete query異常

可是我添加@Thransactional還是會(huì)報(bào)這個(gè)異常

問了好多同行，他們都是告訴我定時(shí)器不能使用事物，實(shí)際并不是這樣的，我查看了很多資料是可以使用的，@Scheduled和@Thransaction不能在同一個(gè)類中。

并且實(shí)體類要加上@EnableTransactionManagement注解，使我們這個(gè)工程支持事物

后來我試了很多

@Thransactional（rolbackFor=ThrowAble.class）
@Thransactional(rolbackFor=Exception.class)
@Thransactional（ReadOnly=false）//jpa默認(rèn)不開啟事物 等等就是想使事物進(jìn)行回滾 可是造化弄人呀

廢話不多說，直接上最關(guān)鍵的!!

// 在連接數(shù)據(jù)庫也就是date jpa 工程的啟動(dòng)類中 配置
@Bean(name="transactionManager")
public PlatformTransactuibManager configurationTm(EntityManagerFactory factory){
	return new JpaTransactionManager(factory);
}

關(guān)于Scheduled定時(shí)任務(wù)

認(rèn)識(shí)定時(shí)器

https://cron.qqe2.com/

定時(shí)器表達(dá)式生成器

定時(shí)器場景使用

/*
    使用定時(shí)任務(wù)關(guān)閉超期未支付訂單，會(huì)存在的弊端
        1、會(huì)有時(shí)間差，導(dǎo)致程序不嚴(yán)謹(jǐn)
        2、不支持集群：單機(jī)沒毛病，使用集群后，就會(huì)有多個(gè)定時(shí)任務(wù)
            解決方案：只使用一臺(tái)計(jì)算機(jī)節(jié)點(diǎn)，單獨(dú)用來運(yùn)行所有的定時(shí)任務(wù)
        3、會(huì)全表檢索數(shù)據(jù)庫，對(duì)數(shù)據(jù)庫的性能有極大的影響：數(shù)據(jù)量大的情況
    定時(shí)任務(wù)，僅僅只適用于小型輕量級(jí)項(xiàng)目，傳統(tǒng)項(xiàng)目

    最好使用消息隊(duì)列 ：MQ：RabbitMQ、RockerMQ、Kafka、ZeroMQ...
        延時(shí)任務(wù)(隊(duì)列)
 */

定時(shí)器的使用

1、需要定時(shí)執(zhí)行的方法上加上@Scheduled注解，這個(gè)注解中可以指定定時(shí)執(zhí)行的規(guī)則，稍后詳細(xì)介紹。

2、Spring容器中使用@EnableScheduling開啟定時(shí)任務(wù)的執(zhí)行，此時(shí)spring容器才可以識(shí)別@Scheduled標(biāo)注的方法，然后自動(dòng)定時(shí)執(zhí)行。

Component

package com.laity.config;

import com.laity.service.OrderService;
import com.laity.utils.DateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * @author: Laity
 * @Project: JavaLaity
 * @Package: com.laity.config.OrderJob
 * @Date: 2022年08月12日 11:55
 * @Description: 定時(shí)任務(wù)
 * <p>
 * https://cron.qqe2.com/ cron表達(dá)式網(wǎng)站
 */
@Component
public class OrderJob {


    @Autowired
    private OrderService orderService;

    /*
        使用定時(shí)任務(wù)關(guān)閉超期未支付訂單，會(huì)存在的弊端
            1、會(huì)有時(shí)間差，導(dǎo)致程序不嚴(yán)謹(jǐn)
            2、不支持集群：單機(jī)沒毛病，使用集群后，就會(huì)有多個(gè)定時(shí)任務(wù)
                解決方案：只使用一臺(tái)計(jì)算機(jī)節(jié)點(diǎn)，單獨(dú)用來運(yùn)行所有的定時(shí)任務(wù)
            3、會(huì)全表檢索數(shù)據(jù)庫，對(duì)數(shù)據(jù)庫的性能有極大的影響：數(shù)據(jù)量大的情況
        定時(shí)任務(wù)，僅僅只適用于小型輕量級(jí)項(xiàng)目，傳統(tǒng)項(xiàng)目

        最好使用消息隊(duì)列 ：MQ：RabbitMQ、RockerMQ、Kafka、ZeroMQ...
            延時(shí)任務(wù)(隊(duì)列)
     */

    /*定時(shí)檢索未支付的訂單，并將其關(guān)閉*/
    //@Scheduled(cron = "0/3 * * * * ?")
    @Scheduled(cron = "* * 0/1 * * ?")
    public void autoCloseOrder() {
        orderService.closeOrder();
//        System.out.println("執(zhí)行定時(shí)任務(wù)，當(dāng)前時(shí)間為:" + DateUtil.getCurrentDateString(DateUtil.DATETIME_PATTERN));
    }
}

啟動(dòng)類

在啟動(dòng)類中開啟定時(shí)器

package com.laity;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import tk.mybatis.spring.annotation.MapperScan;

/**
 * @author: Laity
 * @Project: JavaLaity
 * @Package: com.laity.Application
 * @Date: 2022年07月19日 15:55
 * @Description: 自動(dòng)裝配注解
 * @EnableAutoConfiguration
 */
@Slf4j
@ServletComponentScan
@SpringBootApplication
//@EnableTransactionManagement /*開啟事務(wù)管理 - 但是因?yàn)閟pringboot自動(dòng)裝配(事務(wù)的自動(dòng)裝配)的關(guān)系我們不去使用這個(gè)注釋*/
@MapperScan(basePackages = "com.laity.mapper")  /*掃描 mybatis 通用 mapper 所在的包*/
// 掃描所有包 以及 相關(guān)組件包 idworker => 主鍵生成
@ComponentScan(basePackages = {"com.laity", "org.n3r.idworker"})
@EnableScheduling  /*開啟定時(shí)任務(wù)*/
public class Application {
    public static void main(String[] args) {
        ConfigurableApplicationContext run = SpringApplication.run(Application.class, args);
        log.info(run.toString());
    }
}