备案控制台
探索云世界
开发者社区 云原生 微服务 文章 正文

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

2022-11-15 284
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
简介： 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

文章标签：
云数据库 Redis 版
.NET
微服务
NoSQL
Redis
存储
开发框架
关键词：
.NET .netcore
.NETCore
云数据库 Redis 版操作
ASP.NET core
ASP Core
相关实践学习
基于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
红目香薰
目录
相关文章
追逐时光者
|
18天前
|
数据可视化 网络协议 C#
C#/.NET/.NET Core优秀项目和框架2024年3月简报
公众号每月定期推广和分享的C#/.NET/.NET Core优秀项目和框架（每周至少会推荐两个优秀的项目和框架当然节假日除外），公众号推文中有项目和框架的介绍、功能特点、使用方式以及部分功能截图等（打不开或者打开GitHub很慢的同学可以优先查看公众号推文，文末一定会附带项目和框架源码地址）。注意：排名不分先后，都是十分优秀的开源项目和框架，每周定期更新分享（欢迎关注公众号：追逐时光者，第一时间获取每周精选分享资讯🔔）。
追逐时光者
48 1
亚丁号
|
3月前
|
开发框架 前端开发 JavaScript
盘点72个ASP.NET Core源码Net爱好者不容错过
盘点72个ASP.NET Core源码Net爱好者不容错过
亚丁号
71 0
Cool架构
|
30天前
|
存储 NoSQL Java
Redis 数据结构操作入门
Redis 数据结构操作入门
Cool架构
15 0
不会就选C.
|
1月前
|
缓存 NoSQL 数据库
[Redis]——数据一致性，先操作数据库，还是先更新缓存？
[Redis]——数据一致性，先操作数据库，还是先更新缓存？
不会就选C.
33 0
追逐时光者
|
1月前
|
开发框架 人工智能 .NET
C#/.NET/.NET Core拾遗补漏合集（持续更新）
C#/.NET/.NET Core拾遗补漏合集（持续更新）
追逐时光者
15 1
傻啦嘿哟
|
1月前
|
存储 NoSQL Redis
如何在Python中操作Redis数据库
如何在Python中操作Redis数据库
傻啦嘿哟
29 0
GoodTime
|
1月前
|
开发框架 中间件 .NET
C# .NET面试系列七：ASP.NET Core
## 第一部分：ASP.NET Core #### 1. 如何在 controller 中注入 service? 在.NET中，在ASP.NET Core应用程序中的Controller中注入服务通常使用<u>依赖注入（Dependency Injection）</u>来实现。以下是一些步骤，说明如何在Controller中注入服务： 1、创建服务 首先，确保你已经在应用程序中注册了服务。这通常在Startup.cs文件的ConfigureServices方法中完成。例如： ```c# services.AddScoped<IMyService, MyService>(); //
GoodTime
65 0
麒麟改bug
|
2月前
|
NoSQL 测试技术 Redis
六步操作教你轻松搭建Redis集群
Redis 是我们目前大规模使用的缓存中间件，由于它强大高效而又便捷的功能，得到了广泛的使用。单节点的Redis已经就达到了很高的性能，为了提高可用性我们可以使用Redis集群。本文参考了Rdis的官方文档和使用Redis官方提供的Redis Cluster工具搭建Rdis集群。
麒麟改bug
43 0
老码识途
|
2月前
|
开发框架 前端开发 .NET
福利来袭，.NET Core开发5大案例，30w字PDF文档大放送！！！
为了便于大家查找，特将之前开发的.Net Core相关的五大案例整理成文，共计440页，32w字，免费提供给大家，文章底部有PDF下载链接。
老码识途
35 1
福利来袭，.NET Core开发5大案例，30w字PDF文档大放送！！！
追逐时光者
|
2月前
|
算法 BI API
C#/.NET/.NET Core优秀项目和框架2024年1月简报
C#/.NET/.NET Core优秀项目和框架2024年1月简报
追逐时光者
72 2
云原生

微服务

热门文章

最新文章

  • 1
    微服务架构的理论基础 - 康威定律
  • 2
    微服务（Microservice）那点事
  • 3
    微服务选择Spring Cloud还是Dubbo？
  • 4
    微服务架构的分布式事务解决方案
  • 5
    2019年5月下旬最值得一读的9本技术书籍（微服务架构、算法、大数据等书籍）！
  • 6
    微服务网关Zuul迁移到Spring Cloud Gateway
  • 7
    微服务架构下的事务一致性保证
  • 8
    鹰眼跟踪、限流降级，EDAS的微服务解决之道
  • 9
    微服务一站式解决方案Spring Cloud
  • 10
    微服务架构下分布式事务解决方案 —— 阿里GTS
  • 1
    【微服务系列笔记】Seata
    44
  • 2
    【微服务系列笔记】MQ消息可靠性
    33
  • 3
    nacos报错 Server check fail, please check server 127.0.0.1 ,port 9848 is available , error ={}
    35
  • 4
    nacos 2.3.2模式 standalone 使用nginx 反向代理之后访问nacos控制台静
    33
  • 5
    SpringBoot中bean的生命周期
    40
  • 6
    深入探索：主流低代码开发平台的应用场景及开发流程
    24
  • 7
    云原生开源沙龙北京站开启报名 | 微服务安全零信任架构
    2591
  • 8
    SIP极简教程
    80
  • 9
    SpringCloud微服务实战——搭建企业级开发框架（四十六）：【移动开发】整合uni-app搭建移动端快速开发框架-环境搭建
    145
  • 10
    阿里云微服务引擎 MSE 及 API 网关 2024 年 02 月产品动态
    463

    • 相关课程

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

    • 相关电子书

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

    • 相关实验场景

    更多
  • 通过EDAS实现K8s微服务应用的金丝雀发布
  • SAE极速部署弹性微服务商城
  • Shared Server 的高可用特性
  • 基于MSE实现微服务的全链路灰度
  • Elasticsearch Java API Client 开发
  • 基于云原生网关实现微服务的多版本线上灰度
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）