Redis：发布/订阅（pub/sub） - 版本历史

Eijux：Eijux移动页面Redis：发布/订阅至Redis：发布/订阅（pub/sub），不留重定向

2021-11-02T17:10:14Z

Eijux移动页面Redis：发布/订阅至Redis：发布/订阅（pub/sub），不留重定向

←上一版本	2021年11月3日 (三) 01:10的版本
（没有差异）

Eijux：/* PUBSUB */

2021-11-02T17:06:29Z

PUBSUB

←上一版本		2021年11月3日 (三) 01:06的版本
第114行：		第114行：
	# 返回值：一个整数回复（Integer reply）。		# 返回值：一个整数回复（Integer reply）。
	</syntaxhighlight>		</syntaxhighlight>
	#* ~~这个命令返回的不是订阅模式的客户端的数量，而是“所有客户端订阅的模式的数量总和”。~~		#* 这个命令返回的不是订阅模式的客户端的数量，而是“所有客户端订阅的模式的数量总和”（多个客户端订阅相同的模式时，会被重复计算）。
	~~#* 当有多个客户端订阅相同的模式时，相同的订阅会被重复计算。~~
	#: 示例：		#: 示例：
	#: <syntaxhighlight lang="bash" highlight="">		#: <syntaxhighlight lang="bash" highlight="">

Eijux：/* PUBSUB */

2021-11-02T17:03:55Z

PUBSUB

@@ 第58行： / 第58行： @@
 === PUBSUB ===
 PUBSUB 有多个可用的子命令：
 # 列出当前的活跃频道：
+# 再使用 client-3 打印当前订阅模式的数量：
+redis> PUBSUB NUMPAT
+(integer) 4
+</syntaxhighlight>
 == 频道和模式 ==

Eijux：/* 发布和订阅 */

2021-11-02T16:38:26Z

发布和订阅

←上一版本		2021年11月3日 (三) 00:38的版本
第25行：		第25行：
	# 消息服务（broker）		# 消息服务（broker）

	== ~~发布和订阅~~ ==		== Pub/Sub 命令 ==
	正在订阅频道的客户端不应该发送除下述之外的其他命令：		正在订阅频道的客户端不应该发送除下述之外的其他命令：
	{\| class="wikitable"		{\| class="wikitable"
第33行：		第33行：
	\| rowspan="2" \| 订阅频道		\| rowspan="2" \| 订阅频道
	\| SUBSCRIBE <channel> [<channel> ...] \|\| '''订阅'''给定的一个或多个频道的信息。		\| SUBSCRIBE <channel> [<channel> ...] \|\| '''订阅'''给定的一个或多个频道的信息。
			* 返回值：“信息”（参见下节“信息的格式”）；
	\|-		\|-
	\| UNSUBSCRIBE [<channel> [<channel> ...]] \|\| '''退订'''给定的频道。		\| UNSUBSCRIBE [<channel> [<channel> ...]] \|\| '''退订'''给定的频道。
			* 返回值在不同的客户端中有不同的表现；
	\|-		\|-
	\| rowspan="2" \| 订阅模式		\| rowspan="2" \| 订阅模式
	\| PSUBSCRIBE <pattern> [<pattern> ...] \|\| '''订阅'''一个或多个符合给定模式的频道。		\| PSUBSCRIBE <pattern> [<pattern> ...] \|\| '''订阅'''一个或多个符合给定模式的频道。
			* 返回值：“信息”；
	\|-		\|-
	\| PUNSUBSCRIBE [<pattern> [<pattern> ...]] \|\| '''退订'''给定模式的频道。		\| PUNSUBSCRIBE [<pattern> [<pattern> ...]] \|\| '''退订'''给定模式的频道。
			* 返回值在不同的客户端中有不同的表现；
	\|-		\|-
	\| 发布		\| 发布
	\| PUBLISH <channel> <message> \|\| 将信息'''发布'''到指定的频道。		\| PUBLISH <channel> <message> \|\| 将信息'''发布'''到指定的频道。
			* 返回值：接收到信息 <message> 的订阅者数量。
	\|-		\|-
	\| 状态		\| 系统状态
	\| PUBSUB <subcommand> [<argument> [<argument> ...]] \|\| ~~查看订阅与发布系统状态。~~		\| PUBSUB <subcommand> [<argument> [<argument> ...]] \|\| 它是一个查看订阅与发布系统状态的内省命令，由数个不同格式的子命令组成。
	\|}		\|}
	* 客户端订阅的模式里面可以包含多个 glob 风格的通配符，比如： '''*''' 、 '''?''' 和 '''[...]'''，等等。		* 客户端订阅的模式里面可以包含多个 glob 风格的通配符，比如： '''*''' 、 '''?''' 和 '''[...]'''，等等。
