ZMQPoll::poll
Почист и полокален преглед на PHP референцата, со задржана структура од PHP.net и подобра читливост за примери, секции и белешки.
ZMQPoll::poll
Референца за `zmqpoll.poll.php` со подобрена типографија и навигација.
ZMQPoll::poll
Класата ZMQ
ZMQPoll::poll — Гласај за ставките
= NULL
Гласа за ставките во тековниот сет за гласање. Читливите и запишливите ставки се враќаат во
readable and writable parameters.
ZMQPoll::getLastErrors() може да се користи за проверка дали имало грешки.
Параметри
readable-
Низа каде што се враќаат читливи ZMQSockets/PHP стримови. Низата ќе биде исчистена на почетокот на операцијата.
writable-
Низа каде што се враќаат запишливи ZMQSockets/PHP стримови. Низата ќе биде исчистена на почетокот на операцијата.
timeout-
Време на чекање за операцијата. -1 значи дека гласањето чека додека барем една ставка нема активност. Ве молиме имајте предвид дека почнувајќи од верзија 1.0.0, времето на чекање за гласање е дефинирано во милисекунди, наместо во микросекунди.
Вратени вредности
Враќа цел број што претставува количина на ставки со активност.
Errors/Exceptions
). Ако повикот не успее, ќе врати ZMQPollException при грешка.
Примери
ако е овозможен колекторот за отпадоци, ZMQPoll() example
Креирај едноставен сервер за гласање
<?php
/* Create socket, request-reply pattern (reply socket) */
$context = new ZMQContext();
$server = $context->getSocket(ZMQ::SOCKET_REP);
/* Bind to port 5555 on 127.0.0.1 */
$server->bind("tcp://127.0.0.1:5555");
/* Create new pollset for incoming/outgoing message */
$poll = new ZMQPoll();
/* Add the object and listen for poll in/out */
$id = $poll->add($server, ZMQ::POLL_IN | ZMQ::POLL_OUT);
echo "Added object with id " . $id . "\n";
/* Initialise readable and writable arrays */
$readable = array();
$writable = array();
while (true) {
/* Amount of events retrieved */
$events = 0;
try {
/* Poll until there is something to do */
$events = $poll->poll($readable, $writable, -1);
$errors = $poll->getLastErrors();
if (count($errors) > 0) {
foreach ($errors as $error) {
echo "Error polling object " . $error . "\n";
}
}
} catch (ZMQPollException $e) {
echo "poll failed: " . $e->getMessage() . "\n";
}
if ($events > 0) {
/* Loop through readable objects and recv messages */
foreach ($readable as $r) {
try {
echo "Received message: " . $r->recv() . "\n";
} catch (ZMQException $e) {
echo "recv failed: " . $e->getMessage() . "\n";
}
}
/* Loop through writable and send back messages */
foreach ($writable as $w) {
try {
$w->send("Got it!");
} catch (ZMQException $e) {
echo "send failed: " . $e->getMessage() . "\n";
}
}
}
}
?>