【从零开始的rust web开发之路 四】rust语言tokio异步使用redis教程

文章目录

前言

使用rust写web，自然是离不开redis缓存的。rust也有现成redis连接库，并且支持阻塞和异步两种模式。下面教程我我以tokio异步操作redis方式为主，同步的操作可以参考异步，区别不大

一、首先引入依赖

redis = { version = "0.24.0",features = [ "r2d2" , "tokio-comp" ] }

我这里feature开启了r2d2连接池，以及开启了tokio异步支持特性。
全部特性列表如下
可选功能
定义了一些可以启用其他功能的功能 如果需要的话。其中一些是默认打开的。

  • acl：启用 ACL 支持（默认启用）
  • aio：启用异步 IO 支持（默认启用）
  • geospatial：启用地理空间支持（默认启用）
  • script：启用脚本支持（默认启用）
  • r2d2：启用 R2D2 连接池支持（可选）
  • ahash：启用AHASH地图/设置支持并在内部使用AHASH（+7-10%性能）- （可选）
  • cluster：启用 Redis集群支持（可选）
  • cluster-async：启用异步 Redis 集群支持（可选）
  • tokio-comp：启用对 Tokio的支持（可选）
  • connection-manager：启用对自动重新连接的支持（可选）
  • keep-alive：通过板启用保持活动选项（可选）socket2

二、创建redis客户端

    let client = redis::Client::open("redis://127.0.0.1:6379/").unwrap();//获取连接let con = client.get_async_connection().await.expect("连接redis失败");

此处url的格式为redis://[][:@][:port][/]
db是redis数据库索引。可根据业务自行修改

三、相关操作

设置值

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");con.set::<&str,u32,()>("my_key", 12).await.expect("操作失败");
}

此处<&str,u32,()>前两个泛型指定key，value。第三个泛型是实现了FromRedisValue Trait的返回，set方法可以不指定

mset设置多个key值

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");con.mset::<&str,u32,()>(&[("my_key1", 100), ("my_key2", 200)]).await.expect("操作失败");
}

设置含有过期时间的值

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");//设置60秒过期，第三个参数是过期时间con.pset_ex::<&str,u32,()>("my_key", 12,60*1000).await.expect("操作失败");
}

pset_ex是毫秒单位，set_ex是秒

如果key不存在才设置

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");con.set_nx::<&str,u32,()>("key3",30).await.expect("操作失败");
}

获取基本类型值

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");let value : u32 = con.get("my_key").await.expect("获取值失败");println!("my_key = {}", value);
}

删除一个键

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");con.del::<&str, ()>("key3") .await.expect("删除redis key失败");
}

删除多个键

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");// 多个键删除let keys_to_delete = vec!["my_key1", "my_key2"];let result = con.del::<&Vec<&str>, i32>(&keys_to_delete).await;match result {Ok(count) => println!("Deleted {} keys", count),Err(e) => println!("Error: {}", e),}
}

判断键是否存在

#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");// 判断键是否存在let exists : bool = con.exists("my_key").await.expect("执行redis命令失败");println!("exists: {}", exists);
}

更多详细的接口文档可以看官网AsyncCommands接口https://docs.rs/redis/0.24.0/redis/trait.AsyncCommands.html

如何使用json序列化

 可以通过自定义方法添加泛型约束实现功能。使用serde_json库来进行序列化

导入相关依赖

[dependencies]
tokio = { version = "1.35.1", features = ["full"] }
redis = { version = "0.24.0",features = [ "r2d2" , "tokio-comp","json" ] }
serde_json = "1.0.111"
serde = { version = "1.0.195", features = ["derive"] }

代码相关实例

use redis::{aio, AsyncCommands, RedisError, RedisResult, ToRedisArgs};
use serde::{Deserialize, Serialize};
use serde::de::DeserializeOwned;#[derive(Debug, Clone,Deserialize, Serialize)]
struct User{name: String,age: u8,email: String,
}#[tokio::main]
async  fn main() {let client = redis::Client::open("redis://127.0.0.1:6379/10").unwrap();let mut con = client.get_async_connection().await.expect("连接redis失败");// 判断键是否存在let user = User{name: "zhangsan".to_string(),age: 18,email: "11111111".to_string(),};set_json(&mut con,"user1",&user).await.expect("设置失败");let user :User = get_json(&mut con, "user2").await.expect("获取失败,没有找到User");println!("user:{:?}",user);
}//设置json格式对象
pub async fn set_json<K,T>(con: &mut aio::Connection, key: K, obj : &T) -> RedisResult<String>where K: ToRedisArgs + Send + Sync, T: Serialize{let json = serde_json::to_string(obj);match json {Ok(obj) => {con.set::<K,String, String>(key,obj).await},Err(e) => {return Err(RedisError::from(e));}}
}//获得json格式对象
pub async fn get_json<K, T>(con: &mut aio::Connection, key: K) -> RedisResult<T>where K: ToRedisArgs + Send + Sync, T: DeserializeOwned{let json : String = con.get(key).await?;let result = serde_json::from_str(&json);return match result {Ok(obj) => { Ok(obj) },Err(e) => { Err(RedisError::from(e)) }}
}

