快捷導(dǎo)航

解決@Scheduled定時器使用@Thransactional事物問題

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

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

@Scheduled定時器使用@Thransactional問題

最近遇到一個非常棘手的問題

當jpa使用update/delete時如果不添加@Thransactional會報

Executing an update/delete query;

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

可是我添加@Thransactional還是會報這個異常

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

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

后來我試了很多

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

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

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

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

認識定時器

https://cron.qqe2.com/

定時器表達式生成器

定時器場景使用

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

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

定時器的使用

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

2、Spring容器中使用@EnableScheduling開啟定時任務(wù)的執(zhí)行，此時spring容器才可以識別@Scheduled標注的方法，然后自動定時執(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: 定時任務(wù)
 * <p>
 * https://cron.qqe2.com/ cron表達式網(wǎng)站
 */
@Component
public class OrderJob {


    @Autowired
    private OrderService orderService;

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

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

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

啟動類

在啟動類中開啟定時器

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: 自動裝配注解
 * @EnableAutoConfiguration
 */
@Slf4j
@ServletComponentScan
@SpringBootApplication
//@EnableTransactionManagement /*開啟事務(wù)管理 - 但是因為springboot自動裝配(事務(wù)的自動裝配)的關(guān)系我們不去使用這個注釋*/
@MapperScan(basePackages = "com.laity.mapper")  /*掃描 mybatis 通用 mapper 所在的包*/
// 掃描所有包 以及 相關(guān)組件包 idworker => 主鍵生成
@ComponentScan(basePackages = {"com.laity", "org.n3r.idworker"})
@EnableScheduling  /*開啟定時任務(wù)*/
public class Application {
    public static void main(String[] args) {
        ConfigurableApplicationContext run = SpringApplication.run(Application.class, args);
        log.info(run.toString());
    }
}