Struct ConfigWatcher 

pub struct ConfigWatcher { /* private fields */ }

配置热重载观察器

在后台定时轮询配置文件修改时间，检测到变化时自动重新加载配置。 对齐 PHP think-swoole 的热重载机制，无需重启服务即可更新配置。

设计

• 使用 Arc<RwLock<AppConfig\>> 共享配置，读无锁、写互斥
• 轮询间隔默认 5 秒（可配置），通过 tokio::time::interval 实现
• 比较文件修改时间（mtime），避免频繁的文件读取
• 配置重载失败时保留旧配置，记录错误日志

用法

use sz_rust_core::config::{AppConfig, ConfigWatcher};
use std::sync::Arc;
use parking_lot::RwLock;

let config = AppConfig::load_from_dir("config/").unwrap();
let shared = Arc::new(RwLock::new(config));
let watcher = ConfigWatcher::new("config/", shared.clone());

// 启动后台监听（spawn 到 tokio runtime）
let handle = watcher.start();

// 读取最新配置（热重载后自动生效）
let current = shared.read().clone();

// 停止监听
handle.stop();

Implementations

impl ConfigWatcher

pub fn new( config_dir: impl Into<PathBuf>, shared_config: Arc<RwLock<AppConfig>>, ) -> Self

创建配置热重载观察器

参数

• config_dir：配置文件目录
• shared_config：共享配置（通过 Arc<RwLock<AppConfig>> 分享给业务层）

pub fn with_poll_interval(self, secs: u64) -> Self

设置轮询间隔（秒）

pub fn start(self) -> ConfigWatcherHandle

启动后台配置监听

返回 ConfigWatcherHandle，调用 stop() 可停止监听。