Redis-rs для Rust: полное руководство с примерами

Что такое Redis-rs и зачем он нужен?

Redis-rs — это асинхронный и синхронный клиент для Redis, написанный на языке Rust. Это одна из самых популярных и активно поддерживаемых библиотек для работы с Redis в экосистеме Rust. Она предоставляет удобный, безопасный и высокопроизводительный интерфейс для взаимодействия с сервером Redis.

Зачем нужен Redis-rs?

• Высокая производительность: Rust известен своей скоростью и безопасностью памяти. Redis-rs наследует эти качества, обеспечивая минимальные накладные расходы при работе с Redis.
• Асинхронность: Библиотека изначально спроектирована для работы с асинхронными рантаймами, такими как Tokio и async-std, что позволяет обрабатывать тысячи соединений без блокировки потоков.
• Типобезопасность: Rust строгая система типов помогает избежать многих ошибок на этапе компиляции. Redis-rs использует это преимущество, предоставляя типизированные команды.
• Поддержка кластеров и репликации: Библиотека поддерживает работу с кластерами Redis, автоматическое перенаправление запросов и работу с репликами.
• Активное сообщество: Redis-rs имеет большую аудиторию разработчиков, регулярно обновляется и хорошо документирована.

Эта библиотека идеально подходит для создания высоконагруженных веб-приложений, систем кэширования, очередей сообщений, сессионных хранилищ и любых других проектов, где требуется быстрый доступ к данным через Redis.

Установка Redis-rs

Для установки Redis-rs в ваш проект на Rust, добавьте зависимость в файл Cargo.toml:

[dependencies]
redis = "0.27.0"  # Проверьте актуальную версию на crates.io
tokio = { version = "1.0", features = ["full"] }  # Для асинхронного выполнения

Затем выполните команду:

cargo build

Если вы планируете использовать синхронный клиент, вам не нужен Tokio, но для асинхронного — он обязателен.

Быстрый старт с примером кода

Давайте напишем простую программу, которая подключается к Redis, записывает значение и читает его обратно.

use redis::AsyncCommands;
use tokio;

#[tokio::main]
async fn main() -> redis::RedisResult<()> {
    // Устанавливаем соединение с Redis сервером
    let client = redis::Client::open("redis://127.0.0.1:6379/")?;
    let mut con = client.get_async_connection().await?;

    // Устанавливаем ключ "hello" со значением "world"
    con.set("hello", "world").await?;

    // Получаем значение по ключу "hello"
    let value: String = con.get("hello").await?;
    println!("Значение ключа 'hello': {}", value);

    Ok(())
}

Этот пример показывает базовую работу с Redis-rs: подключение, запись и чтение данных. Обратите внимание на использование #[tokio::main] — это макрос, который запускает асинхронный рантайм Tokio.

Основные методы и функции Redis-rs

Рассмотрим 10 наиболее часто используемых методов. Все примеры предполагают, что у вас есть асинхронное соединение con, полученное через client.get_async_connection().await?.

1. set() — установка значения

Описание: Устанавливает значение для указанного ключа. Если ключ уже существует, значение перезаписывается.

Параметры:

• key: K — ключ (любой тип, реализующий ToRedisArgs)
• value: V — значение (любой тип, реализующий ToRedisArgs)

Пример:

con.set("user:1:name", "Alice").await?;
con.set("counter", 42).await?;

2. get() — получение значения

Описание: Получает значение по указанному ключу. Возвращает Option<T>, где T — ожидаемый тип.

Параметры:

• key: K — ключ

Пример:

let name: Option<String> = con.get("user:1:name").await?;
let counter: Option<i32> = con.get("counter").await?;

if let Some(name) = name {
    println!("Имя пользователя: {}", name);
}

3. del() — удаление ключа

Описание: Удаляет один или несколько ключей. Возвращает количество удаленных ключей.

Параметры:

• key: K — ключ (или несколько ключей через запятую)

Пример:

let deleted: i32 = con.del("user:1:name").await?;
println!("Удалено ключей: {}", deleted);

// Удаление нескольких ключей
con.del(&["key1", "key2", "key3"]).await?;

4. exists() — проверка существования ключа

Описание: Проверяет, существует ли указанный ключ. Возвращает bool.

Параметры:

• key: K — ключ

Пример:

let user_exists: bool = con.exists("user:1:name").await?;
if user_exists {
    println!("Пользователь существует");
}

5. expire() — установка времени жизни ключа

Описание: Устанавливает время жизни ключа в секундах. После истечения времени ключ автоматически удаляется.

Параметры:

• key: K — ключ
• seconds: i64 — время жизни в секундах

Пример:

con.set("temp_data", "value").await?;
con.expire("temp_data", 3600).await?; // Ключ удалится через 1 час

6. incr() — инкремент значения

Описание: Увеличивает числовое значение ключа на 1. Если ключ не существует, создает его со значением 0, затем инкрементирует.

Параметры:

• key: K — ключ

Пример:

let new_count: i64 = con.incr("page_views", 1).await?;
println!("Новое значение счетчика: {}", new_count);

7. lpush() / rpush() — добавление в список

Описание: Добавляет один или несколько элементов в начало (lpush) или конец (rpush) списка.

Параметры:

• key: K — ключ списка
• value: V — значение (или несколько значений)

Пример:

// Добавляем элементы в список "tasks"
con.rpush("tasks", "task1").await?;
con.rpush("tasks", "task2").await?;
con.lpush("tasks", "urgent_task").await?; // Добавляем в начало

8. lpop() / rpop() — извлечение из списка

Описание: Удаляет и возвращает первый (lpop) или последний (rpop) элемент списка.

Параметры:

• key: K — ключ списка

Пример:

let first_task: Option<String> = con.lpop("tasks").await?;
if let Some(task) = first_task {
    println!("Выполнена задача: {}", task);
}

9. sadd() / smembers() — работа с множествами

Описание: sadd добавляет элемент в множество. smembers возвращает все элементы множества.

Параметры:

• key: K — ключ множества
• value: V — значение (для sadd)

Пример:

// Добавляем теги к статье
con.sadd("article:1:tags", "rust").await?;
con.sadd("article:1:tags", "redis").await?;
con.sadd("article:1:tags", "database").await?;

// Получаем все теги
let tags: Vec<String> = con.smembers("article:1:tags").await?;
println!("Теги статьи: {:?}", tags);

10. hset() / hget() — работа с хешами

Описание: hset устанавливает поле в хеше. hget получает значение поля.

Параметры:

• key: K — ключ хеша
• field: F — имя поля
• value: V — значение (только для hset)

Пример:

// Сохраняем информацию о пользователе в хеш
con.hset("user:1", "name", "Alice").await?;
con.hset("user:1", "age", 30).await?;
con.hset("user:1", "email", "alice@example.com").await?;

// Получаем отдельные поля
let name: String = con.hget("user:1", "name").await?;
let age: i32 = con.hget("user:1", "age").await?;
println!("Пользователь: {} ({} лет)", name, age);

Реальный практический пример использования

Давайте создадим простую систему кэширования результатов API-запросов. Это типичный сценарий использования Redis в веб-приложениях.

use redis::AsyncCommands;
use serde::{Deserialize, Serialize};
use tokio;

#[derive(Serialize, Deserialize, Debug)]
struct UserData {
    id: u32,
    name: String,
    email: String,
}

async fn get_user_from_database(user_id: u32) -> UserData {
    // Имитация долгого запроса к базе данных
    tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;
    UserData {
        id: user_id,
        name: format!("User_{}", user_id),
        email: format!("user{}@example.com", user_id),
    }
}

async fn get_cached_user(
    con: &mut redis::aio::Connection,
    user_id: u32,
) -> redis::RedisResult<UserData> {
    let cache_key = format!("user:{}:data", user_id);

    // Пытаемся получить данные из кэша
    let cached: Option<String> = con.get(&cache_key).await?;

    if let Some(json_data) = cached {
        // Данные найдены в кэше — десериализуем
        let user: UserData = serde_json::from_str(&json_data).unwrap();
        println!("Данные получены из кэша");
        return Ok(user);
    }

    // Данных нет в кэше — загружаем из БД
    println!("Данных нет в кэше, загружаем из БД...");
    let user = get_user_from_database(user_id).await;

    // Сохраняем в кэш на 1 час
    let json_data = serde_json::to_string(&user).unwrap();
    con.set_ex(&cache_key, &json_data, 3600).await?;

    Ok(user)
}

#[tokio::main]
async fn main() -> redis::RedisResult<()> {
    let client = redis::Client::open("redis://127.0.0.1:637