Java?SpringTask定時自動化處理方法

更新時間：2024年08月02日 12:03:42 作者：Alphamilk

這篇文章主要介紹了Java?SpringTask定時自動化處理,通過自動化,不僅可以提高工作效率和準確性,還可以釋放人力資源以專注于更高價值的工作,需要的朋友可以參考下

一、自動化處理

1.1 什么是自動化處理

自動化處理是指使用軟件工具或程序自動執(zhí)行原本需要人工干預的任務。這些任務可以是重復性的、耗時的或者需要高度準確性的操作。通過自動化，不僅可以提高工作效率和準確性，還可以釋放人力資源以專注于更高價值的工作。

1.2 SpringTask介紹

二、SpringTask的基本使用

2.1 引入依賴

由于springTask 是SpringFramWork包的內容，所以不需要進行引入新的依賴。

2.2 通過控制臺加入注解啟用SpringTask

@SpringBootApplication
@EnableScheduling
public class SpringTaskApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringTaskApplication.class, args);
    }
}

2.3 使用Cron表達式規(guī)定時間

如果不會使用Cron表達式的使用可以直接使用cron的生成網站

https://cron.qqe2.com/

常用cron表達式：

2.4 通過@Schedule(Cron表達式) 實現定時任務（每兩秒執(zhí)行一次）

@Component
@Slf4j
public class springTaskTest {
//    每兩秒執(zhí)行一次
    @Scheduled(cron = "0/2 * * * * ?")
    public void AutoTask(){
        log.info("自動化代碼執(zhí)行中");
    }
}

三、實戰(zhàn)

要求實現一個用戶與AI助手對話交互表，要求一個用戶一天最多能對話200次，并且為了控制并發(fā)量，每個用戶在一分鐘之內最多進行對話十次。

3.1 創(chuàng)建一個交互表

CREATE TABLE user_request_log (
    user_id BIGINT NOT NULL,
    request_date DATE NOT NULL,
    total_requests INT DEFAULT 200,
    minute_requests INT DEFAULT 10,
    minute_start_time DATETIME,
    PRIMARY KEY (user_id, request_date),
    INDEX idx_minute_start_time (minute_start_time)
);

user_id: 用戶ID，作為主鍵的一部分，類型為BIGINT。
request_date: 當天的日期，作為主鍵的一部分，類型為DATE。
total_requests: 當天的總請求次數，類型為INT，默認值為0。
minute_requests: 當前分鐘的請求次數，類型為INT，默認值為0。
minute_start_time: 當前分鐘開始的時間戳，類型為DATETIME。
主鍵由user_id和request_date組成，以確保每個用戶每天的記錄唯一。
添加了一個索引idx_minute_start_time以加快按minute_start_time查詢的速度。

3.2 引入mybatis-plus 并配置數據庫

依賴：

        <!--        數據庫依賴-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.5.5</version>
            <exclusions>
                <exclusion>
                    <groupId>org.mybatis</groupId>
                    <artifactId>mybatis-spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>3.0.3</version>
        </dependency>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
            <scope>runtime</scope>
        </dependency>

application.yml

spring:
  # 數據源配置
  datasource:
    url: jdbc:mysql://localhost:3306/ap_security?characterEncoding=utf-8&serverTimezone=UTC
    username: root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver
  application:
    name: SpringTask

使用mybatis-plus快速生成實體與架構

3.3 模擬訪問的Controller

@RestController
@Slf4j
@RequestMapping("/user")
public class UserController {
    @Autowired
    UserRequestLogMapper userRequestLogMapper;
//    模擬進行對話
    @GetMapping("/chat")
    public String Chat(){
        UserRequestLog userRequestLog = userRequestLogMapper.selectById(1);
//        當有次數時候才能進行對話
        if (userRequestLog.getTotalRequests()>0 && userRequestLog.getMinuteRequests()>0){
//            減去數量
            userRequestLog.setMinuteRequests(userRequestLog.getMinuteRequests()-1);
            userRequestLog.setTotalRequests(userRequestLog.getTotalRequests()-1);
            userRequestLogMapper.updateById(userRequestLog);
            return "對話成功";
        }else {
            return "您暫時已經沒有對話次數了";
        }
    }
}

3.4 設置定時任務

@Component
@Slf4j
public class springTaskTest {
    @Autowired
    UserRequestLogMapper userRequestLogMapper;
    //    每一分鐘執(zhí)行一次
    @Scheduled(cron = "0 0/1 * * * ?")
    public void AutoTask(){
        log.info("執(zhí)行增加分鐘對話次數");
        UserRequestLog userRequestLog = userRequestLogMapper.selectById(1);
        userRequestLog.setMinuteRequests(20);
        userRequestLogMapper.updateById(userRequestLog);
    }
    //    每天凌晨3點執(zhí)行一次
    @Scheduled(cron = "0 0 3 * * ?")
    public  void DayAuto(){
        log.info("執(zhí)行增加天數的總次數");
        UserRequestLog userRequestLog = userRequestLogMapper.selectById(1);
        userRequestLog.setTotalRequests(200);
        userRequestLogMapper.updateById(userRequestLog);
    }
}

測試：