ZMQSocket::recv

(PECL zmq >= 0.5.0)

ZMQSocket::recv ā€” Recebe uma mensagem

DescriĆ§Ć£o

public function ZMQSocket::recv(int $mode = 0): string

Recebe uma mensagem a partir de um socket. Por padrĆ£o a recepĆ§Ć£o serĆ” bloqueada atĆ© que uma mensagem esteja disponĆ­vel a menos que a constante ZMQ::MODE_DONTWAIT seja usada. A constante ZMQ::SOCKOPT_RCVMORE pode ser usada para receber mensagens de mĆŗltiplas partes. Consulte ZMQSocket::setSockOpt() para mais informaƧƵes.

ParĆ¢metros

mode

Passa indicadores para a recepĆ§Ć£o de mensagens de mĆŗltiplas partes ou operaƧƵes nĆ£o bloqueantes. Consulte as constantes ZMQ::MODE_*.

Valor Retornado

Retorna a mensagem. Se ZMQ::MODE_DONTWAIT for usada e a operaĆ§Ć£o for bloqueante, false deve ser retornado.

Erros/ExceƧƵes

LanƧa ZMQSocketException em erros.

Exemplos

Exemplo #1 Um exemplo de envio/recepĆ§Ć£o

Envio / recepĆ§Ć£o nĆ£o bloqueantes

<?php

/* Cria um novo objeto de enfileiramento, Ʃ necessƔrio existir um servidor na outra ponta */
$fila = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_REQ);
$fila->connect("tcp://127.0.0.1:5555");

/* Atribui o socket 1 Ć  fila, envia e recebe */
$tentativas = 5;
$enviando = true;

/* Inicia um laƧo */
do {
try {
/* Tenta enviar / receber */
if ($enviando) {
echo "Enviando mensagem\n";
$fila->send("Isso Ć© uma mensagem", ZMQ::MODE_DONTWAIT);
$enviando = false;
} else {
echo "Obteve resposta: " . $fila->recv(ZMQ::MODE_DONTWAIT) . "\n";
break;
}
} catch (ZMQSocketException $e) {
/* EAGAIN significa que a operaĆ§Ć£o foi bloqueada, tentar novamente */
if ($e->getCode() === ZMQ::ERR_EAGAIN) {
echo " - Obteve EAGAIN, tentando novamente ($tentativas)\n";
} else {
die(" - Erro: " . $e->getMessage());
}
}
/* DƔ uma pausa durante as operaƧƵes */
usleep(5);
} while (--$tentativas);
?>

O exemplo acima produzirĆ” algo semelhante a:

Enviando mensagem
 - Obteve EAGAIN, tentando novamente (4)
Obteve resposta: Isso Ć© uma mensagem

Melhore Esta PƔgina

Aprenda Como Melhorar Esta PĆ”gina ā€¢ Envie uma SolicitaĆ§Ć£o de ModificaĆ§Ć£o ā€¢ Reporte um Problema
ļ¼‹adicionar nota

Notas de UsuƔrios

NĆ£o hĆ” notas de usuĆ”rios para esta pĆ”gina.