AI 助理
备案控制台
开发者社区 云原生 微服务 文章 正文

ASP.NET Core微服务(六)——【.Net Core操作redis】StackExchange.Redis

2022-11-15 341
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
云原生网关 MSE Higress，422元/月
注册配置 MSE Nacos/ZooKeeper，118元/月
简介： ASP.NET Core微服务(六)——【.Net Core操作redis】StackExchange.Redis

项目创建

为了测试方便，使用控制台应用程序即可。


image.png


这里创建.NET Core 3.1(长期支持)

image.png



可以看到，非常干净


image.png


StackExchange.Redis操作示例

打开NuGet包管理器，搜索【StackExchange.Redis】，本示例使用的是2.6.66版本

image.png


引包【using StackExchange.Redis;】

image.png


ConnectionMultiplexer

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("127.0.0.1:6379");
            IDatabase db = conn.GetDatabase();
            db.StringSet("userName","admin");
            RedisValue redisValue = db.StringGet("userName");
            Console.WriteLine(redisValue);
        }
    }
}


输出结果，可以看到admin是咱们拿到的值。



image.png

RedisDBHelper

using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Text;
namespace demo_20221010_redis
{
    class RedisDBHelper
    {
        private ConnectionMultiplexer redis { get; set; }
        public IDatabase db { get; set; }
        /// <summary>
        /// 其实有个链接就行，一般都是默认本地。如果不是就再传
        /// </summary>
        /// <param name="connection"></param>
        public RedisDBHelper(string connection)
        {
            redis = ConnectionMultiplexer.Connect(connection);
            db = redis.GetDatabase();
        }
    }
}


使用RedisDBHelper测试

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            bool isf = redis.db.StringSet("userName","admin");
            if (isf)
            {
                RedisValue redisValue = redis.db.StringGet("userName");
                Console.WriteLine(redisValue.ToString());
            }
            else {
                Console.WriteLine("写入失败");
            }
        }
    }
}

image.png


有存储时间的String

这里输入的时间必须是TimeSpan类型。故而使用TimeSpan.FromSeconds(double);来输入时间。


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            bool isf = redis.db.StringSet("haveTime","我是存储时间",TimeSpan.FromSeconds(120));
            if (isf) {
                Console.WriteLine("存储值："+redis.db.StringGet("haveTime").ToString()) ;
                Console.WriteLine("剩余时间："+redis.db.KeyTimeToLive("haveTime"));
            }
        }
    }
}

image.png


Redis删除Key：KeyDelete

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            bool isf = redis.db.StringSet("haveTime","我是存储时间",TimeSpan.FromSeconds(120));
            if (isf) {
                //删除后再查询，肯定是空
                redis.db.KeyDelete("havaTime");
                Console.WriteLine("是否有值："+redis.db.StringGet("havaTime"));
            }
        }
    }
}

image.png


没有值就是正确的，这个删除可以删除任何的可以，都是通用的。


Redis的List操作

向左添加，其中ListRange是读取。


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mylist");
            RedisValue[] arr = new RedisValue[10];
            for (int i = 0; i < arr.Length; i++)
            {
                arr[i]=  new RedisValue("正确"+i);
            }
            long isf = redis.db.ListLeftPush("mylist",arr);
            RedisValue[] list = redis.db.ListRange("mylist");
            foreach (var item in list)
            {
                Console.WriteLine(item);
            }
        }
    }
}

image.png


向右添加

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mylist");
            RedisValue[] arr = new RedisValue[10];
            for (int i = 0; i < arr.Length; i++)
            {
                arr[i]=  new RedisValue("正确"+i);
            }
            long isf = redis.db.ListRightPush("mylist",arr);
            RedisValue[] list = redis.db.ListRange("mylist");
            foreach (var item in list)
            {
                Console.WriteLine(item);
            }
        }
    }
}


image.png


redis list范围查询

一般的时候list存储的值都是成千上万的，甚至几十上百万，所以我们需要好好处理一下。一般的情况下也就获取最后一千条左右的数据，如果都返回去了不就能让别人推算出后面的大致数据走向了吗？


这里我专门匹配的写了RedisValue，其实写字符串数组也行的。


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mylist");
            RedisValue[] arr = new RedisValue[10];
            for (int i = 0; i < arr.Length; i++)
            {
                arr[i] = new RedisValue("正确" + i);
            }
            long isf = redis.db.ListRightPush("mylist", arr);
            RedisValue[] list = redis.db.ListRange("mylist",0,5);
            foreach (var item in list)
            {
                Console.WriteLine(item);
            }
        }
    }
}


image.png


redis HashSet操作

