Spring中定时任务@Scheduled的一点小小研究

最近做一个公众号项目,微信公众号会要求服务端找微信请求一个access_token,获取的过程:

access_token是公众号的全局唯一接口调用凭据,公众号调用各接口时都需使用access_token。开发者需要进行妥善保存。access_token的存储至少要保留512个字符空间。access_token的有效期目前为2个小时,需定时刷新,重复获取将导致上次获取的access_token失效。

公众平台的API调用所需的access_token的使用及生成方式说明:

1、建议公众号开发者使用中控服务器统一获取和刷新Access_token,其他业务逻辑服务器所使用的access_token均来自于该中控服务器,不应该各自去刷新,否则容易造成冲突,导致access_token覆盖而影响业务;

2、目前Access_token的有效期通过返回的expire_in来传达,目前是7200秒之内的值。中控服务器需要根据这个有效时间提前去刷新新access_token。在刷新过程中,中控服务器可对外继续输出的老access_token,此时公众平台后台会保证在5分钟内,新老access_token都可用,这保证了第三方业务的平滑过渡;

3、Access_token的有效时间可能会在未来有调整,所以中控服务器不仅需要内部定时主动刷新,还需要提供被动刷新access_token的接口,这样便于业务服务器在API调用获知access_token已超时的情况下,可以触发access_token的刷新流程。

所以解决方案就是做一个定时任务,服务启动的时候获取一次token,之后每隔两小时自动获取一次。这用Spring的@Scheduled注解很容易实现:

@Override
    @Scheduled(fixedRate=1000*60*59*2)
    public void updateToken() {

        try{
            for(AppConfig appConfig : SysConfig.AppLists){
                Token token = TokenAPI.token(appConfig.wxAppId,appConfig.wxAppSecret);
                appConfig.access_token = token.getAccess_token();
                Ticket ticket = TicketAPI.ticketGetticket(token.getAccess_token());
                appConfig.ticket = ticket.getTicket();
                logger.info("access_token:" + token.getAccess_token()+",js_api_ticket:"+ticket.getTicket());
            }
        }catch (Exception e){
            logger.info("刷新access_token出错");
        }
    }

这里使用fixedRate来指定任务执行的时间间隔(毫秒记)。

然后因为现在项目只有一个服务号,没有申请测试用的服务号,本地调试也会去获取access_token ,结果导致服务端的生产环境的token失效,必须重启服务器的tomcat来刷新token。显然这种做法是非常愚蠢的,目前还没正式投入使用,投入使用后这显然不能接受。

解决方案就是,统一一个接口来向服务端获取token,当token失效时,执行一次updateToken的方法,以刷新token。

===================================================================手动分割线============================================================

然后我就比较好奇一个事,那就是,当加了@Scheduled(fixedRate=1000*60*59*2)的方法被其他方法调用的时候,定时任务会有变化吗?比如,我调用一次,那么任务是还是按照以前预定的时间跑呢,还是会在我调用之后的2小时(预约的间隔时间)才会再跑?百度Google找了找,包括官方文档也没给个说法。为这个也不想去看源代码,还是写个demo验证下算了。

首先创建一个Spring Boot的项目,引入web模块(使用rest请求来手动调用定时任务)

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

项目结构:

Service接口:

package com.xiatingfei.schedule.demo.service;

public interface TaskService {

    void SayHelloTask();

}

Service实现(每隔10秒钟在控制台打印一次Hello!):

package com.xiatingfei.schedule.demo.service.impl;

import com.xiatingfei.schedule.demo.service.TaskService;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.text.SimpleDateFormat;
import java.util.Date;

@Service
public class TaskServiceImpl implements TaskService {

    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

    @Override
    @Scheduled(fixedRate = 10000)
    public void SayHelloTask() {
        System.out.println("Hello! Now is "  + dateFormat.format(new Date()));
    }
}

Controller:

package com.xiatingfei.schedule.demo.controller;

import com.xiatingfei.schedule.demo.service.TaskService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/demo")
public class TriggerController {

    @Autowired
    TaskService taskService;

    @RequestMapping("/sayHello")
    public void TriggerTask(){
        taskService.SayHelloTask();
    }

}

然后在SpringBoot的启动类加入定时任务的注解@EnableScheduling

package com.xiatingfei.schedule.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

启动应用,可以看到控制台可以定时打印Hello和时间:

在Postman给服务端发一个请求,手动调用定时任务:

get http://localhost:8080/demo/sayHello

结果:

可以看到定时任务没有受到调用的影响,还是按照自己的节奏10秒钟一次~~

(而且,还会发现Spring会在第一次收到Http请求的时候才会初始化dispatcherServlet,而不是服务启动的时候就初始化)

原文地址:https://www.cnblogs.com/xtf2009/p/9614496.html

时间: 2024-10-03 22:40:39

Spring中定时任务@Scheduled的一点小小研究的相关文章

