# 订阅模式 [TOC] 本文档适用于4.2.13及以上版本，**4.2.12及以下版本订阅模式存在BUG** ## 订阅 与phpredis不同，subscribe/psubscribe为协程风格。 ~~~ $redis = new Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379); if ($redis->subscribe(['channel1', 'channel2', 'channel3'])) // 或者使用psubscribe { while ($msg = $redis->recv()) { // msg是一个数组, 包含以下信息 // $type # 返回值的类型：显示订阅成功 // $name # 订阅的频道名字 或 来源频道名字 // $info # 目前已订阅的频道数量 或 信息内容 list($type, $name, $info) = $msg; if ($type == 'subscribe') // 或psubscribe { // 频道订阅成功消息，订阅几个频道就有几条 } else if ($type == 'unsubscribe' && $info == 0) // 或punsubscribe { break; // 收到取消订阅消息，并且剩余订阅的频道数为0，不再接收，结束循环 } else if ($type == 'message') // 若为psubscribe，此处为pmessage { // 打印来源频道名字 var_dump($name); // 打印消息 var_dump($info); // 处理消息 // balabalaba.... if ($need_unsubscribe) // 某个情况下需要退订 { $redis->unsubscribe(); // 继续recv等待退订完成 } } } } ~~~ ## 退订 退订使用unsubscribe/punsubscribe，`$redis->unsubscribe(['channel1'])` 此时`$redis->recv()`将会接收到一条取消订阅消息，若取消订阅多个频道，则会收到多条。 **注意：退订后务必继续recv()到收到最后一条取消订阅消息（$msg\[2\] == 0），收到此条消息后，才会退出订阅模式** ## En ~~~ $redis = new Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379); if ($redis->subscribe(['channel1', 'channel2', 'channel3'])) // or use psubscribe { while ($msg = $redis->recv()) { // msg is an array containing the following information // $type # return type: show subscription success // $name # subscribed channel name or source channel name // $info # the number of channels or information content currently subscribed list($type, $name, $info) = $msg; if ($type == 'subscribe') // or psubscribe { // channel subscription success message } else if ($type == 'unsubscribe' && $info == 0) // or punsubscribe { break; // received the unsubscribe message, and the number of channels remaining for the subscription is 0, no longer received, break the loop } else if ($type == 'message') // if it's psubscribe，here is pmessage { // print source channel name var_dump($name); // print message var_dump($info); // handle messsage if ($need_unsubscribe) // in some cases, you need to unsubscribe { $redis->unsubscribe(); // continue recv to wait unsubscribe finished } } } } ~~~