Heim > Backend-Entwicklung > PHP-Tutorial > php使用rabbitmq无法持久化问题

php使用rabbitmq无法持久化问题

WBOY
Freigeben: 2016-06-23 14:01:01
Original
1092 Leute haben es durchsucht

$ename = "ename14";
$qname = "qname14";
$con = new AMQPConnection();
$con->connect();
$ch  = new AMQPChannel($con);


$ex    = new AMQPExchange($ch);
$ex->setName($ename);
$ex->setType(AMQP_EX_TYPE_DIRECT);
$ex->setFlags(2);
$ex->declare();

$q   = new AMQPQueue($ch);
$q->setName($qname);
$q->setFlags(2);
$q->declare();
$q->bind($ex->getName(),$qname);
$ex->publish(time(),$qname);

上面标红的地方。是声明需要持久化。但是重起服务器之后,队列里面的数据就不见了。有谁遇到过吗


回复讨论(解决方案)

$ex->publish 可以设置持久化的参数
参考 http://haili.me/archives/tag/RabbitMQ%E6%8C%81%E4%B9%85%E5%8C%96

Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage