PubSub如何在BookSleeveRedis中工作？

PubSub如何在BookSleeve / Redis中工作？

1：您的示例（

Test

）中只有一个频道；通道只是用于特定发布/订阅交换的名称。但是，由于redis API的工作原理的特殊性，有必要使用2个 连接
。具有 任何 订阅的连接不能执行任何其他 *** 作，除了：

• 听消息
• 管理自己的订阅（

  subscribe

  ，

  psubscribe

  ，

  unsubscribe

  ，

  punsubscribe

  ）

但是，我不明白这一点：

private static Dictionary<string, RedisSubscriberConnection>

除非您要满足自己的特定需求，否则您不需要多个订阅者连接。单个订阅者连接可以处理任意数量的订阅。快速检查一下

clientlist

我的一台服务器，并且与（在撰写本文时）23,002个订阅建立了一个连接。可能可以减少，但是：它起作用。

2：模式订阅支持通配符；因此

/topic/1

，

/topic/2/

您可以订阅而不是订阅等等

/topic/*

。所使用的 实际
通道的名称

publish

作为回调签名的一部分提供给接收者。

都可以。应该注意的是，的性能

publish

受唯一订阅总数的影响-
但坦率地说，即使您有成千上万个使用

subscribe

而不是订阅的频道，它的速度仍然非常快（如：0ms）

psubscribe

。

但是从

publish

时间复杂度：O（N + M），其中N是订阅接收通道的客户端数，M是订阅模式（任何客户端）的总数。

我建议阅读pub / sub的redis文档。

---

编辑以下问题：

a）如果我想保证在接收项目时保留从同一发布者发送项目的顺序，我必须同步（使用Result或Wait（））进行发布，对吗？

根本没有任何区别；因为您提到了

Result

/

Wait()

，所以我假设您正在谈论BookSleeve-
在这种情况下，多路复用器已经保留了命令顺序。Redis本身是单线程的，并且将始终按顺序在单个连接上处理命令。但是：订阅服务器上的回调可以异步执行，并且可以（单独）传递给工作线程。我目前正在调查是否可以强制从强制进行此 *** 作

RedisSubscriberConnection

。

更新：从1.3.22开始，您可以将设置

CompletionMode

为

PreserveOrder

-，那么所有回调将依次而不是同时完成。

b）根据您的建议进行调整后，无论有效载荷的大小如何，发布少量项目时我的表现都很好。但是，当同一发布者发送100,000个或更多项目时，性能会迅速下降（仅从我的机器发送时会下降到7-8秒）。

首先，这段时间听起来很高-
在本地测试我得到的（对于100,000个出版物，包括等待所有出版物的响应）是1766ms（本地）或1219ms（远程）（听起来可能违反直觉，但是我的“本地”是）
t运行相同版本的redis；在Centos上，我的“远程”是2.6.12；在Windows上，我的“本地”是2.6.8-pre2。

我不能让实际的服务器建立网络更快或速度，而是：如果这是数据包碎片，我已经添加（只为你）一

SuspendFlush()

/

ResumeFlush()

对。这将禁用快速刷新（即，当发送队列为空时；仍会发生其他类型的刷新）；您可能会发现这有帮助：

conn.SuspendFlush();try {    // start lots of operations...} finally {    conn.ResumeFlush();}

请注意，

Wait

直到恢复后才应该这样做，因为在调用之前

ResumeFlush()

，可能还有一些 *** 作仍在发送缓冲区中。有了这些，我得到了（100,000次 *** 作）：

local: 1766ms (eager-flush) vs 1554ms (suspend-flush)remote: 1219ms (eager-flush) vs 796ms (suspend-flush)

如您所见，它可以为远程服务器提供更多帮助，因为它将通过网络放置更少的数据包。

我无法使用事务，因为稍后要发布的项目无法一次全部使用。有没有一种方法可以在记住这些知识的情况下进行优化？

我 认为 以上已解决了这一问题-但请注意，最近

CreateBatch

也添加了它。批处理的 *** 作很像交易-
只是：没有交易。同样，这是减少数据包碎片的另一种机制。在您的特定情况下，我怀疑暂停/恢复（同花）是您最好的选择。

您是否建议使用一个常规的RedisConnection和一个RedisSubscriberConnection或任何其他配置来使此类包装器执行所需的功能？

只要你不执行阻塞 *** 作（

blpop

，

brpop

，

brpoplpush

等），或将过大的BLOB沿着电线（潜在延迟等 *** 作，同时它清除），那么每个类型的单个连接通常工作得很好。但是YMMV取决于您的确切使用要求。