скелет асинхронного демона.
Для системы очередей используются системные очереди линукса. (CentOS, Убунту они уже сконфигурены, в других дистрибах линуксов может потребоваться конфигурирование очередей).
TO DO: сделать мультитридинг
использование класса двумя путями:
- через наследование, тогда нужно переопределить функцию run() которая выполняется для каждого входящего сообщения,
- через замыкание, как в текущем воркере.
Для обхода очереди сообщений сделал функцию-генератор responses, возвращающий yield.
Для примера что может делать демон использовал pear класс HTTP_Request2, поэтому нужно pear install HTTP_Request2-2.3.0
Запуск сервера пока без демонизации, просто:
# /opt/plesk/php/7.0/bin/php -f worker.php
Для примера файл client.php Клиент должен располагаться на этой же машине, вызываться через http, например, как часть фреймворка