本文將帶你全面掌握 moka，從核心特性、基礎(chǔ)環(huán)境搭建，到同步/異步實(shí)戰(zhàn)、高級(jí)配置，再到生產(chǎn)環(huán)境最佳實(shí)踐與避坑指南，讓你快速在項(xiàng)目中落地這款高性能緩存庫(kù)。

moka 是什么？以及優(yōu)勢(shì)

moka 是一款純 Rust 實(shí)現(xiàn)的并發(fā)安全、高性能內(nèi)存緩存庫(kù)，靈感源自 Java 生態(tài)的 Caffeine 緩存庫(kù)，專為高并發(fā)服務(wù)端場(chǎng)景設(shè)計(jì)，專注于本地內(nèi)存緩存。

• 先進(jìn)淘汰算法：采用 TinyLFU（頻率優(yōu)先+時(shí)間輔助）淘汰策略，相比傳統(tǒng) LRU 抗緩存污染能力更強(qiáng)，在熱點(diǎn)數(shù)據(jù)場(chǎng)景下命中率可提升10%~30%，尤其適合高頻訪問(wèn)不均衡的場(chǎng)景。
• 極致并發(fā)性能：采用細(xì)粒度鎖設(shè)計(jì)，多線程/異步任務(wù)并發(fā)訪問(wèn)時(shí)無(wú)明顯性能瓶頸，單線程 get 操作延遲可低至納秒級(jí)，遠(yuǎn)超同類 Rust 緩存庫(kù)。
• 全場(chǎng)景適配：支持固定容量/權(quán)重容量（按條目大小而非數(shù)量限制）、TTL（生存時(shí)間）/TTI（空閑時(shí)間）過(guò)期策略，還支持 per-entry 自定義過(guò)期，滿足不同業(yè)務(wù)場(chǎng)景需求。
• 生產(chǎn)級(jí)特性完備：提供緩存統(tǒng)計(jì)（命中率、條目數(shù)等）、原子填充（避免并發(fā)重復(fù)計(jì)算）、驅(qū)逐回調(diào)事件、內(nèi)存控制等特性，可直接用于生產(chǎn)環(huán)境。
• 零成本抽象：純 Rust 原生實(shí)現(xiàn)，無(wú)額外運(yùn)行時(shí)開(kāi)銷，編譯期保證類型安全，避免空指針、數(shù)據(jù)競(jìng)爭(zhēng)等問(wèn)題。

環(huán)境搭建

moka 的使用門檻極低，只需簡(jiǎn)單引入依賴，即可快速上手。不過(guò)需要注意的是 moka 并沒(méi)有達(dá)到穩(wěn)定版本，還是存在破壞性更新的情況，在使用時(shí)需要注意這一點(diǎn)。

在 Cargo.toml 中添加 moka 依賴，根據(jù)業(yè)務(wù)場(chǎng)景選擇同步或異步版本，在實(shí)際開(kāi)發(fā)中，更推薦使用異步版本：

[dependencies]
# 同步緩存
moka = { version = "0.12", features = ["sync"] }
# 異步緩存
moka = { version = "0.12", features = ["future"] }
tokio = { version = "1", features = ["full"] }
anyhow = "1.0"

moka 提供兩種核心緩存類型：

• sync::Cache：同步緩存，適用于普通多線程場(chǎng)景，線程安全，支持多線程并發(fā)讀寫。
• future::Cache：異步緩存，適用于異步運(yùn)行時(shí)。

基礎(chǔ)使用

先從最簡(jiǎn)單的同步緩存入手，掌握插入、獲取、刪除、過(guò)期等核心操作，后續(xù)異步緩存的 API 與之高度一致，降低學(xué)習(xí)成本。

同步緩存操作入門

演示緩存的創(chuàng)建、插入、獲取、刪除、清空等基礎(chǔ)操作，代碼可直接運(yùn)行：

use moka::sync::Cache;

