PHP - Ratchet WebSockets for PHP - мультипоточность

Добрый день.
Я создал свой первый веб сокет как показано в примерах.
Столкнулся с проблемой что вебсокет по сути однопоточный.. то есть если есть несколько клиентов ждущих ответа от сервера то они получает их по очереди, а не параллельно.

Каким образом из Ratchet WebSockets for PHP можно получить многопоточный вебсокет, чтобы у каждого клиента мог обращаться к вебсокету не стоя в очереди.

Спасибо

 

Код (Text):

1. class API implements MessageComponentInterface {
2.  
3. public function __construct() {
4.  
5. }
6.  
7. public function onOpen(ConnectionInterface $conn) {
8.  
9. }
10.  
11. public function onMessage(ConnectionInterface $from, $msg) {
12.  
13.      // store data in db
14.      // some analysis (take several seconds)
15.      // back answer to client
16.  
17.      //How to back answer to all client in parallel ??
18. }
19.  
20. public function onClose(ConnectionInterface $conn) {
21.  
22.  
23. }
24.  
25. public function onError(ConnectionInterface $conn, \Exception $e) {
26.  
27.  
28. }
29.  
30.  
31.  
32. }

никогда не работал с форком раньше.

Вот пример кода, можно схематично изобразить как это должно выглядеть? спасибо

 

Долгая обработка запроса от клиента у меня как раз связана с тем что сервер ждет не появится ли определеная запись в базе данных в течение 5 секунд(например) от другого клиента . Если она есть сразу возвращает ответ клиент, если нет то ждет.

Я так понимаю что если бы база данных могла асинхроно возвращать ответ то это решило бы мою проблему с многопоточностью , можно было бы обойтись и одним потоком... Это сложно организовать?

 

Сделал как вы сказали, все работает.

Теперь такая проблема возникла.. Когда я закрываю терминал (ssh сессию), вебсокет закрывается.
Каким образом можно заставить его постоянно работать. И как посмотреть из терминала запущен ли он, чтобы снова запустить его при надобности?

Спасибо

 

И еще такой вопрос.

Код (Text):

1. public function onMessage(ConnectionInterface $from, $msg) {
2.  
3.     $pid = pcntl_fork();
4.     if ($pid == -1) {
5.         $this->myPrint("cant create fork");
6.     } else if ($pid) {
7.  
8.     } else {
9.         // ..... $result
10.         $from->send($result);
11.         // $pid = getmypid();
12.         // exit($pid);
13.  
14.     }
15.  
16. }

Если я закрываю дочерний процесс то клиент не получает сообщения...

Если их не закрывать то все работает но процессы плодяться



пробовал закрывать так:

Код (Text):

1. function _exit() {
2.     posix_kill(posix_getpid(), SIGTERM);
3. }

результат то же

ок, даемон для меня новое слово , пошел изучать. (я вообще для мобильных устройств программирую, но появилось надобность серверную часть написать)

upd: http://mithrandir.ru/professional/php/php-daemons.html благодаре этой статье с демонами разобрался.

 

Ganzal,

Спасибо за помощь!

А по проблеме отправки сообщения сокетом из дочернего процесса, перед смертью его можете что то посоветовать?
Если закрываю процесс сообщение не отправляется...

 

1. клиент( на javascript) подключается к вебсокету.
2. затем посылает сообщение вебсокету - json в виде строки.
3. вебсокет получает сообщение от клиент,делает форк, в дочернем процессе, лезет в базу данных, и возвращает тоже - json в виде строки.
4. закрываем дочерней процесс сразу после отправки собшения клиенту.

Если не делаю 4 этап то все работает, если закрываю дочерней процесс сообщение не отправляется. Хотя закрытие в коде после отправки.