php amqp 如何使用-php教程-PHP中文网

php amqp 如何使用

爱谁谁

发布： 2024-08-13 13:16:05

原创

727人浏览过

要使用 AMQP，您需要遵循以下步骤：安装 AMQP 库。使用代码建立与 AMQP 代理的连接。创建一个频道。声明一个交换器。声明一个队列。将队列绑定到交换器。发送消息。使用回调函数接收消息。关闭连接。

php amqp 如何使用

PHP 中使用 AMQP 的方法

前言
AMQP（高级消息队列协议）是一种广泛使用的消息队列协议，允许应用程序彼此可靠地交换消息。本文将介绍如何在 PHP 中使用 AMQP。

使用 AMQP 的步骤

1. 安装 AMQP 库
首先，您需要使用 Composer 安装 AMQP 库：

立即学习“PHP免费学习笔记（深入）”；

<code>composer require php-amqplib/php-amqplib</code>

登录后复制

2. 建立连接
使用以下代码建立与 AMQP 代理的连接：

<code class="php">use PhpAmqpLib\Connection\AMQPStreamConnection;

$host = 'localhost';
$port = 5672;
$user = 'guest';
$password = 'guest';
$vhost = '/';

$connection = new AMQPStreamConnection($host, $port, $user, $password, $vhost);</code>

登录后复制

3. 创建频道
创建一个频道来发送和接收消息：

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

<code class="php">$channel = $connection->channel();</code>

登录后复制

4. 声明交换器
交换器负责将消息路由到正确的队列。声明一个交换器：

<code class="php">$exchangeName = 'my-exchange';
$exchangeType = 'direct';
$passive = false;
$durable = true;
$autoDelete = false;
$channel->exchange_declare($exchangeName, $exchangeType, $passive, $durable, $autoDelete);</code>

登录后复制

5. 声明队列
队列存储消息。声明一个队列：

<code class="php">$queueName = 'my-queue';
$passive = false;
$durable = true;
$exclusive = false;
$autoDelete = false;
$channel->queue_declare($queueName, $passive, $durable, $exclusive, $autoDelete);</code>

登录后复制

6. 绑定队列到交换器
将队列绑定到交换器，以便消息可以从交换器流向队列：

<code class="php">$bindingKey = 'my-binding-key';
$channel->queue_bind($queueName, $exchangeName, $bindingKey);</code>

登录后复制

7. 发送消息
使用以下代码发送消息：

<code class="php">$messageBody = 'Hello, world!';
$channel->basic_publish($messageBody, $exchangeName, $routingKey);</code>

登录后复制

8. 接收消息
使用回调函数接收消息：

<code class="php">$channel->basic_consume($queueName, '', false, true, false, false, function(AMQPEnvelope $envelope, AMQPMessage $message) {
    echo 'Received message: ' . $message->getBody() . PHP_EOL;
});</code>

登录后复制

9. 关闭连接
当您完成时，请关闭连接：

<code class="php">$channel->close();
$connection->close();</code>

登录后复制

以上就是php amqp 如何使用的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

php框架怎样进行Composer管理_php框架依赖管理的使用技巧 php composer 怎么用_PHP Composer依赖管理工具安装与使用方法 PHP Composer包版本依赖管理：已发布版本PHP兼容性约束的策略与限制如何使用Composer管理PHP依赖的详细教程？ php使用什么机制实现自动加载_php使用Composer管理依赖的原理