将数据写入到redis缓存/取出/删除 消息队列
将数据写入到redis缓存,写入 取出 删除 Redis的安装及开启服务就不在这章多讲，直接上写入缓存，从缓存中取出数据，取出成功后在删除缓存。 1:：添加Redis组件包
1：写入缓存 //1获取Redis操作接口 var redisClient = RedisManager.GetClient() //2将添加的数据存储到Redis //2.1 answer redis里面储存的名称，类似于一张表一样，添加成功的数据 model.tojson 需要存储的数据（model.tojson的数据 会储存在这个answer里面） redisClient.AddItemToList("answer",model.ToJson());2：读取Redis缓存 2.1定义一个方法// 获取redis缓存public List<model(返回的实体对象)> GetQuestionnairesByRedis(){//获取Redis操作接口using (var Redis = RedisManager.GetClient()){//获取所有缓存列表var answers= Redis.GetAllItemsFromList("answer");var answerlist= answers.ConvertAll(s => s.ToObject<answer>());return answerlist;}}1.1根据某个参数条件查询储存在redis里面的数据//获取详情redis缓存 var info = bll.GetQuestionnairesByRedis().FirstOrDefault(p => p.Code == code); 3.删除缓存public class AssignaUserByRedis{/// <summary>/// 删除redis缓存记录/// </summary>/// <param name="key"></param>/// <param name="value"></param>/// <returns></returns>public long DeleteAssignaUserFromRedis(string key, string value){//获取Redis操作接口using (var Redis = RedisManager.GetClient()){var ret = Redis.RemoveItemFromList(key, value);return ret;}}}AssignaUserByRedis =new AssignaUserByRedis //item redis存储数据对应的某一个参数（如：主键 id ,code ...）assignaUserByRedis.DeleteAssignaUserFromRedis("answer", item);4.消息队列//获取Redis操作接口 var Redis = RedisManager.GetClient()// 将待推送队列存储到redis //assignUserList 数据列表 ，AssignUsersList 存储到redis 类似于表面assignUserList?.ForEach(x => redisClient.AddItemToList("AssignUsersList", x.ToJson()));5.查询消息队列//获取当前需要推送消息的用户列表var userList = Redis.GetAllItemsFromList("AssignUsersList");6.删除// 从缓存中删除记录 foreach (var item in userList ){assignaUserByRedis.DeleteAssignaUserFromRedis("AssignUsersList", item);}
将数据写入到redis缓存/取出/删除 消息队列相关推荐
- RabbitMQ,Apache的ActiveMQ,阿里RocketMQ,Kafka,ZeroMQ,MetaMQ,Redis也可实现消息队列，RabbitMQ的应用场景以及基本原理介绍，RabbitMQ
RabbitMQ,Apache的ActiveMQ,阿里RocketMQ,Kafka,ZeroMQ,MetaMQ,Redis也可实现消息队列,RabbitMQ的应用场景以及基本原理介绍,RabbitMQ ...
- Redis 使用 List 实现消息队列的利与弊
作者 | 码哥字节 来源 | 码哥字节 分布式系统中必备的一个中间件就是消息队列,通过消息队列我们能对服务间进行异步解耦.流量消峰.实现最终一致性. 目前市面上已经有 RabbitMQ.RochetM ...
- java redis延迟队列_基于redis实现的延迟消息队列
delay-queue redis实现延迟消息队列 需求背景 最近在做一个排队取号的系统 在用户预约时间到达前XX分钟发短信通知 在用户预约时间结束时要判断用户是否去取号了,不然就记录为爽约 在用户取 ...
- redis之如何实现消息队列
写在前面 本文一起来看下使用redis如何实现消息队列的功能.目前在redis想要实现消息队列的功能有如下的两种方案: 1:基于List的lpush和rpop 2:Streams 这里不将pub/su ...
- RTX5 | 消息队列05 - 获取剩余空间，清空消息队列，删除消息队列
文章目录 一.前言 二.实验目的 三.API 3.1.osMessageQueueGetSpace 3.2.osMessageQueueReset 3.3.osMessageQueueDelete 四 ...
- linux消息队列消息清空函数,ipcrm命令_Linux ipcrm 命令用法详解：删除消息队列、信号集、或者共享内存标识...
ipcrm命令用来删除一个或更多的消息队列.信号量集或者共享内存标识. 语法ipcrm [ -m SharedMemoryID ] [ -M SharedMemoryKey ] [ -q Messag ...
- Pyspider 使用带认证redis集群作为消息队列
文章目录 概述 pyspider message_queue 源码解读 pyspider的message_queue的配置文件 使用redis集群时的配置文件 使用redis单点,带认证时的messa ...
- MySQL数据同步到 Redis 缓存的几种方法
1 Mysql查完数据,再同步写入到Redis中 缺点1:会对接口造成延迟,因为同步写入redis本身就有延迟,并且还要做重试,如果redis写入失败,还需要重试,那就更费时间了. 缺点2:不解耦,如 ...
- 大数据互联网架构阶段 QuartZ定时任务+RabbitMQ消息队列
QuartZ定时任务+RabbitMQ消息队列 一 .QuartZ定时任务解决订单系统遗留问题 情景分析: 在电商项目中 , 订单生成后 , 数据库商品数量-1 , 但是用户迟迟不进行支付操作 , 这 ...
最新文章
- SAP QM中阶之Material Specification的使用
- Maven学习总结(七)——eclipse中使用Maven创建Web项目
- 1-4-RHEL6.3-用户及组管理（Red Hat Enterprise Linux Server release 6.3）@树袋飘零
- 如何成为一名优秀的架构师
- Java学习笔记7-1——注解与反射
- [文章存档]Azure上部署的java app在向第三方服务传送中文时出现乱码
- 深入理解CPU cache：组织、一致性（同步）、编程
- 数字化转型方法论_老板让我搞数字化转型？成功之后，我整理了这套超全的方法论...
- H264的RTP负载打包的数据包格式,分组,分片
- Verdi快速使用技巧
- mysql 错误代码1130_mysql出现错误码1130怎么办
- if (Build.VERSION.SDK_INT = Build.VERSION_CODES.KITKAT)设置后的效果
- Python数据挖掘：利用聚类算法进行航空公司客户价值分析
- js简单交互动画，运动吧
- Sklearn-preprocessing.scale/StandardScaler/MinMaxScaler
- 中视典编辑器 输出html5,虚拟现实软件|VRP-BUILDER 虚拟现实编辑器 - 【中视典数字科技】...
- 一句话证明你是搞python_如何用一句话证明你是程序员？
- 纯小白初识函数—主函数调用子函数：
- Jsp和Javascript读写cookie，cookie的path设置，jsp解码cookie值
- 【异常检测-论文阅读】（CVPR 2022）Self-Supervised Predictive Convolutional Attentive Block for Anomaly Detection