PHP постоянное соединение?

Question

[andrei_pro]

Всем привет.

Возможно ли сделать постоянное соединение с сервисом очередей? На высокой нагрузке возникают проблемы с коннектом.

Стек: nginx, php-fpm, rabbitmq

Answer 1

[Олег]

Сокеты
https://www.php.net/manual/ru/book.sockets.php

Answer 2

[Павел Беляев]

А вы вообще как работаете с очередями? Думаете с постоянным соединением не будет проблем с отваливанием?
1. Юзайте сишный клиент для RabbitMQ, а не PHP-библиотеку.
2. Юзайте подписку на очереди, а не долбите в цикле проверку обновлений, там просто делается подписка на обновления и в нее передается функция обработчик, которая молниеносно выполнится в момент получения сообщений. Пример можно глянуть вот тут
3. Можно проверять соединение примерно вот так (если у вас библиотека amqp)

if ($conn->isConnected()) {
    echo "Connected to the broker \o/";
}
else {
    echo "Cannot connect to the broker";
}

ну и реконектить...

4. Если несколько серверов, то наверно имеет смысл везде поставить локально RabbitMQ и настроить кластеризацию

Comments

[andrei_pro]

Сейчас сделал на ноде реализацию, проблем нет, но разные стеки трудно держать.

Кейс такой: есть апи, на него приходит 500 запросов в минуту, нужно данные пушить в очередь, можно с задержкой до часа.
Сразу сделал как тут https://github.com/php-enqueue/enqueue-dev/blob/ma...
Разрывы часто, время отклика по 200мс.
Затем сделал запись в файл и пуш пачкой - иногда баги и потеря сообщений в логике промежутка удаления и отправки файла, разрывы редко, долгий коннект.

Сделал на ноде + постоянное соединение, отправка по 1му сообщению. Ответ 1-2мс, аптайм 100% за месяц.

[Roll Back]

andrei_pro, можете попробовать https://github.com/amphp/socket