PHP实现redis订阅和发布（用于异步任务处理）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP实现redis订阅和发布（用于异步任务处理），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2441字，纯文字阅读大概需要4分钟。

内容图文

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

内容总结

以上是互联网集市为您收集整理的PHP实现redis订阅和发布（用于异步任务处理）全部内容，希望文章能够帮你解决PHP实现redis订阅和发布（用于异步任务处理）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端