队列用法示例think-queue
https://packagist.org/packages/topthink/think-queue
需要php-amqplib
https://packagist.org/packages/php-amqplib/php-amqplib
-------------------------
测试使用的是thinkphp6，think-queue3
composer require topthink/think-queue
composer require php-amqplib/php-amqplib
然后用下载的代码覆盖即可，对比原think-queue有如下修改
1.修改了php think queue:work支持rabbitmq，上线尽量少用这个方式，
2.增加的php think queue:amqp，上线推荐使用。
3.修改了think queue:restart，用于向队列发送退出消息
4.增加了默认队列用于消费退出的消息
5.集群在配置里用英文逗号【,】将多个ip分隔开。
注意：消息手动确认放在delete()里了，操作完任务请务必调用$job->delete();。
.env增加配置
[AMQP]
HOSTNAME = 127.0.0.1
USERNAME = guest
PASSWORD = guest
HOSTPORT = 5672
VHOST = /
-------------------------
目前还在测试阶段。
thinkphp.zip
( 14.46 KB 下载：80 次 )
最佳答案
