Laravel Rabbitmq курс. Брокеры сообщения php laravel. php-amqplib в php и laravel 

Ну это прям то, что доктор прописал! Спасибо за видео)

Спасибо большое за видео. Очень интересно.

Это самое лучшее что я видел, я посмотрел уроков 10 разных ничего никто нормально не объяснил. Тут и объяснили и пример показали, кароче топ, удачи в развитии канала Я подписан уже давно)

Найс! Полезное видео :)

Спасибо! Как всегда на высоте!

Спасибо за видео!)

Огромное спасибо за продолжение! Очень вовремя!!! Даёшь продолжение :)

То, что надо!

Всё как всегда на высшем уровне! Единственное конечно, что не понятно, как запустить в супервизоре. погуглил, но так и не нашел.

Отличное видео (и первое по Rabbit тоже). Спасибо за труд Хочу только уточнить по данным из Конфига и Env - в вашем случае данные берутся именно из конфига, а не из ENV. Чтобы брались из ENV надо в конфиге прописать 'host' => env('RABBITMQ_HOST')

Thanks a lot! 🙏

А я посмотрел ваше видео с базой по Rabbitmq, ну думаю - надо бы где-то почитать, как это в связке с Laravel должно работать, а сегодня захожу на главную канала, а там... мааать честная 🙂

Дякую!

Ну просто гений на ютубере. Очень легко смотрится, все на наглядных примерах, кайф! Единственное, чего я не понял, это можно ли в реббит слать сообщения напрямую из javascript? (также, как мы это делаем в случае с REST, посредством ajax). Насколько я понял, он в основном предназначен для взаимодействия между серверными сервисами (backend to backend).

Предлагаю автору ввиду его неоспоримой крутости открыть свое рекрутинговое it агентство) Я правильно понимаю что если consumer должен будет отдать какой-либо ответ то нужно сделать аналогичное обратное подключение? Брокер может использоваться только для подконтрольных сервисов или и для сторонних вроде почты или облака, если может то по какому принципу? Для углубления знаний о микросервисах было бы здорово реализовать небольшой проект с такой архитектурой в связке с брокером, чтобы как было сказано в одном из видео «все по взрослому»)

Не нашёл похожих вопросов в комментариях Допустим у нас 50 эндпоинтов апи в приложении и мы хотим внедрить раббит для целостности данных. Каждый эндпоинт, очевидно, реализует разную логику обработки данных. 1) Нам нужно для этого 50 очередей создать в раббите, которые будут висеть и ждать сообщений? 2) И как избежать конфликт имен очередей, если нам нужно одинаковую логику обработки делать, только в другом микросервисе? Ставить префикс имени микросервиса в названии очереди? Например такие очереди: 'mic1.addUser', 'mic2.addUser'. Получается так? 3) Создают ли новый обменник для каждого отдельного микросервиса, или все пихают в один? Интересно как на реальных проектах это работает ;) Спасибо)

Спасибо автору за курс. Хотел бы спросить, есть ли у кого-то опыт как сделать то же самое, только через докер?

Подскажите, чтобы использовать этот паке php-amqplib внутри docker конетейнеров он будет работать?

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

Вопрос, а что это за подключение висит на консьюмере? Это лонг пуллинг или периодичные запросы?

Брат, нужно сделать еще очередь, как ловить сообщения в очереди!!! Тема сисек не раскрыта полностью!!! Сделай продолжение! )))) Здоровье тебе и успехов в развитии канала!)

Заработало таки (не признавало is_open и версия ставилась 2.8).. попробовал запустить всё это в голой папке по композеру.json с "php-amqplib/php-amqplib": ">=3.0", так оно начало ругаться что не подключён php extension socket (никогда его не подключал), подключил, после чего ставилась уже не версия 2.8, а версия 3.5, на команду is_open уже не ругалось и работает всё как на видео.. до того был полный кошмар Норм видос, но всё-таки не хватает нескольких бестпракиксов на примере популярных прикладных задач с ларавелом...

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

а как реализовать ретрай если обработка не удалась в консюмере

Спасибо за видео! Все работает, но вот из очереди берет сразу все задания. Закинул 10к делаю запрос на получение и все 10к пропадают.... prefetch_count по разному пытался указывать, но ничего не меняется. Один из вариантов нагуглил такой: $channel->basic_qos(0, 2, true); // Устанавливаем prefetch_count равным 2

Оставь куда тебе задонатить можно. Или карту или донейшн алертсы какие-то и их виды

Я так и не понял - нахера ты в env прописал - что бы ни где это не использовать?

По стрелке видно что Consumer ссылается на queue (Документация во 2 разделе Work Queues). Соответственно можно создать еще 1 consummer который ссылается на ту же очередь указав такие же конфигурации. Пример: public function handle() { $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare('exchange_name', 'direct', false, true, false); $channel->queue_declare('queue_name', false, true, false, false); $channel->queue_bind('queue_name', 'exchange_name', 'user_key'); echo ' [*] Waiting for messages. To exit, press CTRL+C', " "; $callback = function ($msg) { echo ' [x] Received ', $msg->body, " "; $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']); }; $channel->basic_qos(null, 1, null); $channel->basic_consume('queue_name', '', false, false, false, false, $callback); while ($channel->is_consuming()) { try { $channel->wait(); } catch (\Exception $e) { // Обработка ошибки (вывод сообщения или логирование) echo 'An error occurred: ' . $e->getMessage() . " "; } } $channel->close(); $connection->close(); }

Есть $connection, есть непонятный $channel поверх $conection. Зачем эта вторая сущность? В конструкторе $channel разве нельзя прописать connection или в конструкторе connection создать полноценный объект channel? По типу, как сделано в других библиотеках: mysql_connect(): resource|false.