Реализация на Event + Pthreads

[ParkFramework]

Спасибо, за вашу работу.
Очень хотелось бы увидеть качественный пример исполнения данных примеров на в немного другой реализации, вместо модуля libevent использовать более качественный и удобный модуль Event (http://ua2.php.net/manual/ru/book.event.php)

вместо pcntl_fork, использовать Pthreads (http://docs.php.net/manual/ru/book.pthreads.php)

Или услышать ваше мнения про использования данных модулей, для этих задач?
Просто не хочется использовать тяжелые PHPDaemon и/или Ratchet.
Хочется самому реализовать, но сокеты и pcntl_fork довольно низко уровневое программирования и много кода, хочется использовать библиотеки более высокого уровня и на ООП.

[morozovsk]

Пожалуйста.
Сейчас моя библиотека по-умолчанию использует механизм socket_select, но также может использовать pecl/event или pecl/libevent. Для этого в конфиге нужно указать 'eventDriver' => 'event' или 'eventDriver' => 'libevent' соответственно.
pecl/event - это http://pecl.php.net/package/event, документация по этому модулю находится по ссылке, которую вы указали, т.е. http://ua2.php.net/manual/ru/book.event.php
Его поддержку я добавил, после того как убедился, что модуль libevent ведёт себя нестабильно.
Модуль pthreads я видел, но пока в планах нет добавлять его поддержку.
PHPDaemon и Ratchet действительно достаточно тяжёлые. Я не однократно рассматривал их как альтернативу моей библиотеки, но в итоге решил допиливать своё решение. Относительно недавно я сильно переработал свою библиотеку и выпустил вторую версию. Теперь использовать её ещё проще.
Пример: https://github.com/morozovsk/websocket/tree/master/samples/chat/server

[ParkFramework]

Да, модуль Pthreads требует PHP ZTS, работать будет только как модуль Apache, это конечно лишние для демона, но даёт возможность вместо fork использовать потоки, там очень прозрачное и удобное взаимодействия общения между parent и child.

Вот немного описания
http://habrahabr.ru/post/193270/

[ParkFramework]

Да, вместо callback думаю использовать Generator, это даст возможность не терять текущее состояния в методах.

[morozovsk]

Я использовал fork в основном для того чтобы обойти ограничение в 1024 соединения на один процесс и для реализации таймера. После использования модуля event необходимость в этом отпала.

[ParkFramework]

Модуль Event асинхронный, если РНР будет обрабатывать запросы в одном процессе (потоке) в результате в самом модуле Event, будет формироваться очередь ожидания, что понизит RPS для для всех пользователей, так же все это может нагружать только одно ядро процессора, остальные ядра могут простаивать. В общем чтобы не создавать очередь последовательной синхронной обработки, асинхронных запросов, нужно параллельно их выполнять, это можно сделать или через fork или в отдельных потоках.

[morozovsk]

... или в отдельных процессах без использования форка , что я и сделал во второй версии своей библиотеки. форк не подходит, по-тому что отдельные процессы придётся запускать в том числе на других серверах. Т.о. мастер может быть на одном сервере, а воркеры на других.

[ParkFramework]

Где в коде можно посмотреть реализацию создания отдельных процессов?

[morozovsk]

В коде нет реализации создания отдельных процессов (в том числе на других серверах). В коде есть взаимодействия запущенных процессов (в том числе на разных серверах). В конфиге мастера указываете сервисный сокет для работы с воркерами. В воркере указываете сокет для взаимодействия с мастером.
Запускаете мастер на одном сервере, запускаете воркеры на других серверах.
Пример: https://github.com/morozovsk/websocket/tree/master/samples/chat2/server

[ParkFramework]

Не совсем понял, как можно на одном сервере запустить, несколько процессов которые которые будут слушать один порт и асинхронно отвечать на запросы.
На практике, это выйдет наверно в то что первый процесс который запустится займет порт и будет забирать все запросы.
Или я чего-то не понимаю?

[morozovsk]

Всё верно. Эту проблему можно решить используя проксирование через nginx.

[ParkFramework]

Т.е запустить много воркеров, каждый на своем порту если это один сервер, и весь этот список воркеров добавить в upstream Nginx?

[morozovsk]

Всё верно.