AMQP Interop

このドライバは RabbitMQ のキューによって動作します。

amqp interop 互換のトランスポート、 例えば enqueue/amqp-lib パッケージを必要とします。

利点:

• amqp interop 互換のトランスポートであれば、何でも動作します。例えば、

  • PHP amqp extension に基づく enqueue/amqp-ext
  • php-amqplib/php-amqplib に基づく enqueue/amqp-lib
  • bunny に基づく enqueue/amqp-bunny

• 優先度をサポート

• 遅延をサポート

• TTR をサポート

• 試行回数をサポート

• 新しいオプション: vhost, connection_timeout, qos_prefetch_count 等々

• Secure (SSL) AMQP 接続をサポート

• DSN を設定できる: 例えば、amqp:, amqps: または amqp://user:pass@localhost:1000/vhost

構成例:

return [
    'bootstrap' => [
        'queue', // コンポーネントが自身のコンソール・コマンドを登録します
    ],
    'components' => [
        'queue' => [
            'class' => \yii\queue\amqp_interop\Queue::class,
            'port' => 5672,
            'user' => 'guest',
            'password' => 'guest',
            'queueName' => 'queue',
            'driver' => yii\queue\amqp_interop\Queue::ENQUEUE_AMQP_LIB,

            // または
            'dsn' => 'amqp://guest:guest@localhost:5672/%2F',

            // または、上記と同じ
            'dsn' => 'amqp:',
        ],
    ],
];

コンソール

キューに入れられたジョブを実行するためにコンソール・コマンドが使用されます。

yii queue/listen

listen コマンドが無限にキューを調べ続けるデーモンを起動します。キューに新しいタスクがあると、即座に取得され、実行されます。 このコマンドを supervisor または systemd によって適切にデーモン化するのが、 最も効率的な方法です。

Working with headers in messages

The setMessageHeaders attribute can be used to send random headers to the queue along with the message.

For example:

$queue = Yii::$app->queueTest;
$queue->setMessageHeaders = [
    'header1' => 'header-value1',
    'header2' => 'header-value2',
];
$queue->push(new TestJob());

Note! Existing headers will not be overwritten by default.