PHP使用enqueue/amqp-lib实现rabbitmq任务处理

在PHP中使用enqueue/amqp-lib扩展实现RabbitMQ任务处理，涉及以下步骤：

1. 安装enqueue/amqp-lib扩展：
   通过Composer安装enqueue/amqp-lib扩展，这是一个与AMQP协议兼容的PHP库，它提供了与RabbitMQ交互的功能。

   composer require enqueue/amqp-lib

2. 连接到RabbitMQ：
   使用AmqpConnectionFactory创建一个连接工厂，并指定RabbitMQ服务器的连接参数，如主机名、端口、虚拟主机、用户名和密码。

   $factory = new AmqpConnectionFactory([
       'host' => '192.168.6.88', // host
       'port' => '5672', // port
       'vhost' => '/', // virtual host
       'user' => 'admin', // account
       'pass' => 'admin', // password
   ]);
   $context = $factory->createContext();

3. 声明主题（Exchange）：
   创建并声明一个主题，这是一个消息路由的中介，可以是不同类型的Exchange，如直接（direct）、主题（topic）、扇出（fanout）等。

   $exchangeName = 'exchange';
   $fooTopic = $context->createTopic($exchangeName);
   $fooTopic->setType(AmqpTopic::TYPE_FANOUT);
   $context->declareTopic($fooTopic);

4. 声明队列（Queue）：
   创建并声明一个队列，这是消息被存储和消费的地方。可以为队列设置持久化标志（FLAG_DURABLE），以便在RabbitMQ重启后队列仍然存在。

   $queueName = 'rabbitmq';
   $fooQueue = $context->createQueue($queueName);
   $fooQueue->addFlag(AmqpQueue::FLAG_DURABLE);
   $context->declareQueue($fooQueue);

5. 绑定队列到主题：
   将队列绑定到主题，这样发送到主题的消息就会根据绑定规则路由到队列。

   $context->bind(new AmqpBind($fooTopic, $fooQueue));

6. 发送消息：
   创建消息并通过生产者发送到队列。

   $message = $context->createMessage('Hello world!');
   $context->createProducer()->send($fooQueue, $message);

7. 消费消息：
   创建消费者并从队列接收消息。处理消息后，发送ACK应答给RabbitMQ以删除消息，或者使用NACK拒绝消息。

   $consumer = $context->createConsumer($fooQueue);
   while (true) {
       $message = $consumer->receive();
       if ($message) {
           // process a message
           $consumer->acknowledge($message);
       }
   }

8. 高级功能：

   • 发送优先消息：可以设置消息的优先级，优先级高的消息会更早地被消费者接收。

   • 发送延时消息：可以使用延迟策略设置消息的延时，以便消息在指定的延迟后被消费。

   • 清除队列消息：可以使用purgeQueue方法清除队列中的所有消息。

通过以上步骤，你可以使用enqueue/amqp-lib扩展在PHP中实现RabbitMQ的任务处理。这允许你构建异步消息驱动的应用，提高系统的可伸缩性和可靠性。