如果替换file的话直接写名字替换值即可。


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("myHashSet");
            redis.db.HashSet("myHashSet","id","9527");
            redis.db.HashSet("myHashSet","userName","admin");
            redis.db.HashSet("myHashSet","sex","男");
            redis.db.HashSet("myHashSet","age","22");
            redis.db.HashDelete("myHashSet","sex");
            HashEntry[] hashEntries = redis.db.HashGetAll("myHashSet");
            foreach (var item in hashEntries)
            {
                Console.WriteLine(item);
            }
        }
    }
}


image.png


redis Set操作

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mySet");
            redis.db.SetAdd("mySet","a1");
            redis.db.SetAdd("mySet","a2");
            redis.db.SetAdd("mySet","a3");
            redis.db.SetAdd("mySet","a4");
            redis.db.SetAdd("mySet","a5");
            RedisValue[] redisValues = redis.db.SetMembers("mySet");
            foreach (var item in redisValues)
            {
                Console.WriteLine(item);
            }
        }
    }
}

image.png



获取Set长度

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mySet");
            redis.db.KeyDelete("mySet1");
            redis.db.SetAdd("mySet","a1");
            redis.db.SetAdd("mySet","a2");
            redis.db.SetAdd("mySet","a3");
            redis.db.SetAdd("mySet","a4");
            redis.db.SetAdd("mySet","a5");
            redis.db.SetAdd("mySet1","a1");
            redis.db.SetAdd("mySet1","a2");
            redis.db.SetAdd("mySet1","a6");
            redis.db.SetAdd("mySet1","a7");
            long v1 = redis.db.SetLength("mySet");
            long v2 = redis.db.SetLength("mySet1");
            Console.WriteLine("v1:"+v1);
            Console.WriteLine("v2:"+v2);
        }
    }
}


image.png


Set查询交集


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mySet");
            redis.db.KeyDelete("mySet1");
            redis.db.SetAdd("mySet","a1");
            redis.db.SetAdd("mySet","a2");
            redis.db.SetAdd("mySet","a3");
            redis.db.SetAdd("mySet","a4");
            redis.db.SetAdd("mySet","a5");
            redis.db.SetAdd("mySet1","a1");
            redis.db.SetAdd("mySet1","a2");
            redis.db.SetAdd("mySet1","a6");
            redis.db.SetAdd("mySet1","a7");
            RedisValue[] redisValues = redis.db.SetCombine(SetOperation.Intersect, "mySet", "mySet1");
            foreach (var item in redisValues)
            {
                Console.WriteLine(item);
            }
        }
    }
}


image.png


Set查询差集


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mySet");
            redis.db.KeyDelete("mySet1");
            redis.db.SetAdd("mySet","a1");
            redis.db.SetAdd("mySet","a2");
            redis.db.SetAdd("mySet","a3");
            redis.db.SetAdd("mySet","a4");
            redis.db.SetAdd("mySet","a5");
            redis.db.SetAdd("mySet1","a1");
            redis.db.SetAdd("mySet1","a2");
            redis.db.SetAdd("mySet1","a6");
            redis.db.SetAdd("mySet1","a7");
            RedisValue[] redisValues = redis.db.SetCombine(SetOperation.Difference, "mySet", "mySet1");
            foreach (var item in redisValues)
            {
                Console.WriteLine(item);
            }
        }
    }
}

image.png


Set查询并集


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("mySet");
            redis.db.KeyDelete("mySet1");
            redis.db.SetAdd("mySet","a1");
            redis.db.SetAdd("mySet","a2");
            redis.db.SetAdd("mySet","a3");
            redis.db.SetAdd("mySet","a4");
            redis.db.SetAdd("mySet","a5");
            redis.db.SetAdd("mySet1","a1");
            redis.db.SetAdd("mySet1","a2");
            redis.db.SetAdd("mySet1","a6");
            redis.db.SetAdd("mySet1","a7");
            RedisValue[] redisValues = redis.db.SetCombine(SetOperation.Union, "mySet", "mySet1");
            foreach (var item in redisValues)
            {
                Console.WriteLine(item);
            }
        }
    }
}

image.png


Redis ZSET

using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("myZset");
            redis.db.SortedSetAdd("myZset","a1",69);
            redis.db.SortedSetAdd("myZset","a2",79);
            redis.db.SortedSetAdd("myZset","a3",85);
            redis.db.SortedSetAdd("myZset","a4",82);
            redis.db.SortedSetAdd("myZset","a5",92);
            //分数范围
            RedisValue[] redisValues = redis.db.SortedSetRangeByScore("myZset", 70, 90);
            foreach (var item in redisValues)
            {
                Console.WriteLine(item);
            }
        }
    }
}


image.png

正序

Plain Text

自动换行

xxxxxxxxxx

 

1

using StackExchange.Redis;

2

using System;

3

namespace demo_20221010_redis

