C#编程之C#之Redis所欲为
小标 2018-12-28 来源 : 阅读 1341 评论 0

摘要:本文主要向大家介绍了C#编程之C#之Redis所欲为,通过具体的内容向大家展示,希望对大家学习C#编程有所帮助。

本文主要向大家介绍了C#编程之C#之Redis所欲为,通过具体的内容向大家展示,希望对大家学习C#编程有所帮助。

一 Redis是一种支持多种数据结构的键值对数据库
1.1Redis下载地址 :https://github.com/MicrosoftArchive/Redis
建议下载 .msi结尾的应用程序进行安装,会自动安装Redis服务
Redis默认是不能外网访问的
把Redis部署到本地请忽视下面
设置防火墙端口例外
更改redis.conf 文件
bind 127.0.0.1

protected-mode yes
更改为
# bind 127.0.0.1

protected-mode no然后重启Redis服务,
1.2 Redis支持的数据类型:string、list、set、sortedset、geo(Redis 3.2以上版本),注意不同方法写入的值不能用混了,比如有写list的方法写入的值用获取字符串的方法去获取就有问题了。
1.3 Redis的优点:
支持多种复杂类型的数据结构
高命中的数据是运行在内存中的,数据最终还是可以保存到硬盘中,服务器重启后数据不会丢失
服务器是单线程的,来自所有客户端的所有命令都是串行执行的,不用担心并发修改的问题
支持消息订阅/通知机制,可以用作消息队列
key/value 最大长度允许512M
1.4 Redis的缺点:
Redis是单线程的,因此单个Redis的实例只能使用服务器的一个CPU核,不能充分发挥服务器的性能
 
二 在 .Net中操作Redis
2.1 在 .net中主要使用两个开源的组件来操作Redis
1. StackExChange.Redis:依赖的组件少,操作接近原生的Redis操作
2. ServiceStack.Redis:依赖的组件较多,封装的程度较高
NuGet命令安装组件 Install-Package StackExChange.Redis
 
2.2  操作字符串类型的数据

 //创建一个连接,写入一个字符型数据然后读取
public async Task Index()
{    
    //创建一个Redis连接 因为提供了异步的方法,所以本人要玩一个骚操作
    using (ConnectionMultiplexer conn = await ConnectionMultiplexer.ConnectAsync("***.**.**.***:6379"))
    {
        IDatabase db = conn.GetDatabase();
        //往Redis里面写入一个Key为name的字符串
        bool flag= await db.StringSetAsync("name","123");
        //读取数据
        var a= db.StringGet("name");
    }
    return View();
}    


  

//String类型可以用作计数器
public async  Task Index()
{
    using (ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("120.25.161.171:6379,abortConnect = false"))
    {
        IDatabase db = conn.GetDatabase();
        //StringAppend向这个key的字符串追加内容,没有则创建,返回该字符串
        var A = db.StringAppend("敢问是段友?","yes yes yes");
        //StringIncrementAsync计数器,从0开始自加1,没有则从0开始,返回计数后的结果
        long a = await db.StringIncrementAsync("天王盖地虎",1);
        long b = Convert.ToInt64( db.StringGet("天王盖地虎"));
        long c =  db.StringDecrement("清风拂杨柳", 1);
    }
    return View();
}


  
2.3 操作List类型数据

 public async  Task Index()
{
    using (ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("***.**.***.***:6379,abortConnect = false"))
    {
        IDatabase db = conn.GetDatabase();
        for (int i = 0; i < 20; i++)
        {
           //往集合u哦便Push数据
           var a= await db.ListLeftPushAsync("List1", ""+i+"");
        }
        //往集合右边Pop数据Pop读取了数据后数据会从集合中移除(消息队列)
        RedisValue b = db.ListRightPop("List1");
        //读取集合中全部数据,不会将数据移除
        RedisValue[] c =await db.ListRangeAsync("List1");
    }
    return View();
}


  
2.5  Hash
value 又是一个“键值对集合”或者值是另外一个 Dictionary。 
 
