Lib.rs

注意：此项目已被存档。请考虑使用bb8或mobc连接管理器。

Lapin对r2d2连接池的支持。

用法

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

use lapin::ConnectionProperties;
use r2d2_lapin::LapinConnectionManager;
use std::thread;

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

构建时要求

该包在ubuntu-latest上针对以下rust版本进行了测试：nightly、beta、stable和1.45.0。它可能与旧版本兼容，但未进行测试。请参阅r2d2和lapin包的详细要求。