php amqplib如何实现消息持久化

要使用php的amqplib库实现消息持久化，你需要在创建队列和交换机时设置一些参数。以下是一个简单的示例：

1. 首先，确保已经安装了amqplib库。如果没有，请使用以下命令安装：

composer require php-amqplib/php-amqplib 

2. 创建一个名为publisher.php的文件，用于发送持久化消息：

<?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->exchange_declare('persistent_exchange', 'direct', false, true, false);  // 创建一个持久化的队列 $channel->queue_declare('persistent_queue', false, true, false, false);  // 将队列绑定到交换机 $channel->queue_bind('persistent_queue', 'persistent_exchange');  // 创建一个持久化的消息 $msg = new AMQPMessage('Hello, persistent message!', array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT));  // 发送消息到交换机 $channel->basic_publish($msg, 'persistent_exchange');  echo "Sent persistent message!\n";  $channel->close(); $connection->close(); 

3. 创建一个名为consumer.php的文件，用于接收持久化消息：

<?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection;  $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel();  // 创建一个持久化的队列 $channel->queue_declare('persistent_queue', false, true, false, false);  echo "Waiting for messages...\n";  $callback = function ($msg) {     echo 'Received: ', $msg->body, "\n"; };  // 消费持久化消息 $channel->basic_consume('persistent_queue', '', false, true, false, false, $callback);  while ($channel->is_consuming()) {     $channel->wait(); }  $channel->close(); $connection->close(); 

4. 运行publisher.php文件发送持久化消息：

php publisher.php 

5. 运行consumer.php文件接收持久化消息：

php consumer.php 

这样，你就成功地使用php的amqplib库实现了消息持久化。当RabbitMQ服务器重启后，持久化的消息仍然会存在。