Struct ServiceRuntime 

pub struct ServiceRuntime { /* private fields */ }

服务运行时

统一管理服务的生命周期，包括：

• 任务启动和管理（HTTP, gRPC, MQ 消费者等）
• 服务注册和注销
• 优雅停机
• 状态监控

示例

简单模式（不注册服务）

use flare_core_runtime::ServiceRuntime;
use flare_core_runtime::task::SpawnTask;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let runtime = ServiceRuntime::new("my-service")
        .add_spawn("my-task", async { Ok(()) });

    runtime.run().await?;
    Ok(())
}

完整模式（带服务注册）

use flare_core_runtime::ServiceRuntime;
use std::net::SocketAddr;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let runtime = ServiceRuntime::new("my-service")
        .with_address("0.0.0.0:8080".parse().unwrap())
        .add_spawn("grpc", async { Ok(()) });

    runtime.run_with_registration(|addr| {
        Box::pin(async move {
            // 注册服务
            Ok(None)
        })
    }).await?;
    Ok(())
}

Implementations

impl ServiceRuntime

pub fn new(service_name: impl Into<String>) -> Self

创建新的服务运行时

参数

• service_name - 服务名称（用于日志和服务注册）

示例

use flare_core_runtime::ServiceRuntime;

let runtime = ServiceRuntime::new("my-service");

pub fn simple() -> Self

创建简单的任务运行器（无需服务名和地址）

用于运行 MQ 消费者、自定义任务等简单场景

示例

use flare_core_runtime::ServiceRuntime;

// 仅运行 MQ 消费者
let runtime = ServiceRuntime::simple()
    .add_spawn("kafka-consumer", async { Ok(()) });

pub fn mq_consumer() -> Self

创建 MQ 消费者运行器

专门用于运行 MQ 消费者的便捷方法

示例

use flare_core_runtime::ServiceRuntime;

let runtime = ServiceRuntime::mq_consumer()
    .add_spawn("kafka-consumer", async { Ok(()) })
    .add_spawn("nats-consumer", async { Ok(()) });

pub fn tasks() -> Self

创建自定义任务运行器

专门用于运行自定义任务的便捷方法

示例

use flare_core_runtime::ServiceRuntime;

let runtime = ServiceRuntime::tasks()
    .add_spawn("task-1", async { Ok(()) })
    .add_spawn("task-2", async { Ok(()) });

pub fn with_address(self, address: SocketAddr) -> Self

设置服务地址

参数

• address - 服务地址（用于服务注册）

pub fn with_config(self, config: RuntimeConfig) -> Self

设置运行时配置

pub fn with_registry(self, registry: Box<dyn ServiceRegistry>) -> Self

设置服务注册器

pub fn with_health_checker(self, checker: HealthChecker) -> Self

设置健康检查器

pub fn add_health_check(self, check: Arc<dyn HealthCheck>) -> Self

添加健康检查项

pub fn with_health_failure_action(self, action: HealthFailureAction) -> Self

设置健康检查失败时的行为

pub fn add_task(self, task: Box<dyn Task>) -> Self

添加任务

参数

• task - 要添加的任务（实现了 Task trait）

pub fn add_spawn<Fut>(self, name: impl Into<String>, future: Fut) -> Self

where Fut: Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'static,

添加 spawn 任务（直接添加 Future）

参数

• name - 任务名称
• future - 要运行的 Future

示例

use flare_core_runtime::ServiceRuntime;

let runtime = ServiceRuntime::new("my-service")
    .add_spawn("my-task", async { Ok(()) });

pub fn add_spawn_with_deps<Fut>( self, name: impl Into<String>, future: Fut, dependencies: Vec<String>, ) -> Self

where Fut: Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'static,

添加 spawn 任务（带依赖）

pub fn add_spawn_with_shutdown<F, Fut>( self, name: impl Into<String>, future_fn: F, ) -> Self

where F: FnOnce(Receiver<()>) -> Fut + Send + 'static, Fut: Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'static,

添加 spawn 任务（需要 shutdown）

pub fn state_tracker(&self) -> Arc<StateTracker>

获取状态追踪器

pub async fn run(self) -> Result<()>

运行服务（简单模式，不注册服务）

执行以下步骤：

1. 启动所有任务
2. 等待所有任务就绪
3. 等待关闭信号（Ctrl+C）
4. 优雅关闭所有任务

pub async fn run_with_signals( self, signals: Vec<Box<dyn ShutdownSignal>>, ) -> Result<()>

运行服务（带自定义信号）

参数

• signals - 自定义停机信号列表

pub async fn run_with_registration<F, Fut>(self, register_fn: F) -> Result<()>

where F: FnOnce(SocketAddr) -> Fut, Fut: Future<Output = Result<Option<Box<dyn ServiceRegistry>>, Box<dyn Error + Send + Sync>>> + Send,

运行服务（带服务注册）

执行以下步骤：

1. 启动所有任务
2. 等待所有任务就绪
3. 注册服务
4. 等待关闭信号
5. 注销服务
6. 优雅关闭所有任务

pub async fn run_with_registration_and_signals<F, Fut>( self, register_fn: F, signals: Vec<Box<dyn ShutdownSignal>>, ) -> Result<()>

where F: FnOnce(SocketAddr) -> Fut, Fut: Future<Output = Result<Option<Box<dyn ServiceRegistry>>, Box<dyn Error + Send + Sync>>> + Send,

运行服务（带服务注册 + 自定义停机信号）

聚合部署进程可注入 ChannelSignal， 让多个注册型服务共享同一个外部生命周期控制。