rabbitmq 队列 ¶

amqp协议
rabbitmq 服务

安装依赖 ¶

# 安装 woker
composer require shiyun/php-worker
# 安装 queue
composer require shiyun/php-queue
# 
composer require workerman/rabbitmq 
# 安装 amqp
composer require php-amqplib/php-amqplib 3.0
# 如需忽略版本安装 --ignore-platform-reqs
composer require --ignore-platform-reqs php-amqplib/php-amqplib

# 安装 woker
composer require shiyun/php-worker
# 安装 queue
composer require shiyun/php-queue
# 
composer require workerman/rabbitmq 
# 安装 amqp
composer require php-amqplib/php-amqplib 3.0
# 如需忽略版本安装 --ignore-platform-reqs
composer require --ignore-platform-reqs php-amqplib/php-amqplib

配置 ¶

在统一下 /config/shiyun/queue_amqp.php 配置
或者在模块下 /addons/moduleA/config/queue_amqp.php 配置

启动 ¶

启动守护进程运行

php worker:queue start -d

php worker:queue start -d

测试 ¶

访问 http://10yun.host/api_test/mq_send 发送 http://10yun.host/index.php/index/send