PHP中如何操作RabbitMQ的方案和案例-小石头

“

在PHP中实现RabbitMQ消息队列的完整指南

作为现代应用开发中重要的消息代理工具，RabbitMQ与PHP的结合为构建高效的消息系统提供了强大支持。本文将详细介绍如何通过PHP实现RabbitMQ的集成，并分享关键实践技巧。

一、环境准备与安装

安装RabbitMQ服务器（推荐使用Docker快速部署）
通过Composer安装PHP客户端库：composer require php-amqplib/php-amqplib

二、基础消息队列实现

生产者示例代码


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

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

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

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

$message = new AMQPMessage('Hello World!', ['delivery_mode' => 2]);
$channel->basic_publish($message, '', 'task_queue');

echo "" [x] 消息已发送\n"";

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

消费者示例代码


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

use PhpAmqpLib\Connection\AMQPStreamConnection;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

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

$callback = function ($msg) {
    echo "" [x] 收到消息: "", $msg->body, ""\n"";
    $msg->ack();
};

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

while ($channel->is_consuming()) {
    $channel->wait();
}

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