3

我在使用 ZeroMQ 时遇到了一个奇怪的问题，其中一些消息被卡住了，而当新消息到达时才被卡住。就像新消息将卡住的消息推到门上一样（可怕的比较，我知道）。

我的代码很简单：

代表.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 条消息。有任何想法吗？

4

1 回答 1

1

我在这里不是 PHP 专家，但在猜测语法和功能。如果我错了请纠正我

echo $receiver->recv() . ' - ' . $receiver2->recv();

recv() 应该是一个阻塞调用。

  1. $receiver->recv()阻塞，直到收到一些消息。
  2. 但echo不会立即回显消息
  3. 你又被屏蔽了$receiver2->recv()
  4. 只有当您从另一个文件发送消息时才会回显工作，因为它正在等待$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

于 2012-06-22T21:56:49.883 回答