基于yii2通过redis的订阅/发布者模式实现的消息队列
- 安装phpredis扩展
- 安装代码
composer require --prefer-dist johnnylei/yii-redis-queue
- 配置文件
'redis_queue'=>[
'class'=>'johnnylei\redis_queue\RedisQueue',
],
- 使用
// 前台发送
Yii::$app->redis_queue->publish('test', 'xxxxxxxxxxxxxxx');
// console里面监听,并且处理,设置监听不超时
ini_set('default_socket_timeout', -1);
Yii::$app->redis_queue->subscribe('test', function($instance, $channelName, $message) {
var_dump($message);
});