RabbitMQとPHP連携：基本と実装方法を解説

1年 ago
陽, 向宇
1 minute

PHP RabbitMQは、PHPアプリケーションでメッセージキューを実装するためのツールです。以下は、PHP RabbitMQを使用する一般的な手順です。

  1. 最初に、RabbitMQサーバーをインストールして起動する必要があります。
  2. PHPのRabbitMQライブラリをインストールするには、Composerを使用してインストールすることができます。例えば、以下のようにします：
composer require php-amqplib/php-amqplib
  1. PHPアプリケーション内で、RabbitMQサーバーへの接続チャネルを作成する必要があります。例えば：
require_once __DIR__ . '/vendor/autoload.php';

$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
  1. キューを作成し、そのキューにメッセージを送信します。
$channel->queue_declare('hello', false, false, false, false);

$msg = new PhpAmqpLib\Message\AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');

echo " [x] Sent 'Hello World!'\n";

$channel->close();
$connection->close();
  1. メッセージをキューから受け取る：
$channel->queue_declare('hello', false, false, false, false);

echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

$callback = function ($msg) {
  echo " [x] Received ", $msg->body, "\n";
};

$channel->basic_consume('hello', '', false, true, false, false, $callback);

while ($channel->is_consuming()) {
    $channel->wait();
}

$channel->close();
$connection->close();

これはPHP RabbitMQを使用した基本的な手順です。コードは必要に応じてカスタマイズや調整が可能です。

bannerAds