Шаг за шагом к новым знаниям.

Маршрутизация. (используется библиотека pika для Python) Требования. В этом руководстве предполагается, что RabbitMQ  установлен  и запущен на localhost на стандартном порту (5672). Если вы используете другой хост, порт или учетные данные, настройки соединения желательно откорректировать. Где получить помощь? Если у вас возникли проблемы при прочтении данного руководства, вы можете  связаться  с разработчиками через список рассылки. В предыдущей части руководства мы построили простое приложение для логирования. Мы смогли передать лог-сообщения нескольким получателям. В этой части руководства мы собираемся добавить к нему функцию - сделать возможным подписку только на подмножество сообщений. Например, мы сможем отправлять только критические сообщения в файл журнала (чтобы сэкономить место на диске), При этом все еще можно будет печатать все лог-сообщения в терминале. Связывание. В предыдущем примере мы уже делали связывание. Вы можете в...

Публикация/подписка. (используется библиотека pika для Python) Требования. В этом руководстве предполагается, что RabbitMQ  установлен  и запущен на localhost на стандартном порту (5672). Если вы используете другой хост, порт или учетные данные, настройки соединения желательно откорректировать. Где получить помощь? Если у вас возникли проблемы при прочтении данного руководства, вы можете  связаться  с разработчиками через список рассылки. На предыдущем уроке мы создали обработчик очереди. Предполагается, что обработка очереди такова, что каждая задача доставляется только одному обработчику. В этой части мы будем делать совершенно по-другому - мы отправим сообщение нескольким потребителям. Этот шаблон известен как "публикация/подписка".  Чтобы проиллюстрировать этот шаблон мы создадим простую систему логирования. Она будет состоять из двух программ: первая будет отправлять лог-сообщения, а вторая будет принимать и выводить их. ...

 Обработка очередей (используется библиотека pika для Python) Требования. В этом руководстве предполагается, что RabbitMQ установлен и запущен на localhost на стандартном порту (5672). Если вы используете другой хост, порт или учетные данные, настройки соединения желательно откорректировать. Где получить помощь? Если у вас возникли проблемы при прочтении данного руководства, вы можете связаться с разработчиками через список рассылки. В первом уроке мы написали программу для отправки и приема сообщений из именованной очереди. В этом уроке мы создадим обработчик очереди, которая будет использоваться для распределения трудоемких задач среди нескольких сотрудников. Основная идея обработчика очередей (обработчика задач) заключается в том, чтобы не выполнять ресурсоемкую задачу(task) немедленно и не ожидать завершения ее выполнения. Вместо этого мы запланируем выполнить эту задачу позже. Мы инкапсулируем задачу в сообщение и отправим его в очередь. Процесс обраб...

Введение. RabbitMQ - это брокер сообщений: он принимает и пересылает сообщения. Вы можете представить себе его как почтовое отделение: когда вы кладете письмо в ваш почтовый ящик, вы можете быть уверены, что почтальон в конечном итоге доставит письмо получателю. В этой аналогии RabbitMQ - почтовый ящик, почтовое отделение и почтальон. Основное различие между RabbitMQ и почтой заключается в том, что он не имеет дела с бумагой, вместо этого он принимает, хранит и пересылает двоичные данные - сообщения. В RabbitMQ и технологии передачи сообщений используется некоторый жаргон. Producing(отправка) - отправка сообщения. Producer(поставщик) - программа, которая отправляет сообщения. Queue(очередь) - имя почтового ящика, который живет в RabbitMQ. Хотя сообщения передаются через RabbitMQ и ваши приложения, они могут храниться только в очереди. Очередь ограничена только размером оперативной памяти и дисков на сервере, и по сути является большим буфером сообщений. Многие по...