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