基本用法

ConnectionMultiplexer 类是StackExchange.Redis的中枢对象,它在StackExchange.Redis名称空间中;
这个对象封装了很多基础服务对象的详细信息。由于 ConnectionMultiplexer 做了很多底层处理,它在调用者之间被设计为共享和重用。你不应该为每一个操作都创建一个 ConnectionMultiplexer 对象。该对象是完全线程安全的。在随后所有的示例中,ConnectionMultiplexer 被假定成一个存储起来且可供重用的对象。
现在,让我们来创建一个。我们可以使用 ConnectionMultiplexer.Connect 或者 ConnectionMultiplexer.ConnectAsync 并且传递一个配置字符串或者 ConfigurationOptions 对象来完成创建。配置字符串可以被逗号分隔成一系列的节点形式,让我们在本地机器上使用默认端口 6379 来连接到一个实例。

using StackExchange.Redis;
...
ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
// ^^^ 存储并重用该对象

注意:ConnectionMultiplexer 实现了 IDisposable 接口,当不在需要的时候,我们可以释放它。但是,我故意不显示的使用 using 语句。由于该对象是一个很耗费资源的对象,因此最好是重用该对象。

一个更复杂的场景可能涉及到主/从服务的设定。对于这种用法,只需要简单的设定一个连接字符串,该字符串包含主从服务器。(它能够自动的识别出主服务器)

ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("server1:6379,server2:6379");

如果发现两个节点都是主节点(主服务器),它能够通过打破平衡(权衡决策)指定那个是主服务器,从而解决这个问题。但是这种情况是非常罕见的。

如果你有了一个 ConnectionMultiplexer 对象,那么有3个事情是你可能想要做的:

  • 访问redis数据库(注意:在集群情况下,一个单一的逻辑数据库可能分布在多个节点当中)
  • 使用redis的发布/订阅功能
  • 以维护和监控为目的,访问一个独立的服务器

使用redis数据库

访问redis数据库就是这样简单:

IDatabase db = redis.GetDatabase();

GetDatabase 方法返回的对象是一个廉价的直通对象,并不需要存储。注意redis支持多数据库(尽管这不是支持集群);在调用 GetDatabase 时可以任意的指定调用的是那个数据库。还有,如果你计划使用异步API,那你需要为 Task.AsyncState 指定一个值,也可以这样指定:

int databaseNumber = ...
object asyncState = ...
IDatabase db = redis.GetDatabase(databaseNumber, asyncState);

一旦你拥有 IDatabase 对象,那么我们就可以简单的调用Redis API。注意所有的方法都有同步和异步实现。这符合微软的命名规范,异步方法全部以 Async结尾,并且全部都是可等待的。

最简单的操作是存储并且取回一个值:

string value = "abcdefg";
db.StringSet("mykey", value);
...
string value = db.StringGet("mykey");
Console.WriteLine(value); // writes: "abcdefg"

注意:String前缀表示的是Redis的String类型,并且它与.Net的Sting类型在很大程度上是不同的。尽管这两者都能存储文本数据。
然而,redis允许Key和Value都为原生的字节数据。示例如下:

byte[] key = ..., value = ...;
db.StringSet(key, value);
...
byte[] value = db.StringGet(key);

Redis数据库命令所覆盖的Redis数据类型都是可用的。

使用Redis发布/订阅功能

Redis另一个常用的功能是作为发布/订阅消息的分发工具;这也是很简单的,
在连接失败时,ConnectionMultiplexer 将会处理所有的重订阅细节。

ISubscriber sub = redis.GetSubscriber();

GetSubscriber 返回了一个不需要存储的廉价对象。 发布/订阅API没有数据库的概念,但正如之前所提到的,我们可以提供一个异步状态(async-state)。注意:所有的订阅都是全局的。它们不局限于 ISubscriber 的生命周期。发布订阅功能在Redis中叫做通道”channels”;通道不需要预先定义在服务器上(一个令人关注的使用是每个用户的通知通道,例如:Stack Overflow 实时驱动更新部分)。这在.NET中是很常见的,订阅采用匿名函数回调的方式来处理发布消息:

sub.Subscribe("messages", (channel, message) => {Console.WriteLine((string)message);
});

你可以单独的发布一个消息到通道中:

sub.Publish("messages", "hello");

这会将”hello”(实时的)发布到订阅了该消息的控制台中。正如前面所提到的,通道名称和消息都可以使用字节类型。

在顺序性和消息并发处理方面,请参考发布/订阅 消息顺序

访问独立的服务器

出于维护为目的,有时候需要发出特定于某个服务器的命令:

IServer server = redis.GetServer("localhost", 6379);

GetServer 方法将会接受一个 EndPoint 对象或服务器端有唯一标识的键值对对象。和之前一样,GetServer 方法返回一个不需要存储的廉价对象。并且异步状态(async-state)是可被选择指定的。注意:可用的终结点的集合也是可用的:

EndPoint[] endpoints = redis.GetEndPoints();

来自 IServer 的服务器端命令都是可用的;例如:

DateTime lastSave = server.LastSave();
ClientInfo[] clients = server.ClientList();

同步 VS 异步 VS 即发即弃

