如何制作一个简单的任务队列

我想用RabbitMQ和名为AMQP的PHP PECL扩展创建一个简单的任务队列。

我的目标很简单：生产者应该向包含需要处理的对象的信封的特定队列发送消息。

所有消费者都应该听从上述队列，并在消息到来时对其进行处理。我需要能够添加更多的消费者，并让RabbitMq以循环方式发送消息。

虽然这很容易找到python或java库的教程，但我找不到PHP的PECL库的教程。

我不太确定我是否应该绑定任何东西，我有一个使用自定义php库的工作示例，该库使用了"basic_publish和basic_sume"，但在PECL库中没有以这种方式实现。

到目前为止，我得到的是：出版商：

$oConfig = Zend_Registry::get('config');
$sQueue = $oConfig->amqp->validate_queue_name;
$oConnection = new AMQPConnection();
$oConnection->setLogin($oConfig->amqp->login);
$oConnection->setPassword($oConfig->amqp->pass);
$oConnection->setVhost($oConfig->amqp->vhost);
$oConnection->setPort($oConfig->amqp->port);
$oConnection->connect();
$oChannel = new AMQPChannel($oConnection);
$oExchange = new AMQPExchange($oChannel);
$sMsg = new stdClass();
$sMsg->nId = $p_nId;
$sMsg->nStatus= $p_nStatus;
try  {
  $oChannel->startTransaction();
  $bResponse = $oExchange->publish($sMgs,$sQueue);
  if (!$bResponse)  {
    echo "<h1>An error occured, the message can't be published</h1>";
    echo "<h3>Sorry i don't know why</h3>";
    exit;
  }
  $oChannel->commitTransaction();
}  catch (Exception $oException)  {
  echo "<h1>An error occured, the message can't be published</h1>";
  echo "<h3>See error below</h3>";
  echo "<pre>";
  echo print_r($oException->getMessage());
  echo "</pre>";
  exit;
}

工人

  $oConfig = Zend_Registry::get('config');
  $oConnection = new AMQPConnection();
  $oConnection->setLogin($oConfig->amqp->login);
  $oConnection->setPassword($oConfig->amqp->pass);
  $oConnection->setVhost($oConfig->amqp->vhost);
  $oConnection->setPort($oConfig->amqp->port);
  $oConnection->connect();
  $oChannel = new AMQPChannel($oConnection);
  $oQueue = new AMQPQueue($oChannel);
  $oQueue->declare($oConfig->amqp->validate_queue_name);
  function processMessage($oMessage, $oQueue) {
    $nId     = $msg->body->nId;
    $nStatus = $msg->body->nStatus;
    $oIniAct = $oActionMap->findBy('id',$nId);
    $sReply  = $oIniAct->updateStatusMisc($nStatus);
    if ($sReply->status == $nStatus)  {
      $oQueue->ack($sMsg['delivery_tag']);
    } else {
    $oQueue->nack($sMsg['delivery_tag'],AMQP_REQUEUE);
    }
  }
  $oQueue->consume("processMessage",AMQP_NOPARAM);

PHP文档告诉我consumer（）会为每个人锁定相应的线程？所以基本上我一次只能有一个工人在工作？我还看到人们正在绑定队列，但我看到的第一个带有基本消费的工人示例没有使用它。

正如你所看到的，我很困惑，任何帮助/指导/教程ASO。。。将有助于

感谢