在MongoDB中实现分布式互斥锁。

该库仅包含同步实现。如果您需要异步版本，请使用mongo-lock-async库。

该实现依赖于系统时间。请确保您的服务器上NTP客户端配置正确。

安装

将此库添加到Cargo.toml

[dependencies]
mongo_lock = "0"

使用

fn main() {
    let mongo = mongodb::sync::Client::with_uri_str("mongodb://127.0.0.1").unwrap();

    // We need to ensure that mongodb collection has a proper index.
    mongo_lock::prepare_database(&mongo).unwrap();

    if let Ok(Some(lock)) =
        mongo_lock::Lock::try_acquire(
            &mongo,
            "my-key",
            std::time::Duration::from_secs(30)
        )
    {
        println!("Lock acquired.");

        // The lock will be released automatically after leaving the scope.
    }
}