php amqplib安装配置教程-乐工具技术知识

amqplib 是一个用于与 RabbitMQ 交互的 PHP 库。RabbitMQ 是一个开源的消息代理软件，用于通过轻量级和可靠的方式在服务器之间进行消息传递。以下是安装和配置 amqplib 的教程：

安装 RabbitMQ

首先，确保你已经安装了 RabbitMQ。如果没有，请参考 RabbitMQ 官方文档（https://www.rabbitmq.com/download.html）进行安装。

安装 Composer

amqplib 使用 Composer 进行包管理。如果你还没有安装 Composer，请按照以下步骤进行安装：

打开终端或命令提示符
运行以下命令：

curl -sS https://getcomposer.org/installer | php

将 composer.phar 移动到全局可执行路径，例如：

mv composer.phar /usr/local/bin/composer

创建新的 PHP 项目

打开终端或命令提示符
创建一个新的目录并进入该目录：

mkdir my_amqp_project && cd my_amqp_project

初始化 Composer

composer init

按照提示设置项目信息，或直接按回车使用默认值

安装 amqplib

运行以下命令安装 amqplib：

composer require php-amqplib/php-amqplib

编写 PHP 代码

现在你可以开始编写使用 amqplib 的 PHP 代码。以下是一个简单的示例：

创建一个名为 send.php 的文件，并添加以下内容：

channel();

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

$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');
echo " [x] Sent 'Hello World!'\n";

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

创建一个名为 receive.php 的文件，并添加以下内容：

channel();

$channel->queue_declare('hello', false, true, 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();