php的rabbitmq队列持久化设置

2014-03-13 10:12 来源：www.chinab4c.com 作者：ecshop专家

   php的rabbitmq队列持久化设置，这个功能是一个十分伟大的功能，我们在ecshop注册发短信的时候，或者程序要发邮件的时候，往往会拖跨网络速度，在高并发的时候，这个时候我们将数据写到队列中，通过后断消费者去处理，能大大提高网络运行效率。以下是php针对rabbitmq队列的持久化处理。

   $ename = "ename15";
$qname = "queue15";

$con   = new AMQPConnection();
$con->connect();

$ch    = new AMQPChannel($con);

$ex    = new AMQPExchange($ch);
$ex->setName($ename);
$ex->setType(AMQP_EX_TYPE_DIRECT);
$ex->setFlags(AMQP_DURABLE);
$ex->declare();
$q = new AMQPQueue($ch);
$q->setName($qname);
$q->setFlags(AMQP_DURABLE);
$q->declare();
$q->bind($ename,$qname);

$res = $ex->publish("test",$qname,AMQP_NOPARAM, array('delivery_mode'=>2, 'priority'=> 9));
if ($res) {
    echo "push sucess";
} else {
    echo "faild";
}
$con->disconnect();

  来源：http://www.chinab4c.com