第51行：		第56行：
	** 当客户端退订所有频道和模式，也即是这个总数值下降为 0 的时候，客户端将退出订阅与发布状态。		** 当客户端退订所有频道和模式，也即是这个总数值下降为 0 的时候，客户端将退出订阅与发布状态。

			=== PUBSUB ===
			PUBSUB 有多个可用的子命令：
			# 列出当前的活跃频道：

















			== 频道和模式 ==
	=== 订阅频道 ===		=== 订阅频道 ===
	<syntaxhighlight lang="java" highlight="">		<syntaxhighlight lang="java" highlight="">

Eijux：/* 发布和订阅 */

2021-11-02T16:18:25Z

发布和订阅

←上一版本		2021年11月3日 (三) 00:18的版本
第32行：		第32行：
	\|-		\|-
	\| rowspan="2" \| 订阅频道		\| rowspan="2" \| 订阅频道
	\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。		\| SUBSCRIBE <channel> [<channel> ...] \|\| '''订阅'''给定的一个或多个频道的信息。
	\|-		\|-
	\| UNSUBSCRIBE [channel [channel ...]] \|\| '''退订'''给定的频道。		\| UNSUBSCRIBE [<channel> [<channel> ...]] \|\| '''退订'''给定的频道。
	\|-		\|-
	\| rowspan="2" \| 订阅模式		\| rowspan="2" \| 订阅模式
	\| PSUBSCRIBE pattern [pattern ...] \|\| '''~~订阅一个或多个~~'''~~符合给定模式的频道。~~		\| PSUBSCRIBE <pattern> [<pattern> ...] \|\| '''订阅'''一个或多个符合给定模式的频道。
	\|-		\|-
	\| PUNSUBSCRIBE [pattern [pattern ...]] \|\| '''~~退订所有~~'''给定模式的频道。		\| PUNSUBSCRIBE [<pattern> [<pattern> ...]] \|\| '''退订'''给定模式的频道。
	\|-		\|-
	\| 发布		\| 发布
	\|-		\| PUBLISH <channel> <message> \|\| 将信息'''发布'''到指定的频道。
	\| PUBLISH channel message \|\| 将信息'''发布'''到指定的频道。
	\|-		\|-
	\| 状态		\| 状态
	\| PUBSUB subcommand [argument [argument ...]] \|\| 查看订阅与发布系统状态。		\| PUBSUB <subcommand> [<argument> [<argument> ...]] \|\| 查看订阅与发布系统状态。
	\|}		\|}
	* 客户端订阅的模式里面可以包含多个 glob 风格的通配符，比如： '''*''' 、 '''?''' 和 '''[...]'''，等等。		* 客户端订阅的模式里面可以包含多个 glob 风格的通配符，比如： '''*''' 、 '''?''' 和 '''[...]'''，等等。

Eijux：/* 信息的格式 */

2021-11-02T16:15:16Z

信息的格式

