send.php 參考來源：[https://www.rabbitmq.com/tutorials/tutorial-one-php.html](https://www.rabbitmq.com/tutorials/tutorial-one-php.html) ``` //引用所需文件 require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; function send(){ //建立一個連接通道，聲明一個可以發送消息的隊列hello $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); // $exchangeName = 'aliexpress'; //交換機名 $exchangeName = 'ali'; //交換機名 $queueName = 'offline_product'; //隊列名稱 $routingKey = ''; //路由關鍵字(也可以省略) $channel->exchange_declare($exchangeName, 'direct', false, true, false); //聲明初始化交換機 $channel->queue_declare($queueName, false, true, false, false); //聲明初始化一條隊列 $channel->queue_bind($queueName, $exchangeName, $routingKey); //將隊列與某個交換機進行綁定，并使用路由關鍵字 $date = date('Y-m-d H:i:s'); //定義一個消息，消息內容為Hello World! $msg = new AMQPMessage('Hello World!'.$date); $channel->basic_publish($msg, $exchangeName, $routingKey); //發送完成后打印消息告訴發布消息的人：發送成功 echo " [x] Sent 'Hello World!'\n".$date; //關閉連接 $channel->close(); $connection->close(); } ``` https://blog.csdn.net/qq_34908844/article/details/88888719