spring-job插件

spring-job是基于tokio-cron-scheduler实现的

依赖

spring-job = { version = "0.1.1" }

API接口

App实现了JobConfigurator特征，可以通过该特征配置调度任务：

1
#[tokio::main]
2
async fn main() {
3
    App::new()
4
        .add_plugin(JobPlugin)
5
        .add_plugin(SqlxPlugin)
6
        .add_jobs(jobs())
7
        .run()
8
        .await
9
}
10

11
fn jobs() -> Jobs {
12
    Jobs::new().typed_job(cron_job)
13
}
14

15
#[cron("1/10 * * * * *")]
16
async fn cron_job() {
17
    println!("cron scheduled: {:?}", SystemTime::now())
18
}

你也可以使用auto_config宏来实现自动配置，这个过程宏会自动将被过程宏标记的调度任务注册进app中：

+#[auto_config(JobConfigurator)]
 #[tokio::main]
 async fn main() {
     App::new()
         .add_plugin(JobPlugin)
         .add_plugin(SqlxPlugin)
-        .add_jobs(jobs())
         .run()
         .await
}

提取插件注册的Component

上面的SqlxPlugin插件为我们自动注册了一个Sqlx连接池组件，我们可以使用Component从App中提取这个连接池。需要注意spring-job的Component和spring-web的Component虽然实现原理类似，但这两个extractor归属不同的crate下。

use spring_sqlx::{
    sqlx::{self, Row}, ConnectPool
};
use spring_job::cron;
use spring_job::extractor::Component;

#[cron("1/10 * * * * *")]
async fn cron_job(Component(db): Component<ConnectPool>) {
    let time: String = sqlx::query("select DATE_FORMAT(now(),'%Y-%m-%d %H:%i:%s') as time")
        .fetch_one(&db)
        .await
        .context("query failed")
        .unwrap()
        .get("time");
    println!("cron scheduled: {:?}", time)
}