以下是一个简单的PHP中使用AMQP的实例,其中包括了如何连接到RabbitMQ服务器、发布消息以及接收消息的步骤。
1. 安装PHP AMQP扩展
确保你的PHP环境中已经安装了AMQP扩展。你可以使用以下命令来安装:
```bash
sudo pecl install amqp
```
安装完成后,需要将`amqp.so`文件添加到PHP的扩展目录中。
2. 连接到RabbitMQ服务器
```php
require_once 'path/to/Amqp.php';
$connection = new AMQPConnection();
$connection->connect('127.0.0.1', 5672, 'guest', 'guest');
```
3. 创建交换机
```php
$channel = new AMQPChannel($connection);
$channel->declareExchange(new AMQPExchange($channel, 'example_exchange', AMQP_EX_TYPE_DIRECT, true));
```
4. 创建队列
```php
$queue = new AMQPQueue($channel);
$queue->setName('example_queue');
$queue->setFlags(AMQP_DURABLE);
$queue->declare();
$queue->bind('example_exchange', 'example_key');
```
5. 发布消息
```php
$message = new AMQPMessage('Hello, RabbitMQ!');
$message->setRoutingKey('example_key');
$channel->basicPublish('example_exchange', 'example_key', AMQP_DURABLE, false, $message);
```
6. 接收消息
```php
$channel->basicConsume('example_queue', '', false, true, false, false, function(AMQPMessage $message) {
echo $message->getBody() . "