2.6 SortedSet类型的数据
如果对于数据遍历顺序有要求,可以使用 sortedset,他会按照打分来进行遍历。 

 public async  Task Index()
{
    using (ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("120.25.161.171:6379,abortConnect = false"))
    {
        IDatabase db = conn.GetDatabase();
        //SortedSetIncrement 用于给Set数据的vaule排序
        for (int i = 0; i < 5; i++)
        {
            var a = db.SortedSetIncrement("resou","小熊vs",1);
        }
        for (int i = 0; i < 3; i++)
        {
            var b = db.SortedSetIncrement("resou", "田伯光", 1);
        }
        for (int i = 0; i <6; i++)
        {
            var c = db.SortedSetIncrement("resou", "段正淳", 1);
        }

        SortedSetEntry[] d= db.SortedSetRangeByRankWithScores("resou");
        foreach (var item in d)
        {
            Console.WriteLine(item);
        }
        //根据排序返回值,可以根据序号查询其中一部分;
        //RedisValue[] SortedSetRangeByRank(RedisKey key, long start = 0, long stop = -1, Order order = Order.Ascending) 
        //根据排序返回值,可以只返回 start-stop 这个范围; 
        //RedisValue[] SortedSetRangeByScore(RedisKey key, double start = double.NegativeInfinity, double stop = double.PositiveInfinity, Exclude exclude = Exclude.None, Order order = Order.Ascending, long skip = 0, long take = -1) 
    }
    return View();
}


  
2.5 Geo数据类型的基本操作
Geo 是 Redis 3.2 版本后新增的数据类型,用来保存兴趣点(POI,point of interest)的坐标信息。 可以实现计算两 POI 之间的距离、获取一个点周边指定距离的 POI。

public async  Task Index()
{
    using (ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("120.25.161.171:6379,abortConnect = false"))
    {
        IDatabase db = conn.GetDatabase();
        //添加一个兴趣点
        db.GeoAdd("hehe", new GeoEntry(11.22,12.23,"1"));
        db.GeoAdd("hehe", new GeoEntry(11.32, 12.23, "2"));
        db.GeoAdd("hehe", new GeoEntry(11.42, 12.23, "3"));
        //根据点的主键获取坐标
        GeoPosition? pos = db.GeoPosition("ShopsGeo", "1");
        //计算两个兴趣点之间的距离
        var a= db.GeoDistance("hehe","1","3",GeoUnit.Meters);
        //计算某个兴趣点范围内其余的兴趣点
        GeoRadiusResult[] grr= db.GeoRadius("hehe",1,10000,GeoUnit.Meters);
        //计算一个经纬度范围内的距离
        GeoRadiusResult[] grr2 = db.GeoRadius("hehe", 11.42, 12.23,1000, GeoUnit.Meters);
        foreach (var item in grr)
        {
           Console.WriteLine(item.Member + ":" + item.Distance + "米");
        }
    }
    return View();
}


  
三 Redis批量操作
 如果一次性执行多个Redis操作很多那么会很慢,可以使用批量操作。
主要有两种方式:
1) 几乎所有的操作都支持数组类型,这样就可以一次性操作多条数据:比如 GeoAdd(RedisKey key, GeoEntry[] values)、SortedSetAdd(RedisKey key, SortedSetEntry[] values)
2) 如果一次性的操作不是简单的同类型操作,那么就要使用批量模式:
IBatch batch = db.CreateBatch(); db.GeoAdd("ShopsGeo1", new GeoEntry(116.34039, 39.94218, "1")); db.StringSet("abc", "123"); batch.Execute(); 
会把当前连接的 CreateBatch()、Execute()之间的操作一次性提交给服务器。  

本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注职坐标编程语言C#.NET频道!

本文由 @小标 发布于职坐标。未经许可,禁止转载。
喜欢 | 0 不喜欢 | 0
看完这篇文章有何感觉?已经有0人表态,0%的人喜欢 快给朋友分享吧~
评论(0)
后参与评论

您输入的评论内容中包含违禁敏感词

我知道了

助您圆梦职场 匹配合适岗位
验证码手机号,获得海同独家IT培训资料
选择就业方向:
人工智能物联网
大数据开发/分析
人工智能Python
Java全栈开发
WEB前端+H5

请输入正确的手机号码

请输入正确的验证码

获取验证码

您今天的短信下发次数太多了,明天再试试吧!

提交

我们会在第一时间安排职业规划师联系您!

您也可以联系我们的职业规划师咨询:

小职老师的微信号:z_zhizuobiao
小职老师的微信号:z_zhizuobiao

版权所有 职坐标-一站式IT培训就业服务领导者 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
 沪公网安备 31011502005948号    

©2015 www.zhizuobiao.com All Rights Reserved

208小时内训课程