Lib.rs

Lapin支持bb8连接池。

使用方法

有关如何使用连接池的详细信息，请参阅bb8的文档。

use bb8_lapin::prelude::*;

async fn example() {
    let manager = LapinConnectionManager::new("amqp://guest:[email protected]:5672//", ConnectionProperties::default());
    let pool = bb8::Pool::builder()
        .max_size(15)
        .build(manager)
        .await
        .unwrap();
    for _ in 0..20 {
        let pool = pool.clone();
        tokio::spawn(async move {
            let conn = pool.get().await.unwrap();
            // use the connection
            // it will be returned to the pool when it falls out of scope.
        });
    }
}

有关更多示例，请参阅示例文件夹中的文件。

构建时要求

该软件包已在ubuntu-latest上针对nightly和稳定版Rust进行测试。它可能与较旧版本兼容，但这尚未经过测试。请参阅bb8和lapin软件包的详细信息以了解其要求。