redis 队列 ¶
docker环境 ¶
- php
- phpredis (php依赖)
- redis(可用云平台,如阿里云)
- supervisor
安装依赖 ¶
sh
# 安装 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