←上一版本		2021年11月3日 (三) 00:15的版本
第84行：		第84行：

	== 信息的格式 ==		== 信息的格式 ==
			频道转发的每条信息都是一条带有三个元素的多条批量回复（multi-bulk reply）。

			信息类型：（信息的第一个元素）
			# “'''subscribe'''”：表示当前客户端成功地订阅了（信息第二个元素所指示的）频道。
			#: 第二个元素：订阅的频道；
			#: 第三个元素：客户端目前已订阅的频道数量。
			# “'''unsubscribe'''”：表示当前客户端成功地退订了（信息第二个元素所指示的）频道。
			#: 第二个元素：退订的频道；
			#: 第三个元素：客户端目前仍在订阅的频道数量。
			#* 当客户端订阅的频道数量降为 0 时，客户端不再订阅任何频道，它可以像往常一样，执行任何 Redis 命令。
			# “'''message'''”：表示这条信息是由某个客户端执行 PUBLISH 命令所发送的，真正的信息。
			#: 第二个元素：信息来源的频道；
			#: 第三个元素：信息的内容。
			# “'''pmessage '''”：表示有某个客户端通过 PUBLISH 向某个频道发送了信息，而这个频道刚好匹配了当前客户端所订阅的某个模式。
			#: 第二个元素：被匹配的模式；
			#: 第三个元素：被匹配的频道的名字；
			#: 最后一个元素：信息的实际内容。


			示例：
			# subscribe 类型的信息：
			#: <syntaxhighlight lang="bash" highlight="">
			redis> SUBSCRIBE first second
			1) "subscribe"
			2) "first"
			3) (integer) 1

			1) "subscribe"
			2) "second"
			3) (integer) 2
			</syntaxhighlight>
			# message 类型的信息：
			#: 客户端B订阅频道、客户端A项频道发送数据后，客户端B所接受到信息
			#: <syntaxhighlight lang="bash" highlight="">
			redis> SUBSCRIBE hello
			1) "subscribe"
			2) "hello"
			3) (integer) 1
			1) "message"
			2) "second"
			3) "hello"
			</syntaxhighlight>
			# unsubscribe 类型的信息：
			#: <syntaxhighlight lang="bash" highlight="">
			redis> UNSUBSCRIBE
			1) "unsubscribe"
			2) "second"
			3) (integer) 1

			1) "unsubscribe"
			2) "first"
			3) (integer) 0
			</syntaxhighlight>

	== FAQ ==		== FAQ ==

Eijux：/* 通过频道和模式接收同一条信息 */

2021-11-02T15:52:46Z

通过频道和模式接收同一条信息

←上一版本		2021年11月2日 (二) 23:52的版本
第97行：		第97行：
	示例：		示例：
	: 如果客户端执行了以下命令：		: 如果客户端执行了以下命令：
	: <syntaxhighlight lang="~~cmd~~" highlight="">		: <syntaxhighlight lang="bash" highlight="">
	SUBSCRIBE foo		SUBSCRIBE foo
	PSUBSCRIBE f*		PSUBSCRIBE f*
	</syntaxhighlight>		</syntaxhighlight>
	: 当有信息发送到频道 foo 时，客户端将收到两条信息：一条来自频道 foo，信息类型为 message；另一条来自模式 f*，信息类型为 pmessage 。		: 当有信息发送到频道 foo 时，客户端将收到两条信息：一条来自频道 foo，信息类型为 message；另一条来自模式 f*，信息类型为 pmessage 。

2021年11月2日 (二) 15:49 Eijux

2021-11-02T15:49:43Z

←上一版本		2021年11月2日 (二) 23:49的版本
第3行：		第3行：
	__TOC__		__TOC__

	== ~~什么是发布订阅？~~ ==		== 关于 ==
	~~Redis 发布订阅(pub~~/~~sub)是一种消息通信模式：发送者（publish）发送消息，订阅者（subscribe）接收消息。~~		SUBSCRIBE 、 UNSUBSCRIBE 和 PUBLISH 三个命令实现了发布与订阅信息泛型（Publish/Subscribe messaging paradigm），在这个实现中：
	* 发布订阅也叫“'''生产者消费者'''”模式，是实现“'''消息队列'''~~”的一种方式；~~		1、发送者（发送信息的客户端）不是将信息直接发送给特定的接收者（接收信息的客户端），而是将信息发送给频道（channel），然后由频道将信息转发给所有对这个频道感兴趣的订阅者。
			2、发送者无须知道任何关于订阅者的信息，而订阅者也无须知道是那个客户端给它发送信息，它只要关注自己感兴趣的频道即可。

			对发布者和订阅者进行解构（decoupling），可以极大地提高系统的扩展性（scalability），并得到一个更动态的网络拓扑（network topology）。

			发布订阅（pub/sub）是一种消息通信模式：发送者（publish）发送消息，订阅者（subscribe）接收消息。
			:[[File:redis发布.png\|left\|thumb\|200px\|发布]] [[File:reids订阅.png\|none\|thumb\|300px\|订阅]]


			=== “发布订阅”与“消息队列” ===
			发布订阅也叫“'''生产者消费者'''”模式，是实现“'''消息队列'''”的一种方式。基于消息队列，可以实现系统解耦、削峰填谷，顶住流量洪峰。
			* redis 的主业目前是基于键值对的数据存储、缓存等，消息队列可能是 redis 的一种尝试；
			* 常用的流行的消息队列有：“'''ActiveMQ'''”、“'''RabbitMQ'''”等；


