tp5er/think-queue-amqp

think-queue 的 amqp(RabbitMQ)连接器

安装次数: 1,931

依赖关系: 0

建议者: 0

安全性: 0

星标: 0

关注者: 0

分支: 1

开放问题: 0

类型:think-extend

1.0.0 2022-05-04 05:41 UTC

This package is auto-updated.

Last update: 2024-09-20 07:06:30 UTC


README

支持阿里云:账号密码 -> 实例列表 -> 静态用户名密码

'amqp'   => [
    'type'    => 'amqp',
    'queue'   => 'thinkphp',
    'hosts'   => [
          [
          'host'     => '127.0.0.1',
          'port'     => 5672,
          'user'     => 'guest',
          'password' => 'guest',
          'vhost'    => '/',
          ],
    		],
    'options' => [
        'ssl_options' => [
        'ssl_on'      => false,
        'cafile'      => null,
        'local_cert'  => null,
        'local_key'   => null,
        'verify_peer' => true,
        'passphrase'  => null,
        ],
    ],
],

发布任务

think\facade\Queue::push($job, $data = '', $queue = null)think\facade\Queue::later($delay, $job, $data = '', $queue = null) 两个方法,前者立即执行,后者在 $delay 秒后执行

$job` 是任务名
单模块的,且命名空间是`app\job`的,比如上面的例子一,写`Job1`类名即可
多模块的,且命名空间是`app\module\job`的,写`model/Job1`即可
其他的需要些完整的类名,比如上面的例子二,需要写完整的类名`app\lib\job\Job2`
如果一个任务类里有多个小任务的话,如上面的例子二,需要用@+方法名`app\lib\job\Job2@task1`、`app\lib\job\Job2@task2

$data 是你要传到任务中的参数

$queue 队列名,指定这个任务在哪个队列上执行,同下面监控队列时指定的队列名,可不填

监听任务并执行

&> php think queue:listen

&> php think queue:work

有两种方式,具体的可选参数可以通过命令加 --help 查看

更多使用

详细信息请查看官方文档说明 https://github.com/top-think/think-queue/tree/3.0