CakePHP RabbitMQ 使用插件

CakePHP 是一个 PHP Web 应用程序框架，可用于构建与 RabbitMQ 交互的 Web 应用程序。以下是如何在 CakePHP 中使用 RabbitMQ 的示例。

1. 安装 PHP AMQP 扩展

PHP AMQP 扩展为与 RabbitMQ 交互提供了一个 PHP 接口。您可以使用 PECL 通过运行以下命令来安装此扩展：

pecl install amqp

如果您收到错误 “Zend Extension Api No: 320190902 无法找到 autoconf”

运行更多命令。

brew install autoconf
brew install rabbitmq-c

Composer 需要 php-amqplib/php-amqplib。

2. 配置 RabbitMQ 连接

在您的 CakePHP 应用程序中，您可以在 app/config/bootstrap.php 文件中配置 RabbitMQ 连接。这是一个示例：

use Cake\Core\Configure;
use PhpAmqpLib\Connection\AMQPStreamConnection;

Configure::write('RabbitMQ', [
    'host' => 'localhost',
    'port' => 5672,
    'username' => 'guest',
    'password' => 'guest',
    'vhost' => '/',
]);

$connection = new AMQPStreamConnection(
    Configure::read('RabbitMQ.host'),
    Configure::read('RabbitMQ.port'),
    Configure::read('RabbitMQ.username'),
    Configure::read('RabbitMQ.password'),
    Configure::read('RabbitMQ.vhost')
);

这段代码在 Configure 对象中设置 RabbitMQ 连接参数，并创建一个新的 AMQPStreamConnection 对象。

3. 向 RabbitMQ 发送消息

要向 RabbitMQ 发送消息，您可以使用 PhpAmqpLib\Channel\AMQPChannel 类。这是一个示例：

use PhpAmqpLib\Message\AMQPMessage;

$channel = $connection->channel();

$exchangeName = 'my-exchange';
$queueName = 'my-queue';

$channel->exchange_declare($exchangeName, 'direct', false, true, false);
$channel->queue_declare($queueName, false, true, false, false);
$channel->queue_bind($queueName, $exchangeName);

$messageBody = 'Hello, RabbitMQ!';
$message = new AMQPMessage($messageBody);

$channel->basic_publish($message, $exchangeName);

$channel->close();

这段代码声明了一个交换器和一个队列，将队列绑定到交换器，创建一个新消息，并将消息发布到交换器。

4. 从 RabbitMQ 接收消息

要从 RabbitMQ 接收消息，您可以使用 PhpAmqpLib\Channel\AMQPChannel 类并定义一个回调函数来处理传入的消息。这是一个示例：

use PhpAmqpLib\Message\AMQPMessage; 
$callback = function ($message) {
    echo 'Received message: ' . $message->body . PHP_EOL;
};

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

while (count($channel->callbacks)) {
    $channel->wait();
}

这段代码设置了一个将消息体简单地回显到控制台的回调函数。然后，它在队列上设置一个消费者并等待传入的消息。

总而言之，使用 CakePHP 与 RabbitMQ 涉及配置 RabbitMQ 连接并使用 PhpAmqpLib 库发送和接收消息。RabbitMQ 还有许多其他功能和配置，CakePHP 框架也有许多其他功能和能力。

感谢您阅读这篇文章。希望您觉得它有帮助且易于理解。如果您对 CakePHP RabbitMQ 插件有任何反馈或问题，请在下面的评论中分享。我很乐意听取您的意见并进一步讨论这个话题。