fn main() {
    // 創(chuàng)建緩存：最大容量1000條數(shù)據(jù)，超過(guò)容量將按 TinyLFU 算法淘汰
    let cache = Cache::builder()
        .max_capacity(1000) // 核心配置：緩存最大條目數(shù)
        .build();

    // 插入數(shù)據(jù)
    cache.insert("user:1", "張三");
    cache.insert("user:2", "李四");

    // 獲取數(shù)據(jù)（返回 Option<T>，不存在則返回 None）
    if let Some(name) = cache.get(&"user:1") {
        println!("獲取緩存：{}", name);
    }

    // 刪除指定數(shù)據(jù)（兩種方式：invalidate 無(wú)返回值，remove 會(huì)返回被刪除的值）
    // invalidate 刪除數(shù)據(jù)無(wú)返回值
    cache.invalidate(&"user:2");
    // remove 刪除數(shù)據(jù)并返回被刪除的值
    let removed = cache.remove("user:1"); // 返回 Option<T>，此處為 Some("王五")
    println!("被刪除的值：{:?}", removed);

    // 清空所有緩存，謹(jǐn)慎使用，生產(chǎn)環(huán)境需避免誤操作
    cache.invalidate_all();

    //  獲取緩存當(dāng)前條目數(shù)
    println!("緩存當(dāng)前大?。簕}", cache.entry_count());
}

帶過(guò)期時(shí)間的緩存

moka 支持兩種常用過(guò)期策略，可單獨(dú)使用或組合使用，滿足不同業(yè)務(wù)的過(guò)期需求：

• TTL（Time-To-Live）：從數(shù)據(jù)插入時(shí)開(kāi)始計(jì)算，固定存活時(shí)間，到期后自動(dòng)淘汰。
• TTI（Time-To-Idle）：從數(shù)據(jù)最后一次訪問(wèn)時(shí)開(kāi)始計(jì)算，空閑時(shí)間超過(guò)設(shè)定值則淘汰，適合“長(zhǎng)期不訪問(wèn)即失效”的場(chǎng)景。

use moka::sync::Cache;
use std::time::Duration;

fn main() {
    // 創(chuàng)建帶過(guò)期策略的緩存：存活60秒（TTL），空閑30秒（TTI）
    let cache = Cache::builder()
        .max_capacity(100)
        .time_to_live(Duration::from_secs(60)) // 插入后，60秒內(nèi)有效
        .time_to_idle(Duration::from_secs(30)) // 最后一次訪問(wèn)后，30秒內(nèi)無(wú)訪問(wèn)則失效
        .build();

    cache.insert("key1", "value1");

    // 5秒后訪問(wèn)，刷新 TTI 計(jì)時(shí)
    std::thread::sleep(Duration::from_secs(5));
    if let Some(val) = cache.get(&"key1") {
        println!("5秒后訪問(wèn)：{}", val); // 輸出：5秒后訪問(wèn)：value1
    }

    // 再等待35秒（累計(jì)空閑35秒，超過(guò) TTI 30秒）
    std::thread::sleep(Duration::from_secs(35));
    if cache.get(&"key1").is_none() {
        println!("35秒后，緩存已失效（TTL未到，但TTI超時(shí)）");
    }

    // 插入新數(shù)據(jù)，測(cè)試 TTL
    cache.insert("key2", "value2");
    std::thread::sleep(Duration::from_secs(65)); // 超過(guò) TTL 60秒
    if cache.get(&"key2").is_none() {
        println!("65秒后，緩存已失效（TTL超時(shí)）");
    }
}

異步緩存操作入門

異步緩存需依賴 tokio 或 async-std 運(yùn)行時(shí)，以下以 tokio 為例，演示異步插入、獲取、刪除操作：

use moka::future::Cache;
use std::time::Duration;

#[tokio::main]
async fn main() {
    //創(chuàng)建異步緩存：最大容量1000，TTL 60秒
    let cache = Cache::builder()
        .max_capacity(1000)
        .time_to_live(Duration::from_secs(60))
        .build();

    // 異步插入
    cache.insert("user:100", "趙六").await;

    // 異步獲取
    if let Some(name) = cache.get(&"user:100").await {
        println!("異步獲取緩存：{}", name); // 輸出：異步獲取緩存：趙六
    }

    // 異步刪除
    cache.invalidate(&"user:100").await;

    // 異步原子填充：get_with（不存在則計(jì)算并插入，避免并發(fā)重復(fù)計(jì)算）
    // 場(chǎng)景：緩存不存在時(shí)，從數(shù)據(jù)庫(kù)查詢并插入緩存，這里模擬耗時(shí)操作
    let user = cache
        .get_with("user:101", async {
            tokio::time::sleep(Duration::from_millis(50)).await;
            "孫七"
        })
        .await;
    println!("原子填充緩存：{}", user); // 輸出：原子填充緩存：孫七
}

