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

举报
红目香薰 发表于 2022/10/28 00:21:51 2022/10/28
【摘要】 ​ ​编辑ASP.NET Core微服务(六)——【.Net Core操作redis】StackExchange.Redis目录ASP.NET Core微服务(六)——【.Net Core操作redis】StackExchange.Redis项目创建StackExchange.Redis操作示例引包【using StackExchange.Redis;】ConnectionMultiplex...

​

 ​编辑

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

目录

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

项目创建

StackExchange.Redis操作示例

引包【using StackExchange.Redis;】

ConnectionMultiplexer

RedisDBHelper

使用RedisDBHelper测试

有存储时间的String

Redis删除Key：KeyDelete

Redis的List操作

redis list范围查询

redis HashSet操作

redis Set操作

Redis ZSET


项目创建

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

​编辑

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

​编辑

可以看到，非常干净

​编辑

StackExchange.Redis操作示例

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

​编辑

引包【using StackExchange.Redis;】

​编辑

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是咱们拿到的值。 

​编辑

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("写入失败");
            }
        }
    }
}

​编辑

有存储时间的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"));
            }
        }
    }
}

​编辑

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"));
            }
        }
    }
}

​编辑

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

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);
            }
        }
    }
}

​编辑

向右添加

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);
            }
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

获取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);
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

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);
            }
        }
    }
}

​编辑

正序

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.Ascending);
            foreach (var item in sortedSetEntries)
            {
                Console.WriteLine(item);
            }
        }
    }
}

​编辑

倒序

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);
            }
        }
    }
}

​编辑


​

【版权声明】本文为华为云社区用户原创内容，转载时必须标注文章的来源（华为云社区）、文章链接、文章作者等基本信息， 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱： cloudbbs@huaweicloud.com
ASP.NET Redis
  • 点赞
  • 收藏
  • 关注作者

评论（0）

0/1000
抱歉，系统识别当前为高风险访问，暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称，即可参与社区互动！

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

确认 取消

加入云驻计划，成为创作者

  • 华为云周边好礼
  • 免费体验产品
  • 特殊身份标识
  • 线下官方门票
  • 内部专家零距离
  • 与10000+优质创作者共同成长
立即加入