快捷導(dǎo)航

Rust操作Redis從入門到生產(chǎn)級應(yīng)用

更新時間：2026年05月06日 09:00:07 作者：Rust研習(xí)社

本文將基于主流的redis-rs庫,帶你全面掌握Rust操作Redis的技巧,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

在現(xiàn)代后端開發(fā)中，Redis 作為高性能的內(nèi)存數(shù)據(jù)庫，廣泛用于緩存、會話管理、消息隊(duì)列等場景。本文將基于主流的 redis-rs 庫，帶你全面掌握 Rust 操作 Redis 的技巧，覆蓋同步/異步雙模式、連接池、序列化等內(nèi)容。

添加庫依賴

在 Cargo.toml 中配置依賴：

[dependencies]
redis = { version = "1.2", features = [
    "tokio-comp",            # 異步支持
    "connection-manager",    # 內(nèi)置連接池
    "tokio-native-tls-comp",
] }
tokio = { version = "1", features = ["full"] }
anyhow = "1.0"

基礎(chǔ)操作

redis-rs 對 Redis 原生命令做了優(yōu)雅封裝，API 與 Redis 命令高度一致，學(xué)習(xí)成本極低，同時依托 Rust 的編譯期檢查，能從根源規(guī)避類型錯誤、命令誤用等問題。以下示例分別展示同步與異步模式下的基礎(chǔ)操作。

同步模式：簡單場景快速上手

同步模式適合簡單腳本、單線程工具等場景，核心是通過 Client 創(chuàng)建連接，再通過 Commands 特征調(diào)用 Redis 命令：

use anyhow::Result;
use redis::{Client, Commands};
fn main() -> Result<()> {
    // 創(chuàng)建 Redis 客戶端
    let client = Client::open("redis://127.0.0.1:6379")?;
    // 獲取連接（同步連接）
    let mut conn = client.get_connection()?;
    // 字符串操作：SET / GET
    let _: () = conn.set("username", "rust_dev")?; // SET 命令，返回空元組
    let username: Option<String> = conn.get("username")?; // GET 命令，返回 Option（避免空值 panic）
    println!("獲取 username: {:?}", username); // 輸出：Some("rust_dev")
    // 哈希操作：HSET / HGET / HGETALL
    let _: () = conn.hset("user:1", "id", 1)?;
    let _: () = conn.hset("user:1", "name", "Alice")?;
    let user_name: Option<String> = conn.hget("user:1", "name")?;
    let user: Option<redis::Value> = conn.hgetall("user:1")?; // 獲取整個哈希
    println!("獲取用戶名稱: {:?}", user_name); // 輸出：Some("Alice")
    println!("獲取用戶全部信息: {:?}", user);
    // 列表操作：LPUSH / LRANGE
    let _: () = conn.lpush("tasks", "learn redis")?;
    let _: () = conn.lpush("tasks", "learn rust")?;
    let tasks: Vec<String> = conn.lrange("tasks", 0, -1)?; // 獲取所有列表元素
    println!("任務(wù)列表: {:?}", tasks); // 輸出：["learn rust", "learn redis"]
    // 刪除操作：DEL
    let _: () = conn.del("username")?;
    Ok(())
}

異步模式：高并發(fā)場景首選

異步模式基于 Tokio 實(shí)現(xiàn)，非阻塞 IO，其 API 與同步模式高度一致：

use anyhow::Result;
use redis::{AsyncCommands, Client};

#[tokio::main]
async fn main() -> Result<()> {
    // 創(chuàng)建 Redis 客戶端
    let client = Client::open("redis://127.0.0.1:6379")?;
    // 獲取異步連接
    let mut conn = client.get_multiplexed_async_connection().await?;

    // 異步操作：與同步模式 API 一致
    let _: () = conn.set("async_key", "async_value").await?;
    let async_value: Option<String> = conn.get("async_key").await?;
    println!("異步獲取值: {:?}", async_value); // 輸出：Some("async_value")

    // 哈希操作（異步）
    let _: () = conn.hset("async_user:1", "age", 25).await?;
    let age: Option<i32> = conn.hget("async_user:1", "age").await?;
    println!("異步獲取用戶年齡: {:?}", age); // 輸出：Some(25)

    Ok(())
}

進(jìn)階特性

在實(shí)際生產(chǎn)環(huán)境中，僅基礎(chǔ)操作遠(yuǎn)遠(yuǎn)不夠，redis-rs 提供還提供了連接池、管道、事務(wù)、序列化等特性，能幫助我們構(gòu)建更穩(wěn)定、高效的服務(wù)。

連接池：高并發(fā)下的連接管理

頻繁創(chuàng)建/銷毀 Redis 連接會嚴(yán)重影響性能，connection-manager 特性提供了內(nèi)置連接池，能自動管理連接的創(chuàng)建、復(fù)用、銷毀和重連，無需手動處理連接生命周期：

use anyhow::Result;
use redis::{AsyncCommands, Client};

#[tokio::main]
async fn main() -> Result<()> {
    // 創(chuàng)建 Redis 客戶端
    let client = Client::open("redis://127.0.0.1:6379")?;
    // 創(chuàng)建連接池，默認(rèn)配置
    // 另外可提供 get_connection_manager_with_config 自定義最大連接數(shù)、超時時間等
    let mut conn_manager = client.get_connection_manager().await?;

    // 從連接池獲取連接并執(zhí)行操作（自動復(fù)用連接）
    for i in 0..5 {
        let key = format!("pool_key:{}", i);

        let _: () = conn_manager.set(&key, i).await?;
        let value: Option<i32> = conn_manager.get(&key).await?;

        println!("連接池操作 {}: {:?}", key, value);
    }

    Ok(())
}

