Как использовать RabbitMqBundle в Symfony4?

Question

[Zudro]

Что сделал:
- поставил Symfony 4
- поставил RabbitMQ
- проверил отправку в очередь и из неё как написано в мануале на сайте RabbitMQ. Всё работает.
Дальше
- поставил RabbitMqBundle в Symfony

Создал такую настроку в config/old_sound_rabbit_mq.yaml

old_sound_rabbit_mq:
    connections:
        default:
            url: '%env(RABBITMQ_URL)%'
    producers:
        # use 'old_sound_rabbit_mq.task_producer' service to send data.
        task:
            connection:       default
            exchange_options: { name: 'task', type: direct }

Для проверки пробую отправить что то в очередь прям в контроллере.

<?php

namespace App\Controller;

use App\Entity\Setting;
use App\Form\SettingType;
use App\Repository\SettingRepository;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route;

/**
 * @Route("/setting")
 */
class SettingController extends AbstractController
{
public function edit(Request $request, Setting $setting): Response
{
    $form = $this->createForm(SettingType::class, $setting);
    $form->handleRequest($request);

    if ($form->isSubmitted() && $form->isValid()) {
        $this->getDoctrine()->getManager()->flush();

        //////////// Send msg to queue ////////////
            $msg = ['msg' => "Settings was changed!"];
            $this->get('old_sound_rabbit_mq.task_producer')->publish(serialize($msg));
        ////////////////////////////////////////////////

        return $this->redirectToRoute('setting_index');
    }

    return $this->render('setting/edit.html.twig', [
        'setting' => $setting,
        'form' => $form->createView(),
    ]);
}
}

Подозреваю, что проблема в том что я не до конца понимаю каких то процессов в Symfony.

Что я делаю не так?

Comments

[BoShurik]

Что за ошибка? Что ожидаете увидеть?

[Zudro]

BoShurik, Ошибка: Service "my_queue1" not found
Ожидаю что в очередь my_queue1 уйдёт сообщение.
Пологаю что делаю вобще что то не то, так как не подключил ни какие классы ни чего не делал чтобы этот метод был доступен в этом классе. Но как сделать правильно не знаю, потому что А) только изучаю Symfony Б) Все мануалы в интернете на Symfon3

[BoShurik]

Zudro, тут были?

[Zudro]

BoShurik, так от сюда и скопировал. этот же бандл и стоит. мне возможно не очень понятен смысл работы бандлов так как раньше только с ларавель работал. Можете тыкнуть носом что не так, уже весь интернет излазил.

Answer 1

[BoShurik]

Документация

class TaskController
{
    /**
     * @var ProducerInterface
     */
    private $producer;

    public function __construct(ProducerInterface $producer)
    {
        $this->producer = $producer;
    }

    public function indexAction($name)
    {
        $this->producer->publish('test');

        return new Response();
    }
}

# services.yaml
services:
    App\Controller\TaskController:
        arguments:
            - '@old_sound_rabbit_mq.task_producer'

либо (если producer только одни)

# services.yaml
services:
    OldSound\RabbitMqBundle\RabbitMq\ProducerInterface: '@old_sound_rabbit_mq.task_producer'

и понадеяться на autowire
Еще может пригодится: Local service binding

Comments

[Zudro]

Я так и написал, дальше то что?
Метода publish в объекте $this нет, get ссылается на трейт а не на очередь, old_sound_rabbit_mq.task_producer не назначился. Я явно что то упускаю.

[BoShurik]

Zudro, поправил ответ

[BoShurik]

Zudro, с чего вы взяли, что my_queue1 вообще должен работать? Если следовать документации, то вам нужен old_sound_rabbit_mq.task_producer
$this->get('') - получение сервиса из контейнера. В последних версиях симфони контейнер в контроллере не доступен, поэтому нужный вам сервис нужно получать через конструктор или через double dispatch в экшене

[Zudro]

BoShurik, я поменял my_queue1 на old_sound_rabbit_mq.task_producer (поменял в вопросе) а толку не, всё равно ни чего не зрабаотало. Судя по тишине вопросов на эту тему в интернете - как будет никто никогда не пробывал этот бандл по Symfony4.

В последних версиях симфони контейнер в контроллере не доступен

А как я, новичок в Симфони, об этом должен был узнать?! Во всех мануалах пишут именно так.

Сейчас попробую как вы переписали, и отпишусь. Тут тоже кое что не понятно.

[BoShurik]

А как я, новичёк в Симфони, об этом должен был узнать?! Во всех мануалах пишут именно так.

В мануалах, полагаю, предупреждают, о какой версии симфони идет речь.
А так в оффициальной документации это есть: https://symfony.com/doc/current/controller.html#fe...
Плюс можно смотреть нововведения в блоге: https://symfony.com/blog/category/living-on-the-ed...
либо в UPGRADE-x.md https://github.com/symfony/symfony/blob/4.4/UPGRAD...

[Zudro]

BoShurik, всё получилось, спасибо большое!) Впереди ещё много чего читать чтобы вьехать полностью, но сделать как обычно, нужно "вчера" .

Ещё несколько вопросов, если можно.
1. если task это имя эксченжа, то куда мне указать имя очереди в настройках?
exchange_options: { name: 'task', type: direct }

2. как должна выглядеть эта строка, если мне нужно поменять имя эксченжа например на "my_exchange1"?

OldSound\RabbitMqBundle\RabbitMq\ProducerInterface: '@old_sound_rabbit_mq.task_producer'

3. если у меня много разных методов в разных контроллерах отправляют одно и тоже сообщения, аля: {'entity': user, 'id': 1, action: 'was changed'} то это разные продюсеры или нет?

4. можно ли как то привязать отправку сообщения в очередь к событию изменение/удаление/создание entity чтобы не прописывать в каждом методе?

[BoShurik]

1. queue_options: { name: 'queue' } - это должно работать как для producers, так и для consumers
2. Эксченжы привязываются к продюсерам. Т.е. вам надо создать несколько продюсеров, у которых будут прописаны нужные вам эксченжы. Ну и имя соответственно будет old_sound_rabbit_mq.{producer-name}_producer
3. Если они в одну ту же очередь/экченж посылают - то один и тот же
4. Можно

[Zudro]

Спасибо, буду копать дальше. Статью про "Event Listeners and Subscribers" я уже читал - голова закипает. Кто то мне сказал что это можно как-то проще сделать.