第13行：		第25行：
	# 消息服务（broker）		# 消息服务（broker）

			== 发布和订阅 ==
	~~发布：~~		正在订阅频道的客户端不应该发送除下述之外的其他命令：
	~~:[[File:redis发布.png\|200px]]~~
	~~订阅：~~
	~~:[[File:reids订阅.png\|200px]]~~

	== ~~Redis发布和订阅~~ ==
	~~发布订阅是'''消息队列'''的一种方式，基于消息队列的方式，可以实现系统解耦、削峰填谷，顶住流量洪峰；~~
	* redis 的主业目前是基于键值对的数据存储、缓存等，消息队列可能是 redis 的一种尝试；
	* 常用的流行的消息队列有：“'''ActiveMQ'''”、“'''RabbitMQ'''”等；

	~~=== 常用命令 ===~~
	{\| class="wikitable"		{\| class="wikitable"
	! 命令 !! 描述		\|+ Redis：发布/订阅命令
			! !! 命令 !! 描述
	\|-		\|-
			\| rowspan="2" \| 订阅频道
	\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。		\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。
	\|-		\|-
	\| UNSUBSCRIBE [channel [channel ...]] \|\| '''退订'''给定的频道。		\| UNSUBSCRIBE [channel [channel ...]] \|\| '''退订'''给定的频道。
	\|-		\|-
			\| rowspan="2" \| 订阅模式
	\| PSUBSCRIBE pattern [pattern ...] \|\| '''订阅一个或多个'''符合给定模式的频道。		\| PSUBSCRIBE pattern [pattern ...] \|\| '''订阅一个或多个'''符合给定模式的频道。
	\|-		\|-
	\| PUNSUBSCRIBE [pattern [pattern ...]] \|\| '''退订所有'''给定模式的频道。		\| PUNSUBSCRIBE [pattern [pattern ...]] \|\| '''退订所有'''给定模式的频道。
	\|-		\|-
	\| PUBLISH channel message \|\| ~~将信息发送到指定的频道。~~		\| 发布
			\|-
			\| PUBLISH channel message \|\| 将信息'''发布'''到指定的频道。
	\|-		\|-
			\| 状态
	\| PUBSUB subcommand [argument [argument ...]] \|\| 查看订阅与发布系统状态。		\| PUBSUB subcommand [argument [argument ...]] \|\| 查看订阅与发布系统状态。
	\|}		\|}
			* 客户端订阅的模式里面可以包含多个 glob 风格的通配符，比如： '''*''' 、 '''?''' 和 '''[...]'''，等等。
			* 在执行 SUBSCRIBE、UNSUBSCRIBE、PSUBSCRIBE 和 PUNSUBSCRIBE 命令时，返回结果的最后一个元素是客户端目前'''仍在订阅的频道和模式总数'''。
			** 当客户端退订所有频道和模式，也即是这个总数值下降为 0 的时候，客户端将退出订阅与发布状态。

			=== 订阅频道 ===
			<syntaxhighlight lang="java" highlight="">
			// 订阅
			subscribe <channel> [<channel> ...]

			// 发布
			publish <channel> <message>
			</syntaxhighlight>

	~~=== 模拟实现 ===~~
	（以命令行模拟实现）：		（以命令行模拟实现）：
	# 开启 4 个 redis 客户端（“./redis-cli”），如上图，3 个客户端作为消息订阅者，1 个为消息发布者：		# 开启 4 个 redis 客户端（“./redis-cli”），如上图，3 个客户端作为消息订阅者，1 个为消息发布者：
	# 让 3 个消息订阅者订阅某个频道主题：“'''<code>subscribe channelTest</code>'''”；		# 让 3 个消息订阅者订阅某个频道主题：“'''<code>subscribe channelTest</code>'''”；
	~~#: <syntaxhighlight lang="java" highlight="">~~
	~~subscribe channel [channel ...]~~
	~~</syntaxhighlight>~~
	#: [[File:redis订阅channelTest.jpg\|800px]]		#: [[File:redis订阅channelTest.jpg\|800px]]
	# ~~让1个消息发布者向频道主题上发布消息：“~~'''<code>publish channelTest message123</code>'''”；		# 让 1 个消息发布者向频道主题上发布消息：“'''<code>publish channelTest message123</code>'''”；
	~~#: <syntaxhighlight lang="java" highlight="">~~
	~~publish channel message~~
	~~</syntaxhighlight>~~
	#: [[File:redis发布消息到channelTest.jpg\|800px]]		#: [[File:redis发布消息到channelTest.jpg\|800px]]

			=== 订阅模式 ===
			<syntaxhighlight lang="java" highlight="">
			// 订阅
			psubscribe <pattern> [<pattern> ...]

			// 发布
			publish <channel> <message>
			</syntaxhighlight>

			（以命令行模拟实现）：
	~~如果是订阅匹配模式的频道主题：“~~'''<code>psubscribe chan*</code>'''”		# 订阅匹配模式的频道：“'''<code>psubscribe chan*</code>'''”
	~~# 订阅：~~
	~~#: <syntaxhighlight lang="java" highlight="">~~
	~~psubscribe pattern [pattern ...]~~
	~~</syntaxhighlight>~~
	#:[[File:redis订阅（psubscribe）.jpg\|800px]]		#:[[File:redis订阅（psubscribe）.jpg\|800px]]
	# 发布：		# 发布：
	#:[[File:redis发布（psubscribe）.jpg\|800px]]		#:[[File:redis发布（psubscribe）.jpg\|800px]]

			== 信息的格式 ==






			== FAQ ==
			=== 通过频道和模式接收同一条信息 ===
			如果客户端订阅的多个模式匹配了同一个频道，或者客户端同时订阅了某个频道、以及匹配这个频道的某个模式，那么它可能会多次接收到同一条信息。


			示例：
			: 如果客户端执行了以下命令：
			: <syntaxhighlight lang="cmd" highlight="">
			SUBSCRIBE foo
			PSUBSCRIBE f*
			</syntaxhighlight>
			: 当有信息发送到频道 foo 时，客户端将收到两条信息：一条来自频道 foo，信息类型为 message；另一条来自模式 f*，信息类型为 pmessage 。

