Pub/Sub功能基本介绍（意思是Publish，Subscribe），即发布和订阅功能在基于事件的系统中，Pub/Sub是目前广泛使用的通信模型，它以事件作为基本的通信机制，提供大型系统所需的松耦合交互方式：一个订阅者（如客户端）以事件订阅的形式表达一个事件或它有兴趣接收的一类事件；发布者（例如服务器）可以订阅订阅者随时收到他们感兴趣的事件的通知。消息发布者，即发布客户端，不需要独占链接。您可以在发布消息的同时使用同一个redis-client链接执行其他操作（例如：INCR等）。消息订阅者，即订阅客户端，需要独享链接。即在订阅期间，redis-client不能穿插其他操作。此时客户端以阻塞的方式等待“发布端”的消息；这个很好理解，所以订阅端需要使用单独的链接，甚至在一个额外的线程中使用。使用银行卡消费时，银行往往会通过微信、短信或邮件等方式将交易信息告知用户。这是一种发布-订阅模式，发布是指交易信息的发布，订阅是指各种渠道。这在实际工作中很常见，Redis支持这种模式。发布-订阅模型首先需要一个消息源，即必须要有一个消息要发布，比如例子中的银行通知。首先是银行的簿记系统。收到交易订单并记账成功后，发送消息。这时候订阅者就可以接收到消息并进行处理了。观察者模式就是这种模式的典型模型。应用。终端实现订阅，频道为‘chat’发布消息。代码实现subscribe.phpconnect("127.0.0.1",6379);//$redis->setOption(Redis::OPT_READ_TIMEOUT,-1);//redis模式不设置超时，推荐$redis->subscribe(['chan'],'callback');//callback是回调函数的名称//$redis->subscribe(['chan'],array(newTestCall(),'callback'));//如果回调函数是类中的方法名，就这样写//回调函数，这里写处理逻辑functioncallback($instance,$channelName,$message){echo$channelName,"==>",$消息,PHP_EOL;//$instance，就是上面创建的redis实例对象，在回调函数中，默认参数为，所以不需要具体传参。除了SUBSCRIBE,PSUBSCRIBE,UNSUBSCRIBE,PUNSUBSCRIBE这4个命令，这里不能使用其他命令$newredis->connect("127.0.0.1",6379);回显$newredis->get('test')。PHP_EOL;$newredis->close();//可以根据$channelName处理不同的业务逻辑，$messageswitch($chan){case'chan-1':...break;case'chan-2':...中断；}switch($message){case'msg1':...break;case'msg2':...中断；}}publish.phpconnect("127.0.0.1",6379);$redis->publish('chan','这是一条消息');代码在subscribe.php中引入不设置超时的方法一：ini_set('default_socket_timeout',-1);方法二：$redis->setOpt离子（Redis::OPT_READ_TIMEOUT，-1）；如果不设置超时时间，60s后会报错。PHPFatalerror:UncaughtRedisException:readerroronconnectionto127.0.0.1:6379insubscribe.php:6方法一的实现，通过临时修改ini的配置值，default_socket_timeout默认为60s，default_socket_timeout为socket的超时参数stream，即socket流从建立到传输再到关闭的整个过程必须在该参数设置的时间内完成，如果不能完成，则PHP会自动结束socket并返回警告。第二种方法是修改redis配置项，所以只对redis连接生效。与方法一相比，不会对其他方法产生意想不到的影响。批量订阅redis的psubscribe支持通过模式匹配批量订阅，订阅方法回调函数写函数名或者redis->psubscribe(['my*'],array(newTestCall(),'psubscribe'));//回调函数是类中的一个方法，类名写自己定义的classsubscribe.phpconnect("127.0.0.1",6379);$redis->setOption(Redis::OPT_READ_TIMEOUT,-1);//匹配方式一：发布可用$redis->publish('mymest','这是一条消息');//$redis->psubscribe(['my*'],'psubscribe');//匹配方式二：发布可用$redis->publish('mydest','thisisamessage');//$redis->psubscribe(['my?est'],'psubscribe');//匹配方式三：发布可用$redis->publish('myaest','thisisamessage');或者$redis->publish('myeest','这是一条消息');$redis->psubscribe(['my[ae]est'],'psubscribe');函数psubscribe($redis,$pattern,$chan,$msg){echo"Pattern:$patternn";echo"频道:$chann";echo"Payload:$msgn";}模式匹配规则支持以下类型，以hello为例：h?llo订阅hello，hallo和hxlloh*llo订阅hllo和heeeelloh[ae]llosubscribestohelloandhallo,butnothillo特殊字符使用escapepubsub方法引入public函数pubsub(argument)pubsub获取pub/sub系统的信息，$keyword可以是"channels","numsub",or"numpat",三种类型，传入不同的关键字返回的数据是不同的*$redis->pubsub('channels');//Allchannels获取所有通道并返回一个数组*$redis->pubsub('channels','*pattern*');//只是频道匹配你的模式，返回匹配模式的频道*$redis->pubsub('numsub',array('chan1','chan2'));//获取'chan1'和'chan2'的订阅者数量//返回每个订阅频道的数量，返回一个数组*$redis->pubsub('numpat');//获取模式订阅者数量获取模式匹配方法的订阅以上内容希望对大家有所帮助，很多PHPer在进阶的时候总会遇到一些问题和瓶颈。业务代码写多了，就会没有方向感。我不知道从哪里开始改进。为此，我整理了一些PHP进阶、架构视频资料和大厂PHP面试PDF|免费可以关注公众号：PHP开源社区