管道（Pipeline）：批量操作提升性能

Redis 管道允許將多個命令批量發(fā)送到服務(wù)器，減少網(wǎng)絡(luò)往返次數(shù)，顯著提升批量操作的性能。redis-rs 支持管道的鏈?zhǔn)秸{(diào)用，通過 pipe() 創(chuàng)建管道，添加命令后通過 exec() 或 query() 執(zhí)行：

use anyhow::Result;
use redis::{Client, pipe};

#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::open("redis://127.0.0.1:6379")?;
    let mut conn = client.get_connection()?;

    // 創(chuàng)建管道，批量執(zhí)行 SET 命令（無返回值）
    pipe()
        .set("pipe_key1", "value1")
        .set("pipe_key2", "value2")
        .set("pipe_key3", "value3")
        .exec(&mut conn)?;
    println!("管道批量 SET 執(zhí)行完成");

    // 批量執(zhí)行 GET 命令（獲取返回值）
    let (val1, val2, val3): (Option<String>, Option<String>, Option<String>) = pipe()
        .get("pipe_key1")
        .get("pipe_key2")
        .get("pipe_key3")
        .query(&mut conn)?;
    println!("管道批量 GET 結(jié)果: {:?}, {:?}, {:?}", val1, val2, val3);

    Ok(())
}

事務(wù)（Transaction）：保證操作原子性

Redis 事務(wù)通過 MULTI、EXEC 命令實(shí)現(xiàn)，確保多個命令原子性執(zhí)行（要么全部成功，要么全部失?。?。redis-rs 通過管道提供的 atomic() 方法進(jìn)行事務(wù)操作：

use anyhow::Result;
use redis::{Client, pipe};

#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::open("redis://127.0.0.1:6379")?;
    let mut conn = client.get_connection()?;

    // 開啟事務(wù)
    let mut pipe = pipe();
    pipe.atomic();

    // 向事務(wù)中添加命令
    pipe.set("tx_key1", "tx_val1")
        .hset("tx_user:1", "name", "Bob")
        .lpush("tx_tasks", "finish transaction");

    // 執(zhí)行事務(wù)（通過 query 發(fā)送所有命令）
    let results: Vec<redis::Value> = pipe.query(&mut conn)?;
    println!("事務(wù)執(zhí)行結(jié)果: {:?}", results);

    Ok(())
}

Lua 腳本：擴(kuò)展 Redis 功能與原子操作

Redis 支持通過 Lua 腳本執(zhí)行簡單原子操作，redis-rs 提供簡潔的 API 可快速調(diào)用腳本：

use anyhow::Result;
use redis::{Client, Script};

// 定義結(jié)構(gòu)體
#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::open("redis://127.0.0.1:6379")?;
    let mut conn = client.get_multiplexed_async_connection().await?;

    // 定義 Lua 腳本：自增指定 key，返回自增后的值
    let lua_script = Script::new(
        r#"
        local key = KEYS[1]
        -- 調(diào)用 Redis 原生命令 INCR，實(shí)現(xiàn)自增
        return redis.call('INCR', key)
    "#,
    );

    // 執(zhí)行腳本：通過 .key() 傳遞 KEYS 參數(shù)
    let new_val: i32 = lua_script
        .key("simple_lua_counter") // 添加 KEY
        .invoke_async(&mut conn) // 執(zhí)行腳本
        .await?;
    println!("Lua 腳本執(zhí)行結(jié)果（自增后）: {}", new_val); // 首次執(zhí)行輸出 1

    // 傳遞參數(shù)的簡單示例，設(shè)置 key 值并返回
    let set_and_get_script = Script::new(
        r#"
        local key = KEYS[1]
        local val = ARGV[1]
        redis.call('SET', key, val)
        return val
    "#,
    );

    let result: String = set_and_get_script
        .key("lua_test_key") // 添加 KEY
        .arg("test_value") // 添加 ARG
        .invoke_async(&mut conn)
        .await?;
    println!("設(shè)置并返回值: {}", result); // 輸出 test_value

    Ok(())
}

注意事項(xiàng)與最佳實(shí)踐

錯誤處理

Rust 強(qiáng)調(diào)錯誤處理的嚴(yán)謹(jǐn)性，redis-rs 的所有操作都會返回 RedisResult，實(shí)際開發(fā)中應(yīng)避免使用 unwrap()，建議通過 ? 關(guān)鍵字傳播錯誤，或者使用 thiserror 自定義錯誤類型，提升代碼可維護(hù)性。

連接池配置

生產(chǎn)環(huán)境中，需根據(jù)并發(fā)量合理配置連接池的最大連接數(shù)（默認(rèn) 10），避免連接數(shù)過多導(dǎo)致 Redis 服務(wù)壓力過大，或連接數(shù)過少導(dǎo)致請求阻塞。同時可設(shè)置連接超時時間，防止連接泄露。

數(shù)據(jù)類型匹配

redis-rs 是強(qiáng)類型客戶端，Redis 數(shù)據(jù)類型與 Rust 類型需嚴(yán)格匹配（如 Redis 字符串對應(yīng) Rust 的 String，Redis 數(shù)字對應(yīng) Rust i32/u64 等），否則會導(dǎo)致編譯錯誤或運(yùn)行時錯誤。