tp5er/think-queue-amqp

amqp(RabbitMQ) connector for think-queue

1.0.0 2022-05-04 05:41 UTC

Requires

• php: >7.1
• ext-json: *

Requires (Dev)

• mockery/mockery: ^1.2.3
• php-amqplib/php-amqplib: ^2.12|^3.0
• phpunit/phpunit: ^6|^7|^8|^9
• topthink/think-queue: ^3.0

MIT

• queue
• rabbitmq
• message
• think-queue

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