Spring Boot 定时任务 @Scheduled

项目开发中经常需要执行一些定时任务,比如在每天凌晨,需要从 implala 数据库拉取产品功能活跃数据,分析处理后存入到 MySQL 数据库中.类似这样的需求还有许多,那么怎么去实现定时任务呢,有以下几种实现方式. Java 定时任务的几种实现方式 基于 java.util.Timer 定时器,实现类似闹钟的定时任务 使用 Quartz.elastic-job.xxl-job 等开源第三方定时任务框架,适合分布式项目应用 使用 Spring 提供的一个注解: @Schedule,开发简单,使用比

(4) Spring中定时任务Quartz集群配置学习

原 来配置的Quartz是通过spring配置文件生效的,发现在非集群式的服务器上运行良好,但是将工程部署到水平集群服务器上去后改定时功能不能正常运 行,没有任何错误日志,于是从jar包.JDK版本.cronExpression到服务器类型,甚至查到了服务器操作系统的类型,都没能找到解决的办 法,后来才知道是集群惹的祸! 详细步骤如下: 1. 按照Quartz集群工作原理 图:表示了每个节点直接与数据库通信,若离开数据库将对其他节点一无所知 在数据库中建表.建表模版在Quartz包下docs/d

在Spring项目中使用@Scheduled注解定义简单定时任务

如题所示,有时候我们需要在Web项目中配置简单的定时任务,而且因为任务并不复杂不想使用定时调度框架(PS:Quartz.ActiveMQ .Kafka等),这时就可以考虑使用@Scheduled注解来定义简单的定时任务.其全部配置如下: (1)在Spring的配置文件中添加定时任务相关配置: xml配置的头文件中添加: xmlns:task="http://www.springframework.org/schema/task" 以及在xsi:schemaLocation中添加: ht

Spring中使用注解 @Scheduled执行定时任务

注解@Scheduled 可以作为一个触发源添加到一个方法中,例如,以下的方法将以一个固定延迟时间5秒钟调用一次执行,这个周期是以上一个调用任务的完成时间为基准,在上一个任务完成之后,5s后再次执行: 1 @Scheduled(fixedDelay=5000) 2 public void doSomething() { 3 // something that should execute periodically 4 } 如果需要以固定速率执行,只要将注解中指定的属性名称改成fixedRate即

spring 定时任务@Scheduled

1.配置文件 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:task="http://www.springframework.org

Spring定时任务@Scheduled的cron表达式

Spring定时任务@Scheduled可以使用cron表达式,来定时时间节点和频率. 一个cron表达式至少有6个(也可能7个)有空格分隔的时间元素. 按顺序依次为 秒(0~59) 分钟(0~59) 小时(0~23) 天(月)(0~31,但是你需要考虑你月的天数) 月(1~12) 天(星期)(1~7 1=SUN 或 SUN,MON,TUE,WED,THU,FRI,SAT) 7.年份(1970-2099) 其中每个元素可以是一个值(如6),一个连续区间(9-12),一个间隔时间(8-18/4)(

spring boot 学习(八)定时任务 @Scheduled

SpringBoot 定时任务 @Scheduled 前言 有时候,我们有这样的需求,需要在每天的某个固定时间或者每隔一段时间让应用去执行某一个任务.一般情况下,可以使用多线程来实现这个功能:在 Spring 框架下可以搭配 Quartz 来实现,附上笔记 Spring Quartz 实现多任务定时调用.在 SpringBoot 框架下,我们可以用 Spring scheduling 来实现定时任务功能. 首先,我们先创建一个 Spring Boot 项目.创建方法: * (自动完成初始化)ht

通过源码理解Spring中@Scheduled的实现原理并且实现调度任务动态装载

前提 最近的新项目和数据同步相关,有定时调度的需求.之前一直有使用过Quartz.XXL-Job.Easy Scheduler等调度框架,后来越发觉得这些框架太重量级了,于是想到了Spring内置的Scheduling模块.而原生的Scheduling模块只是内存态的调度模块,不支持任务的持久化或者配置(配置任务通过@Scheduled注解进行硬编码,不能抽离到类之外),因此考虑理解Scheduling模块的底层原理,并且基于此造一个简单的轮子,使之支持调度任务配置:通过配置文件或者JDBC数据

spring中quatz的多定时任务配置图文详解

近来公司让用quatz框架做定时功能,而且还是执行多定时任务,真是苦恼. 虽然从网上搜了很多资料,但是写法上不太尽如人意,最后还是请教了螃蟹大神,给的配置建议就是简单啊,现在拿来分享下: 这里我们需要的有两部分,一个是java中的处理类,一个是quatz的配置文件,截图如下applicationContext_quartz.xmlquatz的配置文件地址地址:http://www.itxxz.com/a/kuangjia/kuangjiashili/2014/0602/10.html java中