php+redis 实现发布订阅功能

来源:赵克立博客 分类: PHP 标签:RedisPHP发布时间:2019-12-03 11:26:46最后更新:2019-12-03 14:02:45浏览:474
版权声明:
本文为博主原创文章,转载请声明原文链接...谢谢。o_0。
温馨提示:
技术类文章有它的时效性,请留意文章更新时间以及软件的版本
更新时间:
2019-12-03 14:02:45

前言

redis实现消息队列

redis可以实现发布订阅和消息队列的功能。两者的区别在于

  • 订阅者可以是多个,且可以同时处理发布上来的消息,如果订阅者不在线(服务没有启动)消息将丢失,消息没有持久化。发布和订阅是一块执行的,缺少一个直接忽略这个消息

  • 消息队列只能有一个客户端来处理,处理完之后消息就被标记或删除,即使服务端没有启动消息也不会丢失

  • 两者的使用场景要根据业务数据的准确度,敏感性决定,比如日志就可以用发布订阅来实现,丢失一点也没有关系


发布订阅代码示例

订阅消息

//不超时,否则会被php.ini中的超时限制时间
ini_set('default_socket_timeout', -1);
$redis = new Redis();
//创建一个长链接
$res = $redis->pconnect('127.0.0.1', 6379, 0);
$redis->subscribe(['test'], function ($instance, $channelName, $message) {
    // 回调函数,这里写处理逻辑
    echo $channelName, '==>', $message, PHP_EOL;
});


发布消息

$redis = new Redis();
// 第一个参数为redis服务器的ip,第二个为端口
$res = $redis->connect('127.0.0.1', 6379);
// test为发布的频道名称,hello,world为发布的消息
$res = $redis->publish('test', 'hello,world');


微信号:kelicom QQ群:215861553 紧急求助须知
点击更换验证码
Win32/PHP/JS/Android/Python