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

Question

[e-hot]

Приветствую.
Никогда ранее не приходилось использовать в проектах на SF2 функционал событий, теперь вынужден это сделать, но... Поизучал материалы в инете - жуть как вся эта тема описана и у каждого по-своему - не получилось собрать единую "картинку" виденья Events в SF2, поэтому, если кто в состоянии указать что можно сделать в следующей ситуации:
1. Сервис в одном из своих методов по факту конкретного условия if должен сделать так, чтобы запустился метод другого сервиса с одним параметром из текущего. Ключевое слово - ЗАПУСТИЛСЯ - типа как будто сам. Понятно, что можно просто тупо запустить тот самый метод нужного сервиса, обратившись к нему из текущего метода, но тогда текущий метод текущего сервиса закончит работу только по факту окончания работы того запущенного метода нужного сервиса - а это мне не нужно, необходимо, чтобы запущенный другой процесс шел параллельно и "независимо" от текущего.
2. Другими словами - напрашивается ловля нужного события в системе, взятие параметра и запуск некого процесса в качестве сервиса с использованием переданного параметра.
3. Пока понял, что в методе текущего сервиса нужно прописать создание события, а запускающийся сервис будет являться слушателем или подписчиком - сервис надо так же превратить в слушателя. Обязательно ли создавать класс-слушатель и т.д.?
Кто может, разъясните этот весь процесс.
Заранее спасибо.

Answer 1

[Алексей Скобкин]

Поизучал материалы в инете - жуть как вся эта тема описана и у каждого по-своему - не получилось собрать единую "картинку"

Не надо никаких материалов в интернете. Есть официальная документация, которая нормально описывает суть работы событий в Symfony.

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

Что мешает вызвать из сервиса A сервис B?

Ключевое слово - ЗАПУСТИЛСЯ - типа как будто сам.

Типа как будто само ничего не запускается.

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

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

Пока понял, что в методе текущего сервиса нужно прописать создание события, а запускающийся сервис будет являться слушателем или подписчиком - сервис надо так же превратить в слушателя. Обязательно ли создавать класс-слушатель и т.д.?

Вам вообще по тому как вы описали события не обязательно использовать. Но если будете - нужно будет делать EventListener или EventSubscriber. Читайте документацию.

А вообще, ВОЗМОЖНО, вам нужны очереди. То есть, можно посмотреть в сторону RabbitMQ, ZeroMQ и т.п. Суть будет такая:
У вас есть сервер очередей и пул воркеров, которые постоянно опрашивают сервер очередей на предмет новых заданий.
В вашем коде на PHP сервис отправляет сообщение серверу очередей с параметрами задания и продолжает делать свою работу. В это же время один из воркеров пула получает это задание и начинает его обрабатывать. Но это всё происходит не в рамках одной сессии приложения Symfony, а грубо говоря, работают два отдельных приложения, которые связаны через сервер очередей: ваше приложение на Symfony, которое отправляет задание в очередь и воркер(ы), которые обрабатывают очередь (вообще могут быть написаны на другом языке).

Comments

[e-hot]

Спасибо за ответ. Для меня важен момент: т.е. даже применяя обработку событий, текущий метод текущего сервиса все равно закончит свою работу по факту окончания работы запущенного метода другого сервиса? Если это именно так, то - да, не мой вариант. А про сервер очередей - хорошая идея, когда-то вскользь касался Rabbit-а. В случае очереди, в итоге у меня все равно должен запускаться сервис в SF2, т.е. SF2 отправляет сообщ. серверу очередей, а сервер очереди в ответ запускает в FS2 необходимый сервис. Если пользовать такой подход, то какой сервер очереди подойдет больше для SF2 на Ubuntu 14? Спасибо.

[Алексей Скобкин]

e-hot:

Для меня важен момент: т.е. даже применяя обработку событий, текущий метод текущего сервиса все равно закончит свою работу по факту окончания работы запущенного метода другого сервиса?

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

В случае очереди, в итоге у меня все равно должен запускаться сервис в SF2, т.е. SF2 отправляет сообщ. серверу очередей, а сервер очереди в ответ запускает в FS2 необходимый сервис.

Это работает немного не так. Сервер очередей заведует очередью. А вы уже содержите два "приложения" (или "сервиса" - как вам угодно). Первый - ваше веб(или не веб)-приложение, которое даёт задания для выполнения в фоне. Второй - пул воркеров (или даже один воркер), которые выполняют эти задания запрашивая их из очереди одно за одним.

Если пользовать такой подход, то какой сервер очереди подойдет больше для SF2 на Ubuntu 14? Спасибо.

Вопрос некорректен во всём. Во-первых, как я уже сказал, у вас воркеры, которые обрабатывают задания могут быть вообще на Go написаны быть, например. То есть, Symfony2 тут ни при чём. Во-вторых, надо выбирать инструмент под задачу, а не под инструмент. Почитайте про разные серверы очередей и выберите тот, который решает ваши задачи. Например, если для ваших задач нужна самая простая очередь - выбирайте тот, который проще настроить. В принципе, если обнаружите какие-то проблемы, при грамотном проектировании мигрировать с одного сервера очередей на другой будет не очень сложно.

[e-hot]

Спасибо за подсказки - буду уже нацеленно изучать тему очередей и Event Dispetcher. При этом я нашел еще один способ запараллеливания процесса - если кому поможет :), только он у меня получается не совсем профессиональный наверное и будет происходить не только серверно, но и клиентски:
в моем проекте на конкретной странице выводится конкретный параметр, поэтому я могу смотреть его наличие по факту загрузки самой страницы javascript-ом ( jquery ) и если параметр есть, то передавать его на сервер через ajax POST-ом в нужный сервис, который уже будет работать с полученным параметром - по крайней мере минимум кода и возни - функция на jquery - пара строк, маршрут в routing.yml - тоже пара строк, метод в контроллере запускает метод сервиса - тоже пара строк - как-то вот так

[Алексей Скобкин]

e-hot: При этом вы даёте клиенту видеть, что происходит внутри приложения и, что хуже, модифицировать данные и влиять на процесс.