Eijux：/* 常用命令 */

2021-10-02T16:12:38Z

常用命令

←上一版本		2021年10月3日 (日) 00:12的版本
第30行：		第30行：
	\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。		\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。
	\|-		\|-
	\| ~~PSUBSCRIBE pattern~~ [~~pattern~~ ...] \|\| '''订阅'''~~一个或多个符合给定模式的频道。~~		\| UNSUBSCRIBE [channel [channel ...]] \|\| '''退订'''给定的频道。
	\|-		\|-
	\| ~~UNSUBSCRIBE~~ [~~channel [channel~~ ...]] \|\| '''退订'''~~给定的频道。~~		\| PSUBSCRIBE pattern [pattern ...] \|\| '''订阅一个或多个'''符合给定模式的频道。
	\|-		\|-
	\| PUNSUBSCRIBE [pattern [pattern ...]] \|\| '''退订'''~~所有给定模式的频道。~~		\| PUNSUBSCRIBE [pattern [pattern ...]] \|\| '''退订所有'''给定模式的频道。
	\|-		\|-
	\| PUBLISH channel message \|\| 将信息发送到指定的频道。		\| PUBLISH channel message \|\| 将信息发送到指定的频道。

Eijux：/* 常用命令 */

2021-10-02T16:10:33Z

常用命令

←上一版本		2021年10月3日 (日) 00:10的版本
第26行：		第26行：
	=== 常用命令 ===		=== 常用命令 ===
	{\| class="wikitable"		{\| class="wikitable"
	! ~~Option Name~~ !! ~~Description !! Introduced !! Deprecated~~		! 命令 !! 描述
	\|-		\|-
	\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。		\| SUBSCRIBE channel [channel ...] \|\| '''订阅'''给定的一个或多个频道的信息。

Redis：发布/订阅（pub/sub） - 版本历史

Eijux：​Eijux移动页面Redis：发布/订阅至Redis：发布/订阅（pub/sub），不留重定向

Eijux：​/* PUBSUB */

Eijux：​/* PUBSUB */

Eijux：​/* 发布和订阅 */

Eijux：​/* 发布和订阅 */

Eijux：​/* 信息的格式 */

Eijux：​/* 通过频道和模式接收同一条信息 */

2021年11月2日 (二) 15:49 Eijux

Eijux：​/* 常用命令 */

Eijux：​/* 常用命令 */

Eijux：Eijux移动页面Redis：发布/订阅至Redis：发布/订阅（pub/sub），不留重定向

Eijux：/* PUBSUB */

Eijux：/* PUBSUB */

Eijux：/* 发布和订阅 */

Eijux：/* 发布和订阅 */

Eijux：/* 信息的格式 */

Eijux：/* 通过频道和模式接收同一条信息 */

Eijux：/* 常用命令 */

Eijux：/* 常用命令 */