搜索热词

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脚本执行时间

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

$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",message:{"key":"key2",message:{"key":"key3",message:{"key":"key4","data":"testdata"}

转自：https://www.jmsite.cn/blog-586.html

总结

如果觉得编程之家网站内容还不错，欢迎将编程之家网站推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。