在StackExchange.Redis中,有3个主要的使用机制:

  • 同步 - 在操作完成之前方法会返回给调用者(注意:尽管这可能会阻塞调用者,但是决不会阻塞其他线程;StackExchange.Redis的关键理念就是它积极共享并发调用方之间的连接)

  • 异步 - 操作将在未来的某个时间完成,并且以 Task 或者 Task\

string value = "abcdefg";
await db.StringSetAsync("mykey", value);
...
string value = await db.StringGetAsync("mykey");
Console.WriteLine(value); // writes: "abcdefg"

在所有的方法中,使用即发即弃访问是通过可选参数 CommandFlags flags (默认是传入该参数)来实现的。这样使用时,方法会立即返回默认值(因此通常返回一个字符串的方法会一直返回 null,而返回一个 Int64 方法会一直返回0)。该操作将会在后台继续执行。一个典型的用例是页面点击率统计:

db.StringIncrement(pageKey, flags: CommandFlags.FireAndForget);

StackExchange.Redis官方文档(一)【基本用法】相关推荐

  1. StackExchange.Redis 官方文档(五) Keys, Values and Channels

    StackExchange.Redis 官方文档(五) Keys, Values and Channels 原文:StackExchange.Redis 官方文档(五) Keys, Values an ...

  2. StackExchange.Redis官方文档(四)【键、值以及通道】

    键.值以及通道 在对待Redis时候,键和其他的事物之间有个相当重要的区别.键是在数据库中一段数据的唯一标识(可能String,List,Hash或者其他的Redis数据类型).键是没有任何实质意义, ...

  3. StackExchange.Redis 官方文档(二) Configuration

    配置 有多种方式可以配置redis,StackExchange.Redis提供了一个丰富的配置模型,在执行Connect (or ConnectAsync) 时被调用: var conn = Conn ...

  4. StackExchange.Redis 官方文档(六) PipelinesMultiplexers

    流水线和复用 糟糕的时间浪费.现代的计算机以惊人的速度产生大量的数据,而且高速网络通道(通常在重要的服务器之间同时存在多个链路)提供了很高的带宽,但是计算机花费了大量的时间在 等待数据 上面,这也是造 ...

  5. 《Redis官方文档》用Redis构建分布式锁

    <Redis官方文档>用Redis构建分布式锁 用Redis构建分布式锁 在不同进程需要互斥地访问共享资源时,分布式锁是一种非常有用的技术手段. 有很多三方库和文章描述如何用Redis实现 ...

  6. Redis官方文档(入门必备)

    函数大全 中文文档 官方文档

  7. 《Redis官方文档》Data types—数据类型

    String类型(字符串类型) String 是Redis中最基本的类型.Redis中的String 类型是二进制安全的,也就是说在Redis中String类型可以包含各种数据,比如一张JPEG图片或 ...

  8. 《Redis官方文档》Redis调试指南

    原文链接      译者:Adeline Redis开发过程中十分注重其稳定性:我们尽一切努力来保证每一个版本的稳定,不出现突然崩溃等情况.但是即使在我们百分百的努力下,仍然没办法保证百分百的无bug ...

  9. Redis 官方文档阅读之 High Availability

    文章目录 Distributed nature of Sentinel(sentinel的分布式特性) Quick Start Obtaining Sentinel(获取哨兵) Running Sen ...

最新文章

  1. 浙江发布数字化改革标准化体系建设方案,将于2025年底建成
  2. 【caffe-MATLAB】自己编译faster-rcnn的MATLAB版本
  3. 史上最简单MySQL教程详解(进阶篇)之索引及失效场合总结
  4. 研华数据采集卡如何采集压力信号转化为数字信号_我所了解的数据-数据分析-数据产品...
  5. php语法中变量如何定义和使用,PHP语法—PHP的变量
  6. 12.1 LNMP架构介绍 12.2 MySQL安装 12.3/12.4 PHP安装 12.5 Ng
  7. 一个普通摄像头就能让二次元老婆“活”过来,网友:求收费
  8. PetShop 4.0学习笔记:消息队列MSMQ
  9. 一个码砖的码农,在CSDN写一年博客,出书了?
  10. DVWA教程详细的DVWA-CSRF全等级通关教程
  11. Supporting hyperplane
  12. 图片格式tif转换jpg
  13. python bytes
  14. UnicodeTOGB,能够将Unicode串转换成GB码,方便开发。
  15. (译)计算距离、方位和更多经纬度之间的点
  16. java文件上传后台
  17. (黑龙江) --2011年度注册测绘师资格考试合格人员名单
  18. python strip什么意思_python中strip什么意思
  19. 双11大队长霜波:从手忙脚乱到胸有成竹,我们如何走过这十年?
  20. IK-analyzer添加搜狗词库

热门文章

  1. 新闻发布系统,防火墙关了吗?
  2. UltraEdit 注册机激活
  3. 使用eNSP搭建的小型校园网
  4. linux驱动器和分区的备份,使用dd命令示例
  5. net start mysql命令 显示拒绝访问
  6. 网页打印与导出word实现在A4纸上相同效果
  7. Linux实现文件定期本地备份/异地备份/删除备份的脚本
  8. java台球游戏设计原理_台球游戏的核心算法和AI(1)
  9. odb格式Linux,AD如何输出ODB++文件的格式?
  10. JavaScript中6种常见的继承方式