Комментарии 5
процесс публикования
сложна и тяжела эта русска языка, но есть в ней слово "публикация"
Queue
Durable значит, что exchange сохранится после перезагрузки Rabbit.
По всей видимости, для раздела про очередь имелось ввиду "Durable значит, что queue сохранится после перезагрузки Rabbit".
Хорошая статья, спасибо.
Отличная статья!
Важное замечание: не следует использовать amqproxy для consumer, есть проблемы одностороннего разрушения соединений.
А вот столкнулись тут недавно с одной проблемой, связанной с проксированием, что через amqproxy, что через haproxy, через какое-то время перестают приходить ответы на rpc запросы в celery.
Если celery.broker и celery.backend указать на сам сервер rabbitMQ, то всё работает стабильно. Но через проси нет, задача создаётся в брокере, но от нескольких минут до нескольких часов проходит, и просто перестаёт приходить ответ. Причём через этого же самого брокера сообщения в очереди уходят, но механизм rpc ломается.
Было подозрение что столкнулись с "флаппингом каналов", про него тоже в статье упомянули, очень сильно увеличилось время ответа, и как раз порядок кол-ва примерно похож, но с проксированием ничего не получилось. Пока решилось переработкой логики продюсеров, но вопрос остался, что не так с проксированием ampq.
RabbitMQ: терминология и базовые сущности