我在ZeroMQ上遇到了一个奇怪的问题,其中一些消息被卡住,而新消息到达时才被卡住。就像新邮件将卡住的邮件推送到门上一样(我知道这很糟糕)。
我的代码很简单:
rep.php
$context = new ZMQContext;
$receiver = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$receiver->connect("tcp://localhost:8022");
$receiver2 = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$receiver2->connect("tcp://localhost:8024");
for (;;) {
echo $receiver->recv() . PHP_EOL;
echo $receiver2->recv() . PHP_EOL;
}
cnt.php和cnt2.php(相同的代码,不同的端口)
$context = new ZMQContext;
$work = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
$work->bind('tcp://*:8022');
$work->send('Hello World');
cnt.php发送到8022,cnt2.php发送到8024。它们不时执行,并将消息发送到rep.php。但是,某些消息被卡住了。如果我从cnt.php发送了4条消息,则什么也没收到,但是当我从cnt2.php发送1条消息时,我立即收到5条消息。有任何想法吗?
最佳答案
我不是PHP专家,但猜测语法和功能。如果我错了请指正我
echo $receiver->recv() . ' - ' . $receiver2->recv();
recv()应该是一个阻塞调用。
$receiver->recv()
阻止,直到接收到某些消息为止。 echo
不会立即回显消息$receiver2->recv()
$receiver2->recv()
由于要独立处理套接字recv(),因此应使用轮询或基于事件的异步I / O。
[尝试的解决方案]
$poll = new ZMQPoll();
$poll->add($receiver, ZMQ::POLL_IN);
$poll->add($receiver2, ZMQ::POLL_IN);
$readable = $writeable = array();
while(true) {
$events = $poll->poll($readable, $writeable);
foreach($readable as $socket) {
$message = $socket->recv();
echo $message, PHP_EOL;
}
}
改编自:http://zguide.zeromq.org/php:rrbroker
关于network-programming - 将邮件卡在ZeroMQ中,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11164474/