安装

acts 是一个快速、轻量、可扩展的工作流引擎库，使用 YAML 格式定义工作流并通过消息驱动架构执行和分发消息。

安装 acts 库

通过 cargo 命令安装：

cargo add acts

安装外部存储

外部存储后端（sqlite/postgres/redis/nats/sled）在独立的 acts-store crate 中， 启用对应 feature 后从 acts_store 导入后端，再通过 EngineBuilder::set_store 指定（不设置时默认使用内存存储 MemoryStore）：

# SQLite
cargo add acts-store --features sqlite

# PostgreSQL
cargo add acts-store --features postgres

# NATS
cargo add acts-store --features nats

# Redis
cargo add acts-store --features redis

# Sled
cargo add acts-store --features sled

use acts::Engine;
use acts_store::SqliteStore; // 或 PostgresStore / RedisStore / NatsStore / SledStore
use std::sync::Arc;

#[tokio::main]
async fn main() -> acts::Result<()> {
    let store = SqliteStore::open("data/acts.db").await?;
    let engine = Engine::builder()
        .set_store(Arc::new(store))
        .start()
        .await?;
    Ok(())
}

acts 本身只内置 MemoryStore 与自定义存储所需的 KvStore trait；实现 acts::KvStore 的自定义后端同样通过 set_store 注入。

每个数据库只能有一个写入者：引擎的文档锁是进程内的——同一进程内的所有引擎共享 一张锁表（不同数据库用到了相同键时会被一并串行化，只是多了一点争用），但它不 跨进程，所以两个进程写同一个数据库时彼此没有互斥，同一行的并发更新可能让索引行与 数据行不一致：查询命中已不再持有的值，或漏掉当前值。单实例部署不受影响；多实例 部署请各自使用独立数据库，或在引擎之外自行协调（后端条件写，或覆盖读取过程的锁） ——batch 只保证单次写入原子，不代表「读取 + 另一个进程的写入」是原子的。

创建引擎

#![allow(unused)]
fn main() {
use acts::{Engine, Principal};

let engine = Engine::builder().start().await.unwrap();
// executor 代表一个调用者；直接驱动引擎的嵌入式调用者用的是引擎自身的身份
// （见"访问控制"一章）
let executor = engine.executor(&Principal::unrestricted());
}

部署和启动工作流

#![allow(unused)]
fn main() {
use acts::{Engine, Principal, Vars, Workflow};

let engine = Engine::builder().start().await.unwrap();

// 加载 YAML 模型
let model = r#"
id: my_model
name: my model
steps:
  - name: step 1
    uses: acts.transform.set
    params:
      a: 10
  - name: step 2
    uses: acts.transform.code
    params: |
      return { data: a + 10 };
"#;
let workflow = Workflow::from_yml(model).unwrap();

// 部署模型
let executor = engine.executor(&Principal::unrestricted());
executor.model().deploy(&workflow).expect("fail to deploy workflow");

// 启动工作流
let mut vars = Vars::new();
vars.set("a", 0);
vars.set("pid", "w1");
executor.proc().start(&workflow.id, vars).expect("fail to start workflow");
}

关联项目