RabbitMQ笔记

普通发送：

$ex->publish($message, $this->_queue->getName(), AMQP_MANDATORY, $params);

事务模式：
单个发送：

$ch->startTransaction();
try {
    $ex->publish($message, $this->_queue->getName(), AMQP_MANDATORY, $params);
    $ch->commitTransaction();
}
catch(AMQPConnectionException $e) {
    $ch->rollbackTransaction();
}

批量发送：

$loop_times = 10;
$ch->startTransaction();
for($i=0;$i<$loop_times;$i++) {
    try {
        $ex->publish($message, $this->_queue->getName(), AMQP_MANDATORY, $params);
        $ch->commitTransaction();
    }
    catch(AMQPConnectionException $e) {
        $ch->rollbackTransaction();
    }
}

// to be continued

Refer：
RabbitMQ专栏：https://blog.csdn.net/u013256…
php-amqp测试用例：https://github.com/pdezwart/p…