r2d2-redis

redis-rs 是一个用于 r2d2 连接池的支持库，完全基于 Steven Fackler 的 r2d2-postgres。所有荣誉都归他。

文档可在 此处 查看。

r2d2-redis 最初由 @nevdelap 开发，由于没有足够的时间维护，他已经将仓库迁移到这里。感谢你所有的辛勤工作，@nevdelap！

用法

将此内容添加到您的 Cargo.toml

[dependencies]
r2d2_redis = "0.14.0"

然后查看下面的示例。

示例

请参阅 示例 以获取可运行的示例。

标准用法

此示例展示了使用 redis::Commands 提供的便捷方法的典型用例。您会注意到它几乎与直接使用 redis crate 相同。多亏了 Deref 特性，您可以直接在连接池的连接上调用任何 Connection 方法。

使用 cargo run --example counter 运行

extern crate r2d2_redis;

use std::thread;

use r2d2_redis::{r2d2, RedisConnectionManager};
use r2d2_redis::redis::Commands;

fn main() {
    let manager = RedisConnectionManager::new("redis://127.0.0.1").unwrap();
    let pool = r2d2::Pool::builder()
        .build(manager)
        .unwrap();

    let mut handles = vec![];

    for _i in 0..10i32 {
        let pool = pool.clone();
        handles.push(thread::spawn(move || {
            let mut conn = pool.get().unwrap();
            let n: i64 = conn.incr("counter", 1).unwrap();
            println!("Counter increased to {}", n);
        }));
    }

    for h in handles {
        h.join().unwrap();
    }
}

手动查询构建

不幸的是，有些情况下无法使用 Deref 特性。这通常发生在您需要将 Redis 连接传递到其他地方时，例如手动构建查询和/或 Redis crate 没有公开特定命令的便捷方法（例如 PING）。在这些情况下，您必须直接使用并调用 Deref 特性。

使用 cargo run --example ping

extern crate r2d2_redis;

use std::ops::DerefMut;
use std::thread;

use r2d2_redis::{r2d2, redis, RedisConnectionManager};

fn main() {
    let manager = RedisConnectionManager::new("redis://127.0.0.1").unwrap();
    let pool = r2d2::Pool::builder()
        .build(manager)
        .unwrap();

    let mut handles = vec![];

    for _i in 0..10i32 {
        let pool = pool.clone();
        handles.push(thread::spawn(move || {
            let mut conn = pool.get().unwrap();
            let reply = redis::cmd("PING").query::<String>(conn.deref_mut()).unwrap();
            // Alternatively, without deref():
            // let reply = redis::cmd("PING").query::<String>(&mut *conn).unwrap();
            assert_eq!("PONG", reply);
        }));
    }

    for h in handles {
        h.join().unwrap();
    }
}