Redis 发布订阅

Redis发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。

操作方法

方法名称参数说明备注
pSubscribe$callback, $pattern, …$patterns订阅一个或多个符合给定模式的频道。$callback是回调函数
pubSub$subCommand, …$arguments查看订阅与发布系统状态。
publish$channel, $message将信息发送到指定的频道。
pUnSubscribe$pattern, …$patterns退订所有给定模式的频道。
subscribe$callback, $channel, …$channels订阅给定的一个或多个频道的信息。
unsubscribe$channel, …$channels指退订给定的频道。
setSubscribeStopbool $subscribeStop设置是否退出订阅当你回调函数想退出时,调用这个命令
isSubscribeStop查看当前订阅状态

基本使用

  2. defined("REDIS_HOST") ?: define('REDIS_HOST', '127.0.0.1');
  3. defined("REDIS_PORT") ?: define('REDIS_PORT', 6379);
  4. defined("REDIS_AUTH") ?: define('REDIS_AUTH', 'easyswoole');
  5. go(function () {
  6.     $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  7.         'host'      => '127.0.0.1',
  8.         'port'      => '6379',
  9.         'auth'      => 'easyswoole',
  10.         'serialize' => \EasySwoole\Redis\Config\RedisConfig::SERIALIZE_NONE
  11.     ]));;
  13.     //新开协程进行订阅
  14.     go(function () {
  15.         $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  16.             'host' => REDIS_HOST,
  17.             'port' => REDIS_PORT,
  18.             'auth' => REDIS_AUTH
  19.         ]));
  20.         $redis->pSubscribe(function (\EasySwoole\Redis\Redis $redis, $pattern, $str) {
  21.             var_dump($pattern,$str);
  22.             $data = $redis->unsubscribe('test');
  23.             var_dump($data);
  24.             $redis->setSubscribeStop(true);
  25.         }, 'test', 'test1', 'test2');
  26.     });
  28.     //新开协程进行订阅
  29.     go(function () {
  30.         $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  31.             'host' => REDIS_HOST,
  32.             'port' => REDIS_PORT,
  33.             'auth' => REDIS_AUTH
  34.         ]));
  35.         $redis->subscribe(function (\EasySwoole\Redis\Redis $redis, $pattern, $str) {
  36.             var_dump($pattern,$str);
  37.             $data = $redis->unsubscribe('test');
  38.             var_dump($data);
  39.             $redis->setSubscribeStop(true);
  40.         }, 'test', 'test1', 'test2');
  41.     });
  43.     $data = $redis->pubSub('CHANNELS');
  44.     var_dump($data);
  45.     \Swoole\Coroutine::sleep(1);
  47.     $data = $redis->publish('test2', 'test');
  48.     var_dump($data);
  50.     $data = $redis->pUnSubscribe('test');
  51.     var_dump($data);
  53. });