ZMQPoll::poll()函数—用法及示例

函数：ZMQPoll::poll()

适用版本：ZMQ extension 1.0.0及以上版本

用法： ZMQPoll::poll()函数用于等待指定的ZMQSocket对象上的事件。它将阻塞当前进程，直到满足指定的事件或超时。

语法： public static int ZMQPoll::poll ( array &$readable , array &$writable [, int $timeout = -1 ] )

参数：

• $readable：一个引用类型的数组，用于存储可读事件的ZMQSocket对象。
• $writable：一个引用类型的数组，用于存储可写事件的ZMQSocket对象。
• $timeout：可选参数，表示等待事件的超时时间（以毫秒为单位）。默认值为-1，表示永远等待。

返回值： 该函数返回已发生事件的ZMQSocket对象的数量。

示例：

$context = new ZMQContext();
$socket1 = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$socket1->bind("tcp://localhost:5555");

$socket2 = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
$socket2->connect("tcp://localhost:5555");

$poll = new ZMQPoll();
$poll->add($socket1, ZMQ::POLL_IN);
$poll->add($socket2, ZMQ::POLL_OUT);

$readable = $writable = array();

while (true) {
    $poll->poll($readable, $writable);

    foreach ($readable as $socket) {
        $message = $socket->recv();
        echo "Received message: $message\n";
    }

    foreach ($writable as $socket) {
        $socket->send("Hello, World!");
        echo "Sent message\n";
    }

    $readable = $writable = array(); // 清空数组，准备下一次循环
}

在上面的示例中，我们创建了一个PULL类型的ZMQSocket对象和一个PUSH类型的ZMQSocket对象，并将它们绑定和连接到同一个地址。然后，我们使用ZMQPoll对象将这两个socket对象添加到事件监听列表中，并指定监听的事件类型（POLL_IN和POLL_OUT）。 在主循环中，我们调用ZMQPoll::poll()函数等待事件的发生。一旦有可读或可写事件发生，该函数将返回，并将发生事件的socket对象存储在$readable和$writable数组中。我们通过遍历这两个数组来处理相应的事件，接收和发送消息。

请注意，在每次循环结束后，我们需要清空$readable和$writable数组，以准备下一次循环中的事件监听。这样可以确保只处理当前循环中发生的事件。

以上示例是一个简单的异步通信模式的实现，通过使用ZMQPoll::poll()函数，我们可以同时监听多个socket对象的事件，实现高效的并发处理。