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

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

2022-11-15 558
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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
存储
开发框架
关键词：
.NET core
ASP.NET core
ASP Core
微服务云数据库 Tair（兼容 Redis）
微服务redis
红目香薰
目录
相关文章
Quan_Chen
|
12月前
|
NoSQL Java 关系型数据库
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
本文介绍在 Spring Boot 中集成 Redis 的方法。Redis 是一种支持多种数据结构的非关系型数据库（NoSQL），具备高并发、高性能和灵活扩展的特点，适用于缓存、实时数据分析等场景。其数据以键值对形式存储，支持字符串、哈希、列表、集合等类型。通过将 Redis 与 Mysql 集群结合使用，可实现数据同步，提升系统稳定性。例如，在网站架构中优先从 Redis 获取数据，故障时回退至 Mysql，确保服务不中断。
Quan_Chen
422 0
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
土木林森
|
XML JSON API
ServiceStack：不仅仅是一个高性能Web API和微服务框架，更是一站式解决方案——深入解析其多协议支持及简便开发流程，带您体验前所未有的.NET开发效率革命
【10月更文挑战第9天】ServiceStack 是一个高性能的 Web API 和微服务框架，支持 JSON、XML、CSV 等多种数据格式。它简化了 .NET 应用的开发流程，提供了直观的 RESTful 服务构建方式。ServiceStack 支持高并发请求和复杂业务逻辑，安装简单，通过 NuGet 包管理器即可快速集成。示例代码展示了如何创建一个返回当前日期的简单服务，包括定义请求和响应 DTO、实现服务逻辑、配置路由和宿主。ServiceStack 还支持 WebSocket、SignalR 等实时通信协议，具备自动验证、自动过滤器等丰富功能，适合快速搭建高性能、可扩展的服务端应用。
土木林森
890 3
Quan_Chen
|
12月前
|
NoSQL Java API
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Spring Boot 集成 Redis
本文介绍了在Spring Boot中集成Redis的方法，包括依赖导入、Redis配置及常用API的使用。通过导入`spring-boot-starter-data-redis`依赖和配置`application.yml`文件，可轻松实现Redis集成。文中详细讲解了StringRedisTemplate的使用，适用于字符串操作，并结合FastJSON将实体类转换为JSON存储。还展示了Redis的string、hash和list类型的操作示例。最后总结了Redis在缓存和高并发场景中的应用价值，并提供课程源代码下载链接。
Quan_Chen
2592 0
Quan_Chen
|
12月前
|
NoSQL Java Redis
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 安装
本教程介绍在 VMware 虚拟机（CentOS 7）或阿里云服务器中安装 Redis 的过程，包括安装 gcc 编译环境、下载 Redis（官网或 wget）、解压安装、修改配置文件（如 bind、daemonize、requirepass 等设置）、启动 Redis 服务及测试客户端连接。通过 set 和 get 命令验证安装是否成功。适用于初学者快速上手 Redis 部署。
Quan_Chen
354 0
何雨晨
|
存储 消息中间件 NoSQL
Redis 入门 - C#.NET Core客户端库六种选择
Redis 入门 - C#.NET Core客户端库六种选择
何雨晨
885 8
路边两盏灯
|
缓存 NoSQL Java
【Azure Redis 缓存 Azure Cache For Redis】Redis出现 java.net.SocketTimeoutException: Read timed out 异常
【Azure Redis 缓存 Azure Cache For Redis】Redis出现 java.net.SocketTimeoutException: Read timed out 异常
路边两盏灯
273 5
路边两盏灯
|
缓存 NoSQL 网络协议
【Azure Redis 缓存】Redisson 连接 Azure Redis出现间歇性 java.net.UnknownHostException 异常
【Azure Redis 缓存】Redisson 连接 Azure Redis出现间歇性 java.net.UnknownHostException 异常
路边两盏灯
595 1
路边两盏灯
|
存储 NoSQL Redis
【Azure Developer】一个复制Redis Key到另一个Redis服务的工具(redis_copy_net8)
【Azure Developer】一个复制Redis Key到另一个Redis服务的工具(redis_copy_net8)
路边两盏灯
160 0
【Azure Developer】一个复制Redis Key到另一个Redis服务的工具(redis_copy_net8)
代码掌控者
|
开发框架 JSON .NET
ASP.NET Core 标识（Identity）框架系列（三）：在 ASP.NET Core Web API 项目中使用标识（Identity）框架进行身份验证
ASP.NET Core 标识（Identity）框架系列（三）：在 ASP.NET Core Web API 项目中使用标识（Identity）框架进行身份验证
代码掌控者
298 1
土木林森
|
NoSQL Java Redis
Spring Boot集成Redis全攻略：高效数据存取，打造性能飞跃的Java微服务应用！
【8月更文挑战第3天】Spring Boot是备受欢迎的微服务框架，以其快速开发与轻量特性著称。结合高性能键值数据库Redis，可显著增强应用性能。集成步骤包括：添加`spring-boot-starter-data-redis`依赖，配置Redis服务器参数，注入`RedisTemplate`或`StringRedisTemplate`进行数据操作。这种集成方案适用于缓存、高并发等场景，有效提升数据处理效率。
土木林森
1168 2
云原生

微服务

热门文章

最新文章

  • 1
    微服务架构下，解决数据一致性问题的实践
  • 2
    你所不了解的微服务架构
  • 3
    新网银行微服务转型实践
  • 4
    用SpringCloud进行微服务架构演进
  • 5
    大规模微服务架构下的 Service Mesh 探索之路
  • 6
    融数微服务架构
  • 7
    微服务与网关技术（SIA-GateWay）
  • 8
    微服务实战：从架构到部署
  • 9
    微服务基础
  • 10
    微服务，微架构[六]之springboot集成mybatis
  • 1
    阿里云微服务引擎 MSE 及 API 网关 2026 年 2 月产品动态
    29
  • 2
    阿里云微服务引擎 MSE 及 API 网关 2026 年 1 月产品动态
    203
  • 3
    GoWind Admin｜风行 — 开箱即用的企业级全栈中后台框架・内置微服务接口数据聚合能力
    171
  • 4
    GoWind Admin｜风行 — 开箱即用的企业级全栈中后台框架：数据权限体系设计与实现
    458
  • 5
    阿里云微服务引擎 MSE 及 API 网关 2025 年 12 月产品动态
    258
  • 6
    需求开发人日评估
    145
  • 7
    零拷贝
    119
  • 8
    2-MongoDB单机部署
    229
  • 9
    Java泛型类型擦除以及类型擦除带来的问题
    218
  • 10
    1-MongoDB相关概念
    230

    • 相关课程

    更多
  • 微服务实战-RocketMQ Binder
  • 微服务实战-服务熔断 - Sentinel
  • 微服务实战-服务注册中心 - Nacos
  • 微服务实战-Service Mesh与Istio
  • 微服务实战-服务注册与发现 - Nacos Discovery
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 微服务x容器开源开发者 Meetup 上海站
  • 微服务治理技术白皮书
  • 微服务与Serverless

    • 相关实验场景

    更多
  • SAE极速部署弹性微服务商城
    • 下一篇
    极速数仓ClickHouse步入云原生新纪元