ในบาง page เราอาจจะต้องการที่จะใช้ queuing หลายตัว แทนที่จะ connect / disconnect หลาย ๆ ครั้ง เราสามารถใช้ batch / bulk ในการส่งช้อมูลให้ rabbitmq ในครั้งเดียวได้
<?php
include 'RabbitMQConnection.php';
use PhpAmqpLib\Message\AMQPMessage;
$exchange_name = 'customers';
$queue_name = 'invoices';
/**
* Declares exchange
*
* @param string $exchange_name
* @param string $type
* @param bool $passive
* @param bool $durable
* @param bool $auto_delete
* @param bool $internal
* @param bool $nowait
* @param array $arguments
* @param int $ticket
* @return mixed|null
*/
$channel->exchange_declare($exchange_name, 'fanout', false, true, false);
/**
* Declares queue, creates if needed
*
* @param string $queue
* @param bool $passive
* @param bool $durable
* @param bool $exclusive
* @param bool $auto_delete
* @param bool $nowait
* @param array $arguments
* @param int $ticket
* @return mixed|null
*/
list($queueName, $message_count, $consumer_count) = $channel->queue_declare($queue_name, false, true, false, false);
$properties = [
'content_type' => 'application/json',
'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT,
];
for ($a = 1; $a <= 1000; $a++) {
$datas = [
'id' => str_pad($a, 4, '0', STR_PAD_LEFT),
'rand' => rand(0, 100),
'time' => date('Y-m-d H:m:s'),
];
$msg_body = json_encode($datas);
$msg = new AMQPMessage($msg_body, $properties);
/**
* Publishes a message
*
* @param AMQPMessage $msg
* @param string $exchange
* @param string $routing_key
* @param bool $mandatory
* @param bool $immediate
* @param int $ticket
*/
$channel->basic_publish($msg, $exchange_name, $queue_name);
/**
* Publishes a message
*
* @param AMQPMessage $msg
* @param string $exchange
* @param string $routing_key
* @param bool $mandatory
* @param bool $immediate
* @param int $ticket
*/
$channel->basic_publish($msg, $exchange_name, $queue_name);
echo '<br>' . $msg_body;
}
/**
* Publish batch
*
* @return void
*/
$channel->publish_batch();
$channel->close();
$connection->close();
อ่านเพิ่มเติม