4

{

5

    class Program

6

    {

7

        static void Main(string[] args)

8

        {

9

            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");

10

            redis.db.KeyDelete("myZset");

11

            redis.db.SortedSetAdd("myZset","a1",69);

12

            redis.db.SortedSetAdd("myZset","a2",79);

13

            redis.db.SortedSetAdd("myZset","a3",85);

14

            redis.db.SortedSetAdd("myZset","a4",82);

15

            redis.db.SortedSetAdd("myZset","a5",92);

16

            //正序

17

            SortedSetEntry[] sortedSetEntries = redis.db.SortedSetRangeByRankWithScores("myZset",0,-1,Order.Ascending);

18

            foreach (var item in sortedSetEntries)

19

            {

20

                Console.WriteLine(item);

21

            }

22

        }

23

    }

24

}


image.png


倒序


using StackExchange.Redis;
using System;
namespace demo_20221010_redis
{
    class Program
    {
        static void Main(string[] args)
        {
            RedisDBHelper redis = new RedisDBHelper("127.0.0.1:6379");
            redis.db.KeyDelete("myZset");
            redis.db.SortedSetAdd("myZset","a1",69);
            redis.db.SortedSetAdd("myZset","a2",79);
            redis.db.SortedSetAdd("myZset","a3",85);
            redis.db.SortedSetAdd("myZset","a4",82);
            redis.db.SortedSetAdd("myZset","a5",92);
            //正序
            SortedSetEntry[] sortedSetEntries = redis.db.SortedSetRangeByRankWithScores("myZset",0,-1,Order.Descending);
            foreach (var item in sortedSetEntries)
            {
                Console.WriteLine(item);
            }
        }
    }
}

image.png

文章标签：
云数据库 Tair（兼容 Redis）
.NET
微服务
NoSQL
Redis
存储
开发框架
关键词：
ASP.NET core
.NET core
ASP Core
.NET .netcore
微服务.net
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务，基于高可靠双机热备架构及可无缝扩展的集群架构，满足高读写性能场景及容量需弹性变配的业务需求。 产品详情：https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验：数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引，您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接，领取免费ECS&amp;RDS资源，30分钟完成数据库上云实战！https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
红目香薰
目录
相关文章
土木林森
|
2月前
|
XML JSON API
ServiceStack：不仅仅是一个高性能Web API和微服务框架，更是一站式解决方案——深入解析其多协议支持及简便开发流程，带您体验前所未有的.NET开发效率革命
【10月更文挑战第9天】ServiceStack 是一个高性能的 Web API 和微服务框架，支持 JSON、XML、CSV 等多种数据格式。它简化了 .NET 应用的开发流程，提供了直观的 RESTful 服务构建方式。ServiceStack 支持高并发请求和复杂业务逻辑，安装简单，通过 NuGet 包管理器即可快速集成。示例代码展示了如何创建一个返回当前日期的简单服务，包括定义请求和响应 DTO、实现服务逻辑、配置路由和宿主。ServiceStack 还支持 WebSocket、SignalR 等实时通信协议，具备自动验证、自动过滤器等丰富功能，适合快速搭建高性能、可扩展的服务端应用。
土木林森
143 3
小王老师呀
|
2月前
|
存储 开发框架 JSON
ASP.NET Core OData 9 正式发布
【10月更文挑战第8天】Microsoft 在 2024 年 8 月 30 日宣布推出 ASP.NET Core OData 9，此版本与 .NET 8 的 OData 库保持一致，改进了数据编码以符合 OData 规范，并放弃了对旧版 .NET Framework 的支持，仅支持 .NET 8 及更高版本。新版本引入了更快的 JSON 编写器 `System.Text.UTF8JsonWriter`，优化了内存使用和序列化速度。
小王老师呀
83 0
小王老师呀
|
3月前
|
开发框架 监控 前端开发
在 ASP.NET Core Web API 中使用操作筛选器统一处理通用操作
【9月更文挑战第27天】操作筛选器是ASP.NET Core MVC和Web API中的一种过滤器，可在操作方法执行前后运行代码，适用于日志记录、性能监控和验证等场景。通过实现`IActionFilter`接口的`OnActionExecuting`和`OnActionExecuted`方法，可以统一处理日志、验证及异常。创建并注册自定义筛选器类，能提升代码的可维护性和复用性。
小王老师呀
42 3
长梦
|
3月前
|
开发框架 .NET 中间件
ASP.NET Core Web 开发浅谈
本文介绍ASP.NET Core，一个轻量级、开源的跨平台框架，专为构建高性能Web应用设计。通过简单步骤，你将学会创建首个Web应用。文章还深入探讨了路由配置、依赖注入及安全性配置等常见问题，并提供了实用示例代码以助于理解与避免错误，帮助开发者更好地掌握ASP.NET Core的核心概念。
长梦
109 3
追逐时光者
|
2月前
|
开发框架 JavaScript 前端开发
一个适用于 ASP.NET Core 的轻量级插件框架
一个适用于 ASP.NET Core 的轻量级插件框架
追逐时光者
62 0
小王老师呀
|
3月前
|
开发框架 NoSQL .NET
利用分布式锁在ASP.NET Core中实现防抖
【9月更文挑战第5天】在 ASP.NET Core 中，可通过分布式锁实现防抖功能，仅处理连续相同请求中的首个请求，其余请求返回 204 No Content，直至锁释放。具体步骤包括：安装分布式锁库如 `StackExchange.Redis`；创建分布式锁服务接口及其实现；构建防抖中间件；并在 `Startup.cs` 中注册相关服务和中间件。这一机制有效避免了短时间内重复操作的问题。
小王老师呀
81 4
代码掌控者
|
4月前
|
开发框架 前端开发 中间件
聊聊 ASP.NET Core 中间件（二）：中间件和筛选器的区别
聊聊 ASP.NET Core 中间件（二）：中间件和筛选器的区别
代码掌控者
141 1
代码掌控者
|
4月前
|
开发框架 缓存 NoSQL
聊聊 ASP.NET Core 中间件（一）：一个简单的中间件例子
聊聊 ASP.NET Core 中间件（一）：一个简单的中间件例子
代码掌控者
47 1
代码掌控者
|
4月前
|
开发框架 .NET 数据库连接
闲话 Asp.Net Core 数据校验（三）EF Core 集成 FluentValidation 校验数据例子
闲话 Asp.Net Core 数据校验（三）EF Core 集成 FluentValidation 校验数据例子
代码掌控者
95 1
代码掌控者
|
4月前
|
开发框架 前端开发 .NET
闲话 ASP.NET Core 数据校验（二）：FluentValidation 基本用法
闲话 ASP.NET Core 数据校验（二）：FluentValidation 基本用法
代码掌控者
46 1
云原生

