1.概念 名称及含义 channel 频道:生产者和消费者直接操作的对象 publish 生产者:向channel发送消息 subscribe 消费者:订阅一个或多个channel psubscribe 消费者:匹配订阅一个或多个channel punsubscribe 退订:匹配退订,无参数则退订全部channel unsubscribe 退订:退订指定的channel,无参数则退订全部channel pubsub 列出当前活动channel(至少有一个订阅)
2.注意事项 1)生产者publish消息时打开一个连接,publish后连接可以立即关闭 2)channel只接收publish发送的消息,自身不存储消息,如果channel没有被订阅,则消息丢弃 3)订阅的消费者需要一直在线,阻塞获取消息,连接断开表示立即退订
3.redis可以实现发布订阅和消息队列的功能,两者的区别在于: 1)redis的订阅者可以是多个,且可以同时处理发布上来的消息,如果订阅者不在线(服务没有启动)消息将丢失,消息没有持久化。发布和订阅是一块执行的,缺少一个直接忽略这个消息 2)消息队列只能有一个客户端来处理,处理完之后消息就被标记或删除,即使服务端没有启动消息也不会丢失 3)两者的使用场景要根据业务数据的准确度,敏感性决定,比如日志就可以用redis发布订阅来实现,丢失一点也没有关系
4.直接使用php-redis扩展提供的方法实现发布订阅 1)消费者订阅Subscribe.php <?php //设置php脚本执行时间 set_time_limit(0); //设置socket连接超时时间 ini_set('default_socket_timeout', -1); //声明测试频道名称 $channelName = "testPubSub"; $channelName2 = "testPubSub2"; try { $redis = new Redis(); //建立一个长链接 $redis->pconnect('ip', 6379); //阻塞获取消息 $redis->subscribe(array($channelName, $channelName2), function ($redis, $chan, $msg) { echo "channel:".$chan.",message:".$msg."\n"; }); } catch (Exception $e) { echo $e->getMessage(); }
2)生产者发送消息Publish.php <?php $channelName = "testPubSub"; $channelName2 = "testPubSub2"; //向指定频道发送消息 try { $redis = new Redis(); $redis->connect('192.168.75.132', 6379); for ($i=0;$i<5;$i++) { $data = array('key' => 'key'.$i, 'data' => 'testdata'); $ret = $redis->publish($channelName, json_encode($data)); print_r($ret); } } catch (Exception $e) { echo $e->getMessage(); }
3)执行消费者订阅,开始阻塞获取消息php Subscribe.php
4)执行生产者,开始发送消息php Publish.php
php .\Publish.php 22222 #返回执行结果:频道的订阅数量 查看消费者终端
php .\Subscribe.php channel:testPubSub,message:{"key":"key0","data":"testdata"} channel:testPubSub,message:{"key":"key1","data":"testdata"} channel:testPubSub,message:{"key":"key2","data":"testdata"} channel:testPubSub,message:{"key":"key3","data":"testdata"} channel:testPubSub,message:{"key":"key4","data":"testdata"}
转自:https://www.jmsite.cn/blog-586.html
|
请发表评论