开发者

解决@Scheduled定时器使用@Thransactional事物问题

目录
  • @Scheduled定时器使用@Thransactional问题
    • 最近遇到一个非常棘手的问题
  • 关于Scheduled定时任务
    • 认识定时器
    • 定时器场景使用
    • 定时器的使用
      • Component
      • 启动类
  • 总结

    @Scheduled定时器使用@Thransactional问题

    最近遇到一个非常棘手的问题

    当jpa使用update/delete时如果不添加@Thransactional会报

    Executing an update/delete query;

    nested exception is Javax.persistence.TransactionRequiredException: Executing anupdate/delete queryphp

    可是我添加@Thransactional还是会报这个异http://www.devze.com

    问了好多同行,他们都是告诉我定时器不能使用事物,实际并不是这样的,我查看了很多资料是可以使用的,@Scheduled和@Thransaction不能在同一个类中。

    并且实体类要加上@EnableTransactionManagement注解,使我们这个工程支持事物

    后来我试了很多

    @Thransactional(rolbackFor=ThrowAble.class)
    @Thransactional(rolbackFor=Exception.class)
    @Thransactional(ReadOnly=false)//jpa默认不开启事物 等等就是想使事物进行回滚 可是造化弄人呀

    废话不多说,直接上最关键的!!

    // 在连接数据库也就是date jpa 工程的启动类中 配置
    @Bean(name="transactionManager")
    public PlatformTransacpythontuibManager configurationTm(EntityManagerFactory factory){
    	return new JpaTransactionManager(factory);
    }

    关于Scheduled定时任务

    认识定时器

    https://cron.qqe2.com/

    定时器表达式生成器

    定时器场景使用

    /*
        使用定时任务关闭超期未支付订单,会存在的弊端
            1、会有时间差,导致程序不严谨
            2、不支持集群:单机没毛病,使用集群后,就会有多个定时任务
                解决方案:只使用一台计算机节点,单独用来运行所有的定时任务
            3、会全表检索数据库,对数据库的性能有极大的影响:数据量大的情况
        定时任务,仅仅只适用于小型轻量级项目,传统项目
    
        最好使用消息队列 :MQ:RabbitMQ、RockerMQ、Kafka、ZeroM编程客栈Q...
            延时任务(队列)
     */

    定时器的使用

    1、需要定时执行的方法上加上@Schandroideduled注解,这个注解中可以指定定时执行的规则,稍后详细介绍。

    2、Spring容器中使用@EnableScheduling开启定时任务的执行,此时spring容器才可以识别@Scheduled标注的方法,然后自动定时执行。

    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: 定时任务
     * <p>
     * https://cron.qqe2.com/ cron表达式网站
     */
    @Component
    public class OrderJob {
    
    
        @Autowired
        private OrderService orderService;
    
        /*
            使用定时任务关闭超期未支付订单,会存在的弊端
                1、会有时间差,导致程序不严谨
                2、不支持集群:单机没毛病,使用集群后,就会有多个定时任务
                    解决方案:只使用一台计算机节点,单独用来运行所有的定时任务
                3、会全表检索数据库,对数据库的性能有极大的影响:数据量大的情况
            定时任务,仅仅只适用于小型轻量级项目,传统项目
    
            最好使用消息队列 :MQ:RabbitMQ、RockerMQ、Kafka、ZeroMQ...
                延时任务(队列)
         */
    
        /*定时检索未支付的订单,并将其关闭*/
        //@Scheduled(cron = "0/3 * * * * ?")
        @Scheduled(cron = "* * 0/1 * * ?")
        public void autoCloseorder() {
            orderService.closeOrder();
    //        System.out.println("执行定时任务,当前时间为:" + 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 /*开启事务管理 - 但是因为springboot自动装配(事务的自动装配)的关系我们不去使用这个注释*/
    @MapperScan(basePackages = "com.laity.mapper")  /*扫描 mybatis 通用 mapper 所在的包*/
    // 扫描所有包 以及 相关组件包 idworker => 主键生成
    @ComponentScan(basePackages = {"com.laity", "org.n3r.idworker"})
    @EnableScheduling  /*开启定时任务*/
    public class Application {
        public static void main(String[] args) {
            ConfigurableApplicationContext run = SpringApplication.run(Application.class, args);
            log.info(run.toString());
        }
    }

    总结

    以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程客栈(www.devze.com)。

    0

    上一篇:

    下一篇:

    精彩评论

    暂无评论...
    验证码 换一张
    取 消

    最新开发

    开发排行榜