生產(chǎn)環(huán)境注意事項(xiàng)

避免手動(dòng)加鎖，正確共享緩存

moka 的緩存實(shí)例本身已實(shí)現(xiàn)線程安全，無(wú)需手動(dòng)用 Mutex/RwLock 包裹。多線程/異步任務(wù)共享緩存時(shí)，直接 clone 即可（內(nèi)部采用 Arc 共享，clone 成本極低），避免多余的鎖開(kāi)銷導(dǎo)致性能下降。

大值優(yōu)化：用 Arc 包裝減少克隆開(kāi)銷

moka 的 get 方法會(huì)返回 value 的克隆副本，若 value 是大結(jié)構(gòu)體（如大字符串、復(fù)雜 JSON），頻繁克隆會(huì)產(chǎn)生較大內(nèi)存開(kāi)銷和性能損耗。此時(shí)可使用 Arc 包裝 value，減少克隆成本：

use moka::sync::Cache;
use std::sync::Arc;

fn main() {
    // 用 Arc 包裝大值
    let cache = Cache::new(1000);
    let large_value = Arc::new("大字符串...".repeat(10000));
    cache.insert("key", large_value);

    // 獲取時(shí)克隆 Arc（成本極低，僅增加引用計(jì)數(shù)）
    if let Some(val) = cache.get(&"key") {
        let inner_val = &*val; // 無(wú)需克隆內(nèi)部值，直接引用
    }
}

緩存穿透、擊穿、雪崩的處理

• 緩存穿透：查詢不存在的數(shù)據(jù)，導(dǎo)致緩存失效，頻繁訪問(wèn)數(shù)據(jù)庫(kù)。解決方案：緩存空值（設(shè)置較短 TTL，如5秒），或使用布隆過(guò)濾器過(guò)濾不存在的 key。
• 緩存擊穿：熱點(diǎn) key 過(guò)期時(shí)，大量并發(fā)請(qǐng)求同時(shí)查詢數(shù)據(jù)庫(kù)。解決方案：使用 get_with 原子填充，確保僅一次數(shù)據(jù)庫(kù)查詢；或給熱點(diǎn) key 設(shè)置永不過(guò)期。
• 緩存雪崩：大量緩存同時(shí)過(guò)期，導(dǎo)致數(shù)據(jù)庫(kù)壓力驟增。解決方案：使用自定義過(guò)期策略添加抖動(dòng)（Jitter），避免緩存同時(shí)過(guò)期；或按批次設(shè)置不同的 TTL。

內(nèi)存控制：合理設(shè)置容量與權(quán)重

生產(chǎn)環(huán)境中，需根據(jù)服務(wù)內(nèi)存大小合理設(shè)置緩存容量/權(quán)重，避免緩存占用過(guò)多內(nèi)存導(dǎo)致 OOM。建議設(shè)置緩存容量為服務(wù)可用內(nèi)存的10%~20%，并結(jié)合緩存統(tǒng)計(jì)，動(dòng)態(tài)調(diào)整容量。

總結(jié)

moka 作為 Rust 生態(tài)中高性能內(nèi)存緩存的代表，在我看來(lái)現(xiàn)階段仍不足以用于實(shí)際開(kāi)發(fā)環(huán)境，畢竟還時(shí)不時(shí)存在破壞性更新，可以先關(guān)注著，實(shí)在有本地緩存的需求，那么也還是可以考慮使用 moka 的。

到此這篇關(guān)于Rust 高性能內(nèi)存緩存 moka 完全指南的文章就介紹到這了,更多相關(guān)Rust 內(nèi)存緩存moka內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！