ZMQPoll::add()
向`ZMQPoll`对象添加一个`ZMQSocket`或一个文件描述符，以便将其包含在多路复用器中
ZMQPoll::add()函数用于向ZMQPoll对象添加一个ZMQSocket或一个文件描述符，以便将其包含在多路复用器中。
语法
public bool ZMQPoll::add ( ZMQSocket $entry [, int $type = ZMQ::POLL_IN ] ) : bool
参数
$entry：要添加的ZMQSocket对象或文件描述符。
$type（可选）：指定要监听的事件类型。默认为ZMQ::POLL_IN，表示监听可读事件。
返回值
成功时返回true，失败时返回false。
示例
$context = new ZMQContext();
$socket1 = new ZMQSocket($context, ZMQ::SOCKET_SUB);
$socket1->connect("tcp://localhost:5555");
$socket2 = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
$socket2->connect("tcp://localhost:5556");
$poll = new ZMQPoll();
$poll->add($socket1, ZMQ::POLL_IN); // 添加可读事件监听
$poll->add($socket2, ZMQ::POLL_OUT); // 添加可写事件监听
$readable = $writable = [];
$poll->poll($readable, $writable);
if (in_array($socket1, $readable)) {
// 处理可读事件
$message = $socket1->recv();
echo "Received message: $message\n";
}
if (in_array($socket2, $writable)) {
// 处理可写事件
$socket2->send("Hello, World!");
echo "Sent message\n";
}
在上面的示例中，我们创建了两个ZMQSocket对象，一个用于订阅消息，另一个用于推送消息。然后，我们创建了一个ZMQPoll对象，并使用add()函数将两个ZMQSocket对象添加到多路复用器中。在poll()函数中，我们传递了两个空数组用于接收可读和可写事件的结果。最后，我们使用in_array()函数检查哪个ZMQSocket对象处于可读或可写状态，并执行相应的操作。