C#之Redis所欲为

本文主要是介绍C#之Redis所欲为，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

一 Redis是一种支持多种数据结构的键值对数据库

1.1Redis下载地址 ：https://github.com/MicrosoftArchive/Redis

建议下载 .msi结尾的应用程序进行安装，会自动安装Redis服务

Redis默认是不能外网访问的

把Redis部署到本地请忽视下面

设置防火墙端口例外

更改redis.conf 文件

1.   bind 127.0.0.1
2.    
3.   protected-mode yes

更改为

1.   # bind 127.0.0.1
2.    
3.   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  操作字符串类型的数据

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

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

2.3 操作List类型数据

1.   public async Task<ViewResult> Index()
2.   {
3.   using (ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("***.**.***.***:6379,abortConnect = false"))
4.   {
5.   IDatabase db = conn.GetDatabase();
6.   for (int i = 0; i < 20; i++)
7.   {
8.   //往集合u哦便Push数据
9.   var a= await db.ListLeftPushAsync("List1", ""+i+"");
10.   }
11.   //往集合右边Pop数据Pop读取了数据后数据会从集合中移除（消息队列）
12.   RedisValue b = db.ListRightPop("List1");
13.   //读取集合中全部数据，不会将数据移除
14.   RedisValue[] c =await db.ListRangeAsync("List1");
15.   }
16.   return View();
17.   }

2.5  Hash

value 又是一个“键值对集合”或者值是另外一个 Dictionary。 

2.6 SortedSet类型的数据

如果对于数据遍历顺序有要求，可以使用 sortedset，他会按照打分来进行遍历。 

1.   public async Task<ViewResult> Index()
2.   {
3.   using (ConnectionMultiplexer conn = ConnectionMultiplexer.Connect("120.25.161.171:6379,abortConnect = false"))
4.   {
5.   IDatabase db = conn.GetDatabase();
6.   //SortedSetIncrement 用于给Set数据的vaule排序
7.   for (int i = 0; i < 5; i++)
8.   {
9.   var a = db.SortedSetIncrement("resou","小熊vs",1);
10.   }
11.   for (int i = 0; i < 3; i++)
12.   {
13.   var b = db.SortedSetIncrement("resou", "田伯光", 1);
14.   }
15.   for (int i = 0; i <6; i++)
16.   {
17.   var c = db.SortedSetIncrement("resou", "段正淳", 1);
18.   }
19.    
20.   SortedSetEntry[] d= db.SortedSetRangeByRankWithScores("resou");
21.   foreach (var item in d)
22.   {
23.   Console.WriteLine(item);
24.   }
25.   //根据排序返回值，可以根据序号查询其中一部分；
26.   //RedisValue[] SortedSetRangeByRank(RedisKey key, long start = 0, long stop = -1, Order order = Order.Ascending)
27.   //根据排序返回值，可以只返回 start-stop 这个范围；
28.   //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)
29.   }
30.   return View();
31.   }

2.5 Geo数据类型的基本操作

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

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

三 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()之间的操作一次性提交给服务器。 

转载于:https://www.cnblogs.com/xiongT/p/9038845.html

这篇关于C#之Redis所欲为的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！