微服务

热门文章

最新文章

  • 1
    微服务架构的理论基础 - 康威定律
  • 2
    微服务（Microservice）那点事
  • 3
    微服务选择Spring Cloud还是Dubbo？
  • 4
    微服务一站式解决方案Spring Cloud
  • 5
    微服务架构下分布式事务解决方案 —— 阿里GTS
  • 6
    五分钟内免费体验 EDAS ，完美解决微服务痛点
  • 7
    从 SOA 到微服务，企业分布式应用架构在云原生时代如何重塑？
  • 8
    Java微服务开发指南 -- 使用Spring Boot构建微服务
  • 9
    Istio从懵圈到熟练 – 二分之一活的微服务
  • 10
    5分钟学习基于Go，go-microservice-template，Minke的微服务
  • 1
    阿里云微服务引擎 MSE 及 云原生 API 网关 2024 年 11 月产品动态
    31
  • 2
    Spring Cloud Alibaba：一站式微服务解决方案
    76
  • 3
    微服务架构解析：跨越传统架构的技术革命
    85
  • 4
    从单体到微服务：如何借助 Spring Cloud 实现架构转型
    104
  • 5
    JVM进阶调优系列(10)敢向stop the world喊卡的G1垃圾回收器 | 有必要讲透
    39
  • 6
    JVM进阶调优系列(9)大厂面试官:内存溢出几种？能否现场演示一下？| 面试就那点事
    86
  • 7
    热联集团：从 APISIX 迁移到云原生网关
    95
  • 8
    阿里云微服务引擎 MSE 及 云原生 API 网关 2024 年 10 月产品动态
    59
  • 9
    java.util的Collections类
    51
  • 10
    JVM进阶调优系列(8)如何手把手，逐行教她看懂GC日志？| IT男的专属浪漫
    108

    • 相关课程

    更多
  • 微服务实战-RocketMQ Binder
  • 微服务实战-服务注册中心 - Nacos
  • 微服务实战-Service Mesh与Istio
  • 微服务实战-分布式配置中心 - Config
  • 微服务实战-服务注册与发现 - Nacos Discovery
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 微服务治理技术白皮书
  • 微服务与Serverless
  • EDAS4.0 助力企业一站实现微服务架构转型与 K8s 容器化升级

    • 相关实验场景

    更多
  • 基于Redis实现在线游戏积分排行榜
  • 通过EDAS实现K8s微服务应用的金丝雀发布
  • SAE极速部署弹性微服务商城
  • 基于MSE实现微服务的全链路灰度
  • 基于云原生网关实现微服务的多版本线上灰度
  • Tair for Redis数据闪回：任意时间点数据恢复
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月