public function actionCallback(): void
{
$this->setHeaders();
self::listener();
}
private function setHeaders(): void
{
set_time_limit(0);
header('Content-Type: text/event-stream');
header('Connection: keep-alive');
header('Cache-Control: no-store');
echo 'retry: 10000' . PHP_EOL;
}
public static function listener($timeout = 0): void
{
try {
$context = self::getAmqpConnection();
$queue = $context->createQueue('queue');
$subscriptionConsumer = $context->createSubscriptionConsumer();
$subscriptionConsumer->subscribe(
$context->createConsumer($queue),
function (PsrMessage $message, PsrConsumer $consumer) {
try {
$msg = json_decode($message->getBody());
// сюда заходит
$id = time();
$msg = json_encode($msg, JSON_THROW_ON_ERROR);
self::sendMsg($id, $msg);
$consumer->acknowledge($message);
} catch (\Throwable $e) {
}
}
);
$subscriptionConsumer->consume($timeout);
} catch (\Throwable $e) {
}
}
private static function sendMsg(string $id, string $msg): void
{
echo "data: $msg" . PHP_EOL;
echo "id: $id" . PHP_EOL;
echo PHP_EOL;
ob_flush();
flush();
}
Хочу реализовать server sent events на php - https://bigboxcode.com/php-server-sent-events-sse
Но при запуске слушателя очереди оно просто в бесконечном цикле и не отдает результат
Возможно ли из closure subscribe вывести echo?