通过这两个方法泛型约束据即可实现相关功能

总结

以上就是今天要讲的内容，本文介绍了rust语言tokio异步使用redis教程，后续会出一个扩展使用教程

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/664653.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Windows网络常用的11个命令，ping、tracert、arp、ipconfig、netstat、telnet等

Windows网络常用的11个命令，ping、tracert、arp、ipconfig、netstat、telnet等

1&#xff0e;ping命令 ping是个使用频率极高的实用程序&#xff0c;主要用于确定网络的连通性。ping能够以毫秒为单位显示延迟。如果应答时间短&#xff0c;表示数据报不必通过太多的路由器或网络&#xff0c;连接速度比较快。ping还能显示TTL&#xff08;Time To Live&#…
阅读更多...
AspNet web api 和mvc 过滤器差异

AspNet web api 和mvc 过滤器差异

最近在维护老项目。定义个拦截器记录接口日志。但是发现不生效 最后发现因为继承的 ApiController不是Controller 只能用 System.Web.Http下的拦截器生效。所以现在总结归纳一下 Web Api: System.Web.Http.Filters.ActionFilterAttribute 继承该类 Mvc: System.Web.Mvc.Ac…
阅读更多...
客户端和服务端的简介

客户端和服务端的简介

Client 和 Server 客户端&#xff08;Client&#xff09; 或称用户端&#xff0c;是指与服务器相对应&#xff0c;为客户提供本地服务的程序。除了一些只在本地运行的应用程序之外&#xff0c;一般安装在客户机上&#xff0c;需要与服务端互相配合运行。例如&#xff1a;下载 Q…
阅读更多...
ChatGPT炸裂了

ChatGPT炸裂了

优质内容&#xff1a;ChatGPT太炸裂了 hello&#xff0c;我是小索奇 很多人在使用ChatGPT时遇到了两个主要问题&#xff0c;导致他们觉得这个工具并没有带来太多实际价值。首先&#xff0c;许多人发现ChatGPT的回答缺乏深度&#xff0c;缺乏实用性。其次&#xff0c;一些人在使…
阅读更多...
MySQL操作问题汇总

MySQL操作问题汇总

MySQL操作问题汇总 无法远程连接Ubuntu的MySQL 无法远程连接Ubuntu的MySQL 提示&#xff1a;MySQL默认只允许本地连接&#xff1a;localhost 解决&#xff1a; #1.修改配置文件 #/etc/mysql/mysql.conf.d/mysqld.cnf > cp /etc/mysql/mysql.conf.d/mysqld.cnf /etc/mysql/…
阅读更多...
WebSocketServer依赖注入问题

WebSocketServer依赖注入问题

WebSocketServer加入spring的bean管理 问题 @Component @ServerEndpoint("/webSocket/{topic}") @Slf4j public class WebSocketServer {@Autowiredprivate WsHandle wsHandle;} 前面使用@ServerEndpoint注册一个websocket服务端，然后发现wsHandle依赖注入失败，…
阅读更多...
STM32GPIO输入（按键控制LED、光敏电阻控制蜂鸣器实例）

STM32GPIO输入（按键控制LED、光敏电阻控制蜂鸣器实例）

文章目录 一、介绍传感器模块介绍硬件电路c语言数据类型 二、实例按键控制LED接线图代码实现 光敏电阻控制蜂鸣器组装线路代码实现 相关函数解释 一、介绍 传感器模块介绍 硬件电路 上两种按下时为0&#xff0c;下两种按下时为1。 c语言数据类型 现在常用stdint头文件所定…
阅读更多...
BeanDefinitionRegistry学习

BeanDefinitionRegistry学习

Spring版本5.1.x 简介 在Spring框架中&#xff0c;BeanDefinitionRegistry是一个接口&#xff0c;它主要用于向注册表中注册BeanDefinition实例&#xff0c;完成注册的过程。该接口的主要方法是registerBeanDefinition&#xff0c;用于将一个BeanDefinition实例注册到注册表中…
阅读更多...
【zip密码】zip压缩包的打开密码忘了，怎么办？

【zip密码】zip压缩包的打开密码忘了，怎么办？

Zip压缩包设置了密码&#xff0c;解压的时候就需要输入正确对密码才能顺利解压出文件&#xff0c;正常当我们解压文件或者删除密码的时候&#xff0c;虽然方法多&#xff0c;但是都需要输入正确的密码才能完成。忘记密码就无法进行操作。 那么&#xff0c;忘记了zip压缩包的密…
阅读更多...
一张证书如何改变职业生涯？程序员必看！

一张证书如何改变职业生涯？程序员必看！

随着信息产业的迅猛发展&#xff0c;对行业人才的需求也在逐年扩大。据统计&#xff0c;未来五年&#xff0c;我国对信息化人才的总需求量将高达1500万至2000万人。以软件开发为例&#xff0c;我国对软件人才的需求正以每年20%的速度递增&#xff0c;每年新增的需求接近百万。计…
阅读更多...
1 初识JVM

1 初识JVM

JVM&#xff08;Java Virtual Machine&#xff09;&#xff0c;也就是 “Java虚拟机”。 对于第三点功能&#xff1a;即时编译 常见的JVM 默认安装在JDK中的虚拟机为HotSpot&#xff1a;可以用“java -version”进行查看
阅读更多...
云原生 API 网关链路追踪能力重磅上线

云原生 API 网关链路追踪能力重磅上线

云原生API网关介绍 云原生 API 网关是腾讯云基于开源网关推出的一款高性能高可用的云原生 API 网关产品&#xff0c;作为云上流量入口&#xff0c;集成请求分发、API 管理、流量监控、访问限制等功能&#xff0c;是微服务架构和容器架构中的重要组件。 TSE 云原生 API 网关提…
阅读更多...
数据分析基础之《pandas（4）—pandas画图》

数据分析基础之《pandas（4）—pandas画图》

1、DataFrame.plot(xNone, yNone, kindline) 说明&#xff1a; x&#xff1a;设置x轴标签 y&#xff1a;设置y轴标签 kind&#xff1a; line 折线图 bar 柱状图 hist 直方图 pie 饼图 scatter 散点图 # 找到p_change和turnover之间的关系 data.plot(xvolume, yturnover, kinds…
阅读更多...
【数据库】分区的优点和缺点

【数据库】分区的优点和缺点

​ &#x1f34e;个人博客&#xff1a;个人主页 &#x1f3c6;个人专栏&#xff1a;数据库 ⛳️ 功不唐捐&#xff0c;玉汝于成 目录 前言 正文 优点&#xff1a; 缺点&#xff1a; 结语 我的其他博客 ​ 前言 数据库中的分区技术为处理大规模数据提供了一种有效的手段…
阅读更多...
五大浏览器内核及代表浏览器，一文讲透!

五大浏览器内核及代表浏览器，一文讲透!

Hi,我是贝格前端工场&#xff0c;在进行web前端开发的时候&#xff0c;浏览器兼容性一直是让所有前端工程师头疼的问题&#xff0c;其根源在于不同的浏览器应用了不同的内核&#xff0c;其对html、css、js的解析规则也是不一样的&#xff0c;作为前端开发的你&#xff0c;如果不…
阅读更多...
【核心网】【LTE】附着信令流程报文 - 关键字段内容

【核心网】【LTE】附着信令流程报文 - 关键字段内容

目录 1. (S1AP/NAS-EPS) --> InitialUEMessage, Attach request, PDN connectivity request 2. (DIAMETER) --> cmd=3GPP-Authentication-Information Request(318) flags=RP-- appl=3GPP S6a/S6d(16777251) h2h=
阅读更多...
一文掌握单基因GSEA富集分析

一文掌握单基因GSEA富集分析

本期教程 本期教程原文：一文掌握单基因GSEA富集分析 | gseaGO and gseaKEGG 写在前面 关于GSEA分析，我们在前期的教程单基因GSEA富集分析 | 20220404有出过类似的分享。今天，我们也结合相关的资源整理出一篇关于GSEA的教程及出图教程。每个方法的教程很多，我们大家结合自…
阅读更多...
2024美赛数学建模A题思路分析 - 资源可用性和性别比例(2)

2024美赛数学建模A题思路分析 - 资源可用性和性别比例(2)

# 1 赛题 问题A&#xff1a;资源可用性和性别比例 虽然一些动物物种存在于通常的雄性或雌性性别之外&#xff0c;但大多数物种实质上是雄性或雌性。虽然许多物种在出生时的性别比例为1&#xff1a;1&#xff0c;但其他物种的性别比例并不均匀。这被称为适应性性别比例的变化。…
阅读更多...
C++vector容器

C++vector容器

3.3.2vector容器 vector的数据安排及操作方式&#xff0c;与array非常相似&#xff0c;两者唯一差别在于空间的运用的灵活性。Array是静态控件&#xff0c;一旦配置了就不能改变&#xff0c;要换大一点或者小一点的空间&#xff0c;可以&#xff0c;一切琐碎得由自己来&#x…
阅读更多...
打造实用Python学生管理系统：设计与实现

打造实用Python学生管理系统：设计与实现

引言 在信息化教育管理的背景下&#xff0c;一个高效、便捷的学生管理系统对于提升教学管理效率具有重大意义。Python作为一种功能强大且易读易写的编程语言&#xff0c;非常适合用于开发此类系统。本文将探讨如何使用Python设计并实现一个基础的学生管理系统。 一、系统需求…
阅读更多...
最新文章

Copyright @ 2022~2023