安装rabbit-mq，php联调rabbit-mq

要在PHP中使用RabbitMQ，你需要安装RabbitMQ服务器并使用PHP的AMQP扩展。以下是安装RabbitMQ和PHP AMQP扩展的步骤：

1. 安装RabbitMQ：

   • Linux: 使用包管理器安装，如在Ubuntu/Debian上：

     
     
     
     sudo apt-get update
     sudo apt-get install rabbitmq-server

   • macOS: 使用Homebrew：

     
     
     
     brew install rabbitmq

   • Windows: 下载并安装RabbitMQ从官网：https://www.rabbitmq.com/download.html

2. 安装PHP AMQP扩展：

   • Linux/macOS: 使用PECL安装：

     
     
     
     sudo pecl install amqp

     然后在你的php.ini文件中添加扩展：

     
     
     
     extension=amqp.so

   • Windows: 使用VCPackage或者下载预编译的DLL文件。
3. 重启你的PHP服务器以使扩展生效。

4. 使用PHP AMQP扩展与RabbitMQ交互：

   
   
   
   <?php
   $connection = new AMQPConnection([
       'host' => 'localhost',
       'port' => 5672,
       'vhost' => '/',
       'login' => 'guest',
       'password' => 'guest'
   ]);
   $connection->connect() or die("Cannot connect to the broker!\n");
    
   $channel = new AMQPChannel($connection);
   $exchange = new AMQPExchange($channel);
   $exchange->setName('exchange_name');
   $exchange->setType(AMQP_EX_TYPE_DIRECT); // DIRECT, FANOUT, TOPIC, HEADERS
   $exchange->setFlags(AMQP_DURABLE); // durable
   $exchange->declareExchange();
    
   // 发送消息
   $message = "Hello, RabbitMQ!";
   $exchange->publish($message, 'routing_key');
    
   // 关闭连接
   $connection->disconnect();
   ?>

确保RabbitMQ服务正在运行，并且根据你的环境调整连接参数。上面的代码示例创建了一个连接、通道、交换机，并发布了一条消息。根据你的具体需求，你可能需要创建队列、绑定交换机和队列，以及接收消息。