在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
基础介绍Pub/Sub功能(means Publish, Subscribe)即发布及订阅功能
当使用银行卡消费的时候,银行往往会通过微信、短信或邮件通知用户这笔交易的信息,这便是一种发布订阅模式,这里的发布是交易信息的发布,订阅则是各个渠道。这在实际工作中十分常用,Redis 支持这样的一个模式。 发布订阅模式首先需要消息源,也就是要有消息发布出来,比如例子中的银行通知。首先是银行的记账系统,收到了交易的命令,成功记账后,它就会把消息发送出来,这个时候,订阅者就可以收到这个消息进行处理了,观察者模式就是这个模式的典型应用了。 终端实现订阅,频道为'chat'
代码实现subscribe.php
<?php ini_set('default_socket_timeout', -1); //php配置设置不超时 $redis = new Redis(); $redis->connect("127.0.0.1",6379); //$redis->setOption(Redis::OPT_READ_TIMEOUT, -1); //redis方式设置不超时,推荐 $redis->subscribe(['chan'],'callback'); //callback为回调函数名称 //$redis->subscribe(['chan'],array(new TestCall(),'callback') ); //如果回调函数是类中的方法名,这样写 // 回调函数,这里写处理逻辑 function callback($instance, $channelName, $message) { echo $channelName, "==>", $message, PHP_EOL; //$instance,即为上面创建的redis实例对象,在回调函数中,默认的这个参数就是,因此不需专门传参。 这里除了SUBSCRIBE、PSUBSCRIBE、UNSUBSCRIBE、PUNSUBSCRIBE这4条命令之外其它命令都不能使用 //如果要使用redis中的其他命令,这样实现 $newredis = new Redis(); $newredis->connect("127.0.0.1", 6379); echo $newredis->get('test') . PHP_EOL; $newredis->close(); //可以根据$channelName, $message,处理不同的业务逻辑 switch($chan) { case 'chan-1': ... break; case 'chan-2': ... break; } switch($message) { case 'msg1': ... break; case 'msg2': ... break; } }
publish.php <?php $redis = new Redis(); $redis->connect("127.0.0.1",6379); $redis->publish('chan','this is a message');
代码介绍
方法1:ini_set('default_socket_timeout', -1);方法2: $redis->setOption(Redis::OPT_READ_TIMEOUT, -1); 如果不设置不超时,60s后会报一个错误
方式一的实现,是通过临时修改ini的配置值,default_socket_timeout默认为60s,default_socket_timeout是socket流的超时参数,即socket流从建立到传输再到关闭整个过程必须要在这个参数设置的时间以内完成,如果不能完成,那么PHP将自动结束这个socket并返回一个警告。 方式二是通过修改redis的配置项,因此仅对redis连接生效,相对于方式1,不会产生意外的对其他方法的影响。 批量订阅redis的psubscribe支持通过模式匹配的方式实现批量订阅,订阅方式 回调函数写函数名或者redis->psubscribe(['my*'],array(new TestCall(),'psubscribe')); //回调函数为类中的方法,类名写你自己定义的类 subscribe.php <?php //ini_set('default_socket_timeout', -1); //不超时 $redis = new Redis(); $redis->connect("127.0.0.1",6379); $redis->setOption(Redis::OPT_READ_TIMEOUT, -1); //匹配方式1:发布可用$redis->publish('mymest','this is a message'); //$redis->psubscribe(['my*'],'psubscribe'); //匹配方式2:发布可用$redis->publish('mydest','this is a message'); //$redis->psubscribe(['my?est'],'psubscribe'); //匹配方式3:发布可用$redis->publish('myaest','this is a message');或$redis->publish('myeest','this is a message'); $redis->psubscribe(['my[ae]est'],'psubscribe'); function psubscribe($redis, $pattern, $chan, $msg) { echo "Pattern: $pattern\n"; echo "Channel: $chan\n"; echo "Payload: $msg\n"; }
模式匹配规则 支持以下几种,以hello举例: h?llo subscribes to hello, hallo and hxllo pubsub方法介绍public function pubsub( argument ) pubsub获取pub/sub系统的信息,$keyword可用为"channels", "numsub", 或者"numpat",三种,传入不同的keyword返回的数据不同 * $redis->pubsub('channels'); // All channels 获取所有的频道,返回数组 * $redis->pubsub('channels', '*pattern*'); // Just channels matching your pattern,返回符合匹配模式的频道 * $redis->pubsub('numsub', array('chan1', 'chan2')); // Get subscriber counts for 'chan1' and 'chan2' //返回每个订阅频道的数量,返回数组 * $redis->pubsub('numpat'); // Get the number of pattern subscribers 获取模式匹配方式的订阅
转载至:https://zhuanlan.zhihu.com/p/155667437 |
2022-08-30
2022-08-17
2022-11-06
2022-08-17
2022-08-15
请发表评论