我正在使用 rabbitmq 队列从控制器获取数据,然后消费者服务处理数据并使用 php-excel 生成 excel 表。
我面临的问题是,如果只运行一个消费者,数据将在 Excel 工作表中被覆盖。如果我运行多个消费者,问题就基本解决了。
我使用直接作为 rabbitmq 类型和 luiggio excel 捆绑包用于 symfony2。
有没有人遇到过类似的问题?欢迎任何关于可能问题的提示。
//部分消费者代码
public function execute(AMQPMessage $msg)
{
$data = array();
$data = unserialize($msg->body);
if ($data['type'] == 'sometype') {
$this->excel->excelObj->getProperties()->setCreator("something");
$value = $this->excel->excelObj->setActiveSheetIndex(0);
$value->setCellValue('A1', 'Some Number');
$value->setCellValue('B1', 'Some Other Number');
$incr = 2;
foreach ($data['somedata'] as $datum) {
value->setCellValue('A'.$incr, $datum['that_number']);
value->setCellValue('B'.$incr, $datum['that_number']);
}
} else if ($data['type'] == 'sometype2') {
$this->excel->excelObj->getProperties()->setCreator("something");
$value = $this->excel->excelObj->setActiveSheetIndex(0);
$value->setCellValue('A1', 'Some Number2');
$incr = 2;
foreach ($data['somedata'] as $datum) {
value->setCellValue('A'.$incr, $datum['that_number']);
}
}
$this->excel->excelObj->getActiveSheet()->setTitle('Simple');
$this->excel->excelObj->setActiveSheetIndex(0);
$tempName = $data['type'] .microtime(). '.xls';
$this->excel->getStreamWriter()->write('/tmp/'.$tempName);
}