Англійська для обміну повідомленнями RabbitMQ

Модель AMQP RabbitMQ розділяє поняття «обмін», «черга» і «прив’язка» таким чином, що це точно, але незнайоме, якщо ви працювали тільки з простішими системами черг. Описувати помилку маршрутизації як « повідомлення не прибуло » набагато менш корисно, ніж називати, який обмін, прив’ язку або чергу насправді зазнали невдачі. Цей підручник містить словник для обговорення RabbitMQ.

Ключовий словник

** Exchange ** — компонент, який отримує повідомлення від виробників і маршрутизує їх до однієї або декількох черг на основі правил маршрутизації, сам не зберігаючи повідомлення. “Продюсер публікує повідомлення в обміннику orders, а не безпосередньо в чергу — обмінник вирішує, які черги дійсно отримують повідомлення.”

** Queue ** — буфер, у якому зберігаються повідомлення до їх обробки користувачем, єдиний компонент RabbitMQ, у якому зберігаються повідомлення.

• “Повідомлення накопичуються у черзі, оскільки користувач зазнав аварії годину тому і з того часу їх не обробляли.” *

** Прив’ язка ** — правило, яке з’ єднує обмін з чергою, за бажанням за допомогою ключа або шаблону маршрутизації, визначає, які повідомлення буде доставлено до якого місця.

• “Ми додали нове прив’ язування, щоб повідомлення з ключем маршрутизації order.cancelled також потрапляли до черги аналітики, а не лише до черги виконання.” *

** Ключ маршрутизації ** — це мітка, яку додає до повідомлення його виробник, цей ключ використовується обміном (особливо тематичним і прямим обміном) для визначення, які з прив’ язаних черг мають отримати повідомлення. “Ключ маршрутизації order.created.eu дозволяє нам маршрутизувати замовлення ЄС до черги, специфічної для регіону, без зміни біржі або споживача.”

** Підтвердження (ack) ** — сигнал, який споживач надсилає назад до RabbitMQ, підтверджуючи, що повідомлення було успішно оброблено, після чого RabbitMQ вилучає його з черги.

• “Консумер зазнав аварії перед надсиланням підтвердження, тому RabbitMQ передавав те саме повідомлення кожного разу, коли з’ єднувався знову.” *

** Черга мертвих листів (DLQ) ** — призначена черга, яка отримує повідомлення, які було відхилено, термін дії яких закінчився або обмеження повторних спроб було перевищено, цю чергу використовують для ізоляції проблемних повідомлень для подальшого перевірки.

• “Замість того, щоб втрачати неправильно сформовані повідомлення беззвучно, тепер їх пересилають до черги мертвих листів, щоб ми могли перевірити, що не так.” *

Звичайні фрази

• Чи дійсно повідомлення доходить до обміну, або воно не вдалося до того?»
• «Перевірте прив’язку — чи відповідає маршрутизуючий ключ насправді шаблону, якого ми очікуємо?»
• Чи споживач підтверджує повідомлення, або ж він застряг, передаючи те ж саме?»
• Чи варто це йти в чергу мертвих листів замість того, щоб просто бути скинутим на невдачу?»
• Який тип обміну це - прямий, тематичний або фан-аут? Це змінює поведінку маршрутизації ключів»

Приклади речення

Зневадження проблеми маршрутизації:

• “Повідомлення доходить до обміну в порядку, але воно не з’ являється в черзі — я думаю, що шаблон маршрутизації прив’ язки ключів не відповідає тому, що надсилає виробник.” *

Звітування про помилку надійності: “Ми знайшли петлю передоставки — споживач викидав виняток перед викликом ack, тому RabbitMQ передоставляв те ж саме повідомлення кожні кілька секунд, ніколи не залишаючи його в черзі мертвих листів.”

Пояснення рішення щодо архітектури колегі:

• “Ми використовуємо тематичний обмін замість прямого, оскільки ми хочемо, щоб декілька служб підписувалися на перетинаючийся підмножин подій за допомогою шаблонних ключів маршрутизації, а не просто на точне збігнення.” *

Професійні поради

• Використовуйте **« обмін » ** і **« черга » ** як окремі компоненти, ніколи не взаємозамінні — повідомлення може успішно досягти обміну і все одно ніколи не досягти черги, якщо прив’ язка неправильна.
• Під час надсилання повідомлення про ваду, пов’ язану з втратою повідомлень, вкажіть, чи йдеться про час публікації, час маршрутизації або час використання — кожен з цих параметрів вказує на іншу частину системи.
• Використовуйте « підтвердження », коли обговорюватиметься надійність — повідомлення, яке було передано без підтвердження, є зовсім іншою вада, ніж повідомлення, яке було вимкнено без повідомлення.
• Явно згадайте про чергу ** dead- letter ** під час розробки обробки помилок — маршрутизація помилкових повідомлень у цю чергу, замість відкидання або безкінечного повторення спроб, є стандартним шаблоном надійності.

Практичні вправи

1. Поясніть у двох реченнях, чому повідомлення може потрапити до обміну, але ніколи не потрапить до черги.
2. Написати звіт про помилку у одному реченні, який описує споживача, який застряг у циклі повторного надання.
3. Опишемо вашими словами призначення черги мертвих листів.

На практиці: Навігація та співпраця

Будьмо чесними - навіть з чітким розумінням концепцій RabbitMQ, ефективне спілкування в англомовному середовищі розробки може бути складним. Це не просто про знання слів; це про передачу ваших ідей чітко і точно в контексті професійного співробітництва. Уявіть, що ви працюєте над поліпшенням надійності критичного конвеєра обробки повідомлень. Ви реалізували механізм повторних спроб за допомогою обміну мертвими літерами, і тепер вам слід пояснити свої зміни старшому розробнику під час перегляду коду.

Ключовим є прийняття формулювання, яке є однозначним і дієздатним. Замість того, щоб сказати щось нечітке, наприклад, « Виправлено деякі проблеми з чергою », що може залишити їх з питанням, що саме * було * виправлено, спробуйте: « Я запровадив обмін мертвим листом для повідомлень, які зазнають невдачі після трьох повторних спроб, щоб запобігти втраті даних. Таким чином, ви гарантуєте, що проблемні повідомлення буде переправлено до окремої черги для дослідження і переобробки, зменшуючи вплив на головний потік. Зауважте, що у цьому розділі ви знайдете певну термінологію — « обмін мертвих листів », « повідомлення, що зазнали невдачі », « переобробка » — всі ці терміни ви вже вивчили у цій статті. Ще важливіше, що в ній описується * чому * зміна була внесена: « щоб запобігти втраті даних ». Це негайно встановлює логіку і дозволяє зосередитись на обговоренні потенційних крайніх випадків або альтернативних стратегій.

Іншим поширеним сценарієм є пояснення ваших змін у описі запиту на звантаження. Хороший опис PR - це не просто резюме; це міні-спеціфікація. Замість « Реалізована логіка повторних спроб » ви можете написати: « Цей PR реалізує надійний механізм повторних спроб для обробки повідомлень, використовуючи обмін мертвих листів для обробки постійних помилок. Система спробує передоставити повідомлення до п’ яти разів, перш ніж позначити їх як недоступні для доставки і переслати їх до черги « failed_ messages » для перегляду вручну. Це підвищує стійкість до перехідних проблем мережі і забезпечує цілісність даних. ” Цей рівень деталізації показує ваше розуміння, надає змогу рецензентам швидко зрозуміти реалізацію і зменшує ймовірність нерозуміння під час процесу рецензування. Пам’ятайте, що чіткість є найважливішою - не припускайте, що ваші колеги автоматично розуміють ваш намір; сформулюйте його чітко, використовуючи лексику, яку ви отримали.

Крім того, пам’ ятайте про фрази, що використовуються в розмовах Slack під час зневадження або обговорення потенційних проблем. Замість того, щоб сказати «Ця черга пошкоджена», більш продуктивним твердженням буде: «Я бачу постійні затримки в черзі «заказів» — повідомлення не підтверджуються в очікувані терміни. Я підозрюю, що може бути зв’язуюча проблема, що перешкоджає їм ефективно досягти споживачів. ” Використання точної мови, наприклад, «підтвердження» і посилання на конкретні черги допомагає зосередити зусилля по усуненню несправностей і уникнути неоднозначності.

Ось приклад того, як ви можете налаштувати обмін мертвих літер у RabbitMQ за допомогою rabbitmqctl :

rabbitmqctl -n my_exchange declare_exchange my_exchange type direct durable true
rabbitmqctl -n my_exchange create_dead_letter_exchange my_dead_letter_exchange routing_key '.*' durable true