redis 队列 ¶

docker环境 ¶

php
phpredis （php依赖）
redis（可用云平台，如阿里云）
supervisor

安装依赖 ¶

# 安装 woker
composer require shiyun/php-worker
# 安装 queue
composer require shiyun/php-queue

# 安装 woker
composer require shiyun/php-worker
# 安装 queue
composer require shiyun/php-queue

配置 ¶

配置文件位于 config/shiyun/queue.php

php

return [   
    // 驱动类型，可选择 sync(默认):同步执行，database:数据库驱动,redis:Redis驱动//或其他自定义的完整的类名
    'default'    => 'redis1',
    'connection' => [
        'redis1' => [
            'connect_type' => 'redis',
            'connect_host' => '127.0.0.1',
            'connect_port' => '6379',
            'connect_user' => 'xxxxx',
            'connect_password' => 'xxx123123',
        ]
    ]
];

return [   
    // 驱动类型，可选择 sync(默认):同步执行，database:数据库驱动,redis:Redis驱动//或其他自定义的完整的类名
    'default'    => 'redis1',
    'connection' => [
        'redis1' => [
            'connect_type' => 'redis',
            'connect_host' => '127.0.0.1',
            'connect_port' => '6379',
            'connect_user' => 'xxxxx',
            'connect_password' => 'xxx123123',
        ]
    ]
];

消费者 ¶

开发流程 ¶

生产者

创建 addons\company\module\jobs\XxxProducer.php

消费者

创建 addons\company\module\jobs\XxxConsumer.php

启动 ¶

测试 ¶

浏览器打开 http://10yun.host/index/MyQueue/index，添加任务完成