php+redis 实现发布订阅功能
版权声明：
本文为博主原创文章，转载请声明原文链接...谢谢。o_0。
更新时间：
2019-12-03 14:02:45
温馨提示：
学无止境,技术类文章有它的时效性,请留意文章更新时间,如发现内容有误请留言指出,防止别人"踩坑",我会及时更新文章
前言
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');
