当前位置：首页 > news >正文

Rust 操作 Redis 从入门到生产级应用

news 2026/4/29 7:24:37

Rust 操作 Redis 从入门到生产级应用

在现代后端开发中，Redis 作为高性能的内存数据库，广泛用于缓存、会话管理、消息队列等场景。本文将基于主流的 redis-rs 库，带你全面掌握 Rust 操作 Redis 的技巧，覆盖同步/异步双模式、连接池、序列化等内容。

添加库依赖

在Cargo.toml中配置依赖：

[dependencies] redis = { version = "1.2", features = [ "tokio-comp", # 异步支持 "connection-manager", # 内置连接池 "tokio-native-tls-comp", ] } tokio = { version = "1", features = ["full"] } anyhow = "1.0"

基础操作

redis-rs对 Redis 原生命令做了优雅封装，API 与 Redis 命令高度一致，学习成本极低，同时依托 Rust 的编译期检查，能从根源规避类型错误、命令误用等问题。以下示例分别展示同步与异步模式下的基础操作。

同步模式：简单场景快速上手

同步模式适合简单脚本、单线程工具等场景，核心是通过Client创建连接，再通过Commands特征调用 Redis 命令：

useanyhow::Result;useredis::{Client,Commands};fnmain()->Result<()>{// 创建 Redis 客户端letclient=Client::open("redis://127.0.0.1:6379")?;// 获取连接（同步连接）letmutconn=client.get_connection()?;// 字符串操作：SET / GETlet_:()=conn.set("username","rust_dev")?;// SET 命令，返回空元组letusername:Option<String>=conn.get("username")?;// GET 命令，返回 Option（避免空值 panic）println!("获取 username: {:?}",username);// 输出：Some("rust_dev")// 哈希操作：HSET / HGET / HGETALLlet_:()=conn.hset("user:1","id",1)?;let_:()=conn.hset("user:1","name","Alice")?;letuser_name:Option<String>=conn.hget("user:1","name")?;letuser:Option<redis::Value>=conn.hgetall("user:1")?;// 获取整个哈希println!("获取用户名称: {:?}",user_name);// 输出：Some("Alice")println!("获取用户全部信息: {:?}",user);// 列表操作：LPUSH / LRANGElet_:()=conn.lpush("tasks","learn redis")?;let_:()=conn.lpush("tasks","learn rust")?;lettasks:Vec<String>=conn.lrange("tasks",0,-1)?;// 获取所有列表元素println!("任务列表: {:?}",tasks);// 输出：["learn rust", "learn redis"]// 删除操作：DELlet_:()=conn.del("username")?;Ok(())}

异步模式：高并发场景首选

异步模式基于 Tokio 实现，非阻塞 IO，其 API 与同步模式高度一致：

useanyhow::Result;useredis::{AsyncCommands,Client};#[tokio::main]asyncfnmain()->Result<()>{// 创建 Redis 客户端letclient=Client::open("redis://127.0.0.1:6379")?;// 获取异步连接letmutconn=client.get_multiplexed_async_connection().await?;// 异步操作：与同步模式 API 一致let_:()=conn.set("async_key","async_value").await?;letasync_value:Option<String>=conn.get("async_key").await?;println!("异步获取值: {:?}",async_value);// 输出：Some("async_value")// 哈希操作（异步）let_:()=conn.hset("async_user:1","age",25).await?;letage:Option<i32>=conn.hget("async_user:1","age").await?;println!("异步获取用户年龄: {:?}",age);// 输出：Some(25)Ok(())}

进阶特性

在实际生产环境中，仅基础操作远远不够，redis-rs提供还提供了连接池、管道、事务、序列化等特性，能帮助我们构建更稳定、高效的服务。

连接池：高并发下的连接管理

频繁创建/销毁 Redis 连接会严重影响性能，connection-manager特性提供了内置连接池，能自动管理连接的创建、复用、销毁和重连，无需手动处理连接生命周期：

useanyhow::Result;useredis::{AsyncCommands,Client};#[tokio::main]asyncfnmain()->Result<()>{// 创建 Redis 客户端letclient=Client::open("redis://127.0.0.1:6379")?;// 创建连接池，默认配置// 另外可提供 get_connection_manager_with_config 自定义最大连接数、超时时间等letmutconn_manager=client.get_connection_manager().await?;// 从连接池获取连接并执行操作（自动复用连接）foriin0..5{letkey=format!("pool_key:{}",i);let_:()=conn_manager.set(&key,i).await?;letvalue:Option<i32>=conn_manager.get(&key).await?;println!("连接池操作 {}: {:?}",key,value);}Ok(())}

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

Redis 管道允许将多个命令批量发送到服务器，减少网络往返次数，显著提升批量操作的性能。redis-rs支持管道的链式调用，通过pipe()创建管道，添加命令后通过exec()或query()执行：

useanyhow::Result;useredis::{Client,pipe};#[tokio::main]asyncfnmain()->Result<()>{letclient=Client::open("redis://127.0.0.1:6379")?;letmutconn=client.get_connection()?;// 创建管道，批量执行 SET 命令（无返回值）pipe().set("pipe_key1","value1").set("pipe_key2","value2").set("pipe_key3","value3").exec(&mutconn)?;println!("管道批量 SET 执行完成");// 批量执行 GET 命令（获取返回值）let(val1,val2,val3):(Option<String>,Option<String>,Option<String>)=pipe().get("pipe_key1").get("pipe_key2").get("pipe_key3").query(&mutconn)?;println!("管道批量 GET 结果: {:?}, {:?}, {:?}",val1,val2,val3);Ok(())}

事务（Transaction）：保证操作原子性

Redis 事务通过MULTI、EXEC命令实现，确保多个命令原子性执行（要么全部成功，要么全部失败）。redis-rs通过管道提供的atomic()方法进行事务操作：

useanyhow::Result;useredis::{Client,pipe};#[tokio::main]asyncfnmain()->Result<()>{letclient=Client::open("redis://127.0.0.1:6379")?;letmutconn=client.get_connection()?;// 开启事务letmutpipe=pipe();pipe.atomic();// 向事务中添加命令pipe.set("tx_key1","tx_val1").hset("tx_user:1","name","Bob").lpush("tx_tasks","finish transaction");// 执行事务（通过 query 发送所有命令）letresults:Vec<redis::Value>=pipe.query(&mutconn)?;println!("事务执行结果: {:?}",results);Ok(())}

Lua 脚本：扩展 Redis 功能与原子操作

Redis 支持通过 Lua 脚本执行简单原子操作，redis-rs 提供简洁的 API 可快速调用脚本：

useanyhow::Result;useredis::{Client,Script};// 定义结构体#[tokio::main]asyncfnmain()->Result<()>{letclient=Client::open("redis://127.0.0.1:6379")?;letmutconn=client.get_multiplexed_async_connection().await?;// 定义 Lua 脚本：自增指定 key，返回自增后的值letlua_script=Script::new(r#" local key = KEYS[1] -- 调用 Redis 原生命令 INCR，实现自增 return redis.call('INCR', key) "#,);// 执行脚本：通过 .key() 传递 KEYS 参数letnew_val:i32=lua_script.key("simple_lua_counter")// 添加 KEY.invoke_async(&mutconn)// 执行脚本.await?;println!("Lua 脚本执行结果（自增后）: {}",new_val);// 首次执行输出 1// 传递参数的简单示例，设置 key 值并返回letset_and_get_script=Script::new(r#" local key = KEYS[1] local val = ARGV[1] redis.call('SET', key, val) return val "#,);letresult:String=set_and_get_script.key("lua_test_key")// 添加 KEY.arg("test_value")// 添加 ARG.invoke_async(&mutconn).await?;println!("设置并返回值: {}",result);// 输出 test_valueOk(())}