php连接rabbitmq例子-EW帮帮网

首先确保安装好了Rabbitmq服务器。

1.新建一个空白php项目，安装php客户端库：

composer require php-amqplib/php-amqplib

2.生产者

然后添加生产者代码 (producer.php)

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

// 创建到RabbitMQ服务器的连接[1,2](@ref)
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 声明一个队列，如果不存在则创建[1,2](@ref)
$queueName = 'hello';
$channel->queue_declare($queueName, false, false, false, false);

// 创建消息内容
$data = "Hello RabbitMQ! 时间: " . date('Y-m-d H:i:s');
$msg = new AMQPMessage($data);

// 发送消息到队列[1,2](@ref)
$channel->basic_publish($msg, '', $queueName);
echo " [x] 发送消息: '$data'\n";

// 关闭连接[1,2](@ref)
$channel->close();
$connection->close();

运行生产者：php producer.php

3.消费者

添加consumer.php。 消费者监听并处理队列中的消息：

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;

// 创建到RabbitMQ服务器的连接[1,2](@ref)
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 声明同一个队列[1,2](@ref)
$queueName = 'hello';
$channel->queue_declare($queueName, false, false, false, false);

echo " [*] 等待消息中. 按 CTRL+C 退出\n";

// 定义处理消息的回调函数[1,2](@ref)
$callback = function ($msg) {
    echo " [x] 收到消息: ", $msg->body, "\n";
};

// 开始消费队列中的消息[1,2](@ref)
$channel->basic_consume($queueName, '', false, true, false, false, $callback);

// 持续监听消息[1,2](@ref)
while ($channel->is_consuming()) {
    $channel->wait();
}

// 关闭连接（通常不会执行到这里）[1,2](@ref)
$channel->close();
$connection->close();

运行消费者：php consumer.php