失眠网,内容丰富有趣,生活中的好帮手!
失眠网 > 将数据写入到redis缓存/取出/删除 消息队列

将数据写入到redis缓存/取出/删除 消息队列

时间:2023-10-17 08:07:54

相关推荐

将数据写入到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缓存/取出/删除 消息队列》对你有帮助,请点赞、收藏,并留下你的观点哦!

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。