spring rs下载 - spring rs源代码下载

spring rs

网站数据

0.3.0

下载

Spring-RS是由Rust编写的应用框架，灵感来自Java的Springboot

英语｜｜

Spring-RS是一个应用程序框架，强调了由Java的Springboot启发而不是配置而不是配置。 Spring-RS提供了一个易于扩展的插件系统，用于在Rust社区中集成出色的项目，例如Axum，SQLX，Sea-orm，等。

与Java中的Springboot相比，Spring-RS具有更高的性能和较低的内存使用情况，使您可以完全摆脱肿的JVM和Travel Light。

特征

Spring-RS从很棒的Rust语言中受益，从而受益于C/C ++的最终性能
高安全性：与C/C ++相比， Spring-RS使用的Rust语言提供了内存安全性和线程安全性。
？轻量级：Spring-RS的核心代码不超过5,000行，并且Rust包装的发行版本的二进制尺寸也很小。
？易于使用： Spring-RS提供了清晰简洁的API和可选的程序宏来简化开发。
？高度扩展： Spring-RS使用高度扩展的插件模型，用户可以自定义插件来扩展程序功能。
高度可配置的： Spring-RS使用TOML来配置应用程序和插件来提高应用程序灵活性。

例子

网络

 use spring :: { auto_config , App } ;
use spring_sqlx :: {
    sqlx :: { self , Row } ,
    ConnectPool , SqlxPlugin
} ;
use spring_web :: { get , route } ;
use spring_web :: {
    error :: Result , extractor :: { Path , Component } , handler :: TypeRouter , axum :: response :: IntoResponse , Router ,
    WebConfigurator , WebPlugin ,
} ;
use anyhow :: Context ;

# [ auto_config ( WebConfigurator ) ]
# [ tokio :: main ]
async fn main ( ) {
    App :: new ( )
        . add_plugin ( SqlxPlugin )
        . add_plugin ( WebPlugin )
        . run ( )
        . await
}

# [ get ( "/" ) ]
async fn hello_world ( ) -> impl IntoResponse {
    "hello world"
}

# [ route ( "/hello/:name" , method = "GET" , method = "POST" ) ]
async fn hello ( Path ( name ) : Path < String > ) -> impl IntoResponse {
    format ! ( "hello {name}" )
}

# [ get ( "/version" ) ]
async fn sqlx_request_handler ( Component ( pool ) : Component < ConnectPool > ) -> Result < String > {
    let version = sqlx :: query ( "select version() as version" )
        . fetch_one ( & pool )
        . await
        . context ( "sqlx query failed" ) ?
        . get ( "version" ) ;
    Ok ( version )
}

工作

 use anyhow :: Context ;
use spring :: { auto_config , App } ;
use spring_job :: { cron , fix_delay , fix_rate } ;
use spring_job :: { extractor :: Component , JobConfigurator , JobPlugin } ;
use spring_sqlx :: {
    sqlx :: { self , Row } ,
    ConnectPool , SqlxPlugin ,
} ;
use std :: time :: { Duration , SystemTime } ;

# [ auto_config ( JobConfigurator ) ]
# [ tokio :: main ]
async fn main ( ) {
    App :: new ( )
        . add_plugin ( JobPlugin )
        . add_plugin ( SqlxPlugin )
        . run ( )
        . await ;

    tokio :: time :: sleep ( Duration :: from_secs ( 100 ) ) . await ;
}

# [ cron ( "1/10 * * * * *" ) ]
async fn cron_job ( Component ( db ) : Component < ConnectPool > ) {
    let time : String = sqlx :: query ( "select TO_CHAR(now(),'YYYY-MM-DD HH24:MI:SS') as time" )
        . fetch_one ( & db )
        . await
        . context ( "query failed" )
        . unwrap ( )
        . get ( "time" ) ;
    println ! ( "cron scheduled: {:?}" , time )
}

# [ fix_delay ( 5 ) ]
async fn fix_delay_job ( ) {
    let now = SystemTime :: now ( ) ;
    let datetime : sqlx :: types :: chrono :: DateTime < sqlx :: types :: chrono :: Local > = now . into ( ) ;
    let formatted_time = datetime . format ( "%Y-%m-%d %H:%M:%S" ) ;
    println ! ( "fix delay scheduled: {}" , formatted_time )
}

# [ fix_rate ( 5 ) ]
async fn fix_rate_job ( ) {
    tokio :: time :: sleep ( Duration :: from_secs ( 10 ) ) . await ;
    let now = SystemTime :: now ( ) ;
    let datetime : sqlx :: types :: chrono :: DateTime < sqlx :: types :: chrono :: Local > = now . into ( ) ;
    let formatted_time = datetime . format ( "%Y-%m-%d %H:%M:%S" ) ;
    println ! ( "fix rate scheduled